Update PublisherImplTest.java

googleapis · Jan 12, 2024 · f58238c · f58238c
1 parent e7c0c39
commit f58238c
Showing 1 changed file with 0 additions and 60 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
@@ -592,66 +592,6 @@ public void testResumePublish() throws Exception {
     shutdownTestPublisher(publisher);
   }
 
-  @Test
-  public void testPublishThrowExceptionForUnsubmittedOrderingKeyMessage() throws Exception {
-    Publisher publisher =
-        getTestPublisherBuilder()
-            .setExecutorProvider(SINGLE_THREAD_EXECUTOR)
-            .setBatchingSettings(
-                Publisher.Builder.DEFAULT_BATCHING_SETTINGS
-                    .toBuilder()
-                    .setElementCountThreshold(2L)
-                    .setDelayThreshold(Duration.ofSeconds(500))
-                    .build())
-            .setEnableMessageOrdering(true)
-            .build();
-
-    // Send two messages that will fulfill the first batch, which will return a failure.
-    testPublisherServiceImpl.addPublishError(new StatusException(Status.INVALID_ARGUMENT));
-    ApiFuture<String> publishFuture1 = sendTestMessageWithOrderingKey(publisher, "A", "a");
-    ApiFuture<String> publishFuture2 = sendTestMessageWithOrderingKey(publisher, "B", "a");
-
-    // A third message will fail because the first attempt to publish failed.
-    ApiFuture<String> publishFuture3 = sendTestMessageWithOrderingKey(publisher, "C", "a");
-
-    try {
-      publishFuture1.get();
-      fail("Should have failed.");
-    } catch (ExecutionException e) {
-    }
-
-    try {
-      publishFuture2.get();
-      fail("Should have failed.");
-    } catch (ExecutionException e) {
-    }
-
-    try {
-      publishFuture3.get();
-      fail("Should have failed.");
-    } catch (ExecutionException e) {
-      assertEquals(SequentialExecutorService.CallbackExecutor.CANCELLATION_EXCEPTION, e.getCause());
-    }
-
-    // A subsequent attempt fails immediately.
-    ApiFuture<String> publishFuture4 = sendTestMessageWithOrderingKey(publisher, "D", "a");
-    try {
-      publishFuture4.get();
-      fail("Should have failed.");
-    } catch (ExecutionException e) {
-      assertEquals(SequentialExecutorService.CallbackExecutor.CANCELLATION_EXCEPTION, e.getCause());
-    }
-  }
-
-  private ApiFuture<String> sendTestMessageWithOrderingKey(
-      Publisher publisher, String data, String orderingKey) {
-    return publisher.publish(
-        PubsubMessage.newBuilder()
-            .setOrderingKey(orderingKey)
-            .setData(ByteString.copyFromUtf8(data))
-            .build());
-  }
-
   @Test
   public void testErrorPropagation() throws Exception {
     Publisher publisher =