Skip to content

Commit

Permalink
fix: userKafkas Update, removing broken equals impl
Browse files Browse the repository at this point in the history
  • Loading branch information
secondsun authored and wtrocki committed Mar 31, 2021
1 parent 14d3533 commit dc312e5
Show file tree
Hide file tree
Showing 3 changed files with 3 additions and 21 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -89,21 +89,6 @@ public UserKafka setStatus(String status) {
return this;
}

@Override
public boolean equals(Object o) {
if (this == o) return true;
if (o == null || getClass() != o.getClass()) return false;

UserKafka userKafka = (UserKafka) o;

return id.equals(userKafka.id);
}

@Override
public int hashCode() {
return id.hashCode();
}

public String getUpdatedAt() {
return updatedAt;
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -51,7 +51,8 @@ public String getAccessToken(String accessTokenSecretName, String namespace)
throws ConditionAwareException {
try {
if (isNullOrEmpty(accessTokenSecretName, namespace)) {
throw new IllegalArgumentException("accessTokenSecretName and namespace must be provided and exist.");
throw new IllegalArgumentException(
"accessTokenSecretName and namespace must be provided and exist.");
}
var offlineToken = getOfflineTokenFromSecret(accessTokenSecretName, namespace);
var accessToken = exchangeToken(offlineToken);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -67,10 +67,6 @@ void doCreateOrUpdateResource(
userKafkas.add(userKafka);
});

if (userKafkas.equals(resource.getStatus().getUserKafkas())) {

} else {
resource.getStatus().setUserKafkas(userKafkas);
}
resource.getStatus().setUserKafkas(userKafkas);
}
}

0 comments on commit dc312e5

Please sign in to comment.