Skip to content

Commit

Permalink
test: Change logging
Browse files Browse the repository at this point in the history
  • Loading branch information
michaelpri10 committed May 14, 2024
1 parent 98fca09 commit 095c950
Showing 1 changed file with 5 additions and 5 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -531,7 +531,7 @@ public void testResumePublish() throws Exception {
assertFalse(future1.isDone());
assertFalse(future2.isDone());

System.out.println("Publish 1 and 2");
// System.out.println("Publish 1 and 2");

// This exception should stop future publishing to the same key
testPublisherServiceImpl.addPublishError(new StatusException(Status.INVALID_ARGUMENT));
Expand All @@ -542,14 +542,14 @@ public void testResumePublish() throws Exception {
future1.get();
fail("This should fail.");
} catch (ExecutionException e) {
System.out.println("Message 1 failed");
// System.out.println("Message 1 failed");
}

try {
future2.get();
fail("This should fail.");
} catch (ExecutionException e) {
System.out.println("Message 2 failed");
// System.out.println("Message 2 failed");
}

// Submit new requests with orderA that should fail.
Expand All @@ -561,15 +561,15 @@ public void testResumePublish() throws Exception {
fail("This should fail.");
} catch (ExecutionException e) {
assertEquals(SequentialExecutorService.CallbackExecutor.CANCELLATION_EXCEPTION, e.getCause());
System.out.println("Message 3 failed");
// System.out.println("Message 3 failed");
}

try {
future4.get();
fail("This should fail.");
} catch (ExecutionException e) {
assertEquals(SequentialExecutorService.CallbackExecutor.CANCELLATION_EXCEPTION, e.getCause());
System.out.println("Message 4 failed");
// System.out.println("Message 4 failed");
}

// Submit a new request with orderB, which should succeed
Expand Down

0 comments on commit 095c950

Please sign in to comment.