Update PublisherImplTest.java

googleapis · Jan 12, 2024 · 88a22eb · 88a22eb
1 parent f58238c
commit 88a22eb
Showing 1 changed file with 9 additions and 0 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
@@ -366,6 +366,15 @@ public void testBatchedMessagesWithOrderingKeyByNum() throws Exception {
     shutdownTestPublisher(publisher);
   }
 
+  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 testBatchedMessagesWithOrderingKeyByDuration() throws Exception {
     // Limit the batching timeout to 100 seconds.