Skip to content

Commit

Permalink
Fix failing tests
Browse files Browse the repository at this point in the history
  • Loading branch information
shs96c committed Mar 12, 2020
1 parent 9f9f0e5 commit 7b8015a
Show file tree
Hide file tree
Showing 3 changed files with 3 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -277,7 +277,7 @@ private void refresh(NodeStatus status) {
LOG.fine("Refreshing: " + status.getUri());

// check registrationSecret and stop processing if it doesn't match
if (! Objects.equals(status.getRegistrationSecret(), registrationSecret)) {
if (!Objects.equals(status.getRegistrationSecret(), registrationSecret)) {
LOG.severe(String.format("Node at %s failed to send correct registration secret. Node NOT registered.", status.getUri()));
bus.fire(new NodeRejectedEvent(status.getUri()));
return;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -175,7 +175,7 @@ public void distributorShouldUpdateStateOfExistingNodeWhenNodePublishesStateChan
status.getMaxSessionCount(),
status.getStereotypes(),
ImmutableSet.of(new NodeStatus.Active(CAPS, new SessionId(UUID.randomUUID()), CAPS)),
"cheese");
null);

bus.fire(new NodeStatusEvent(crafted));

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -255,7 +255,7 @@ public void registeringTheCorrectRegistrationSecretWorks()

latch.await(1, SECONDS);

assertThat(latch.getCount()).isEqualTo(1);
assertThat(latch.getCount()).isEqualTo(0);
}


Expand Down

0 comments on commit 7b8015a

Please sign in to comment.