From aa6a256d77ceabf0800b75e5dc582061221f3d9e Mon Sep 17 00:00:00 2001 From: Mike Prieto Date: Tue, 14 May 2024 20:44:12 +0000 Subject: [PATCH] test: Remove logging --- .../cloud/pubsub/v1/PublisherImplTest.java | 16 ---------------- 1 file changed, 16 deletions(-) diff --git a/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/PublisherImplTest.java b/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/PublisherImplTest.java index 8edac56f7..b26bbde30 100644 --- a/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/PublisherImplTest.java +++ b/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/PublisherImplTest.java @@ -513,7 +513,6 @@ public void testEnableMessageOrdering_overwritesMaxAttempts() throws Exception { */ @Test public void testResumePublish() throws Exception { - // System.out.println("Starting testResumePublish"); Publisher publisher = getTestPublisherBuilder() .setBatchingSettings( @@ -531,8 +530,6 @@ public void testResumePublish() throws Exception { assertFalse(future1.isDone()); assertFalse(future2.isDone()); - // System.out.println("Publish 1 and 2"); - // This exception should stop future publishing to the same key testPublisherServiceImpl.addPublishError(new StatusException(Status.INVALID_ARGUMENT)); @@ -542,14 +539,12 @@ public void testResumePublish() throws Exception { future1.get(); fail("This should fail."); } catch (ExecutionException e) { - // System.out.println("Message 1 failed"); } try { future2.get(); fail("This should fail."); } catch (ExecutionException e) { - // System.out.println("Message 2 failed"); } // Submit new requests with orderA that should fail. @@ -561,7 +556,6 @@ 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"); } try { @@ -569,7 +563,6 @@ public void testResumePublish() throws Exception { fail("This should fail."); } catch (ExecutionException e) { assertEquals(SequentialExecutorService.CallbackExecutor.CANCELLATION_EXCEPTION, e.getCause()); - // System.out.println("Message 4 failed"); } // Submit a new request with orderB, which should succeed @@ -582,28 +575,19 @@ public void testResumePublish() throws Exception { assertEquals("5", future5.get()); assertEquals("6", future6.get()); - // System.out.println("Publish and receive 5 and 6"); - // Resume publishing of "orderA", which should now succeed publisher.resumePublish("orderA"); - // System.out.println("Resume publishing of orderA"); - ApiFuture future7 = sendTestMessageWithOrderingKey(publisher, "m7", "orderA"); ApiFuture future8 = sendTestMessageWithOrderingKey(publisher, "m8", "orderA"); testPublisherServiceImpl.addPublishResponse( PublishResponse.newBuilder().addMessageIds("7").addMessageIds("8")); - // System.out.println("Publish of 7 and 8"); - assertEquals("7", future7.get()); assertEquals("8", future8.get()); - // System.out.println("Receive 7 and 8"); - shutdownTestPublisher(publisher); - System.out.println("Ending testResumePublish"); } @Test