Update PublisherImplTest.java

googleapis · Jan 12, 2024 · 067706e · 067706e
1 parent 0c71e42
commit 067706e
Showing 1 changed file with 2 additions and 6 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
@@ -524,14 +524,10 @@ public void testResumePublish() throws Exception {
             .setEnableMessageOrdering(true)
             .build();
 
-    ApiFuture<String> future1 = sendTestMessageWithOrderingKey(publisher, "m1", "orderA");
-    ApiFuture<String> future2 = sendTestMessageWithOrderingKey(publisher, "m2", "orderA");
-
-    assertFalse(future1.isDone());
-    assertFalse(future2.isDone());
-
     // This exception should stop future publishing to the same key
     testPublisherServiceImpl.addPublishError(new StatusException(Status.INVALID_ARGUMENT));
+    ApiFuture<String> future1 = sendTestMessageWithOrderingKey(publisher, "m1", "orderA");
+    ApiFuture<String> future2 = sendTestMessageWithOrderingKey(publisher, "m2", "orderA");
 
     try {
       future1.get();