diff --git a/pubsub/cloud-client/src/main/java/com/example/pubsub/QuickstartSample.java b/pubsub/cloud-client/src/main/java/com/example/pubsub/QuickstartSample.java index 993df394203..fb4bd1fc72f 100644 --- a/pubsub/cloud-client/src/main/java/com/example/pubsub/QuickstartSample.java +++ b/pubsub/cloud-client/src/main/java/com/example/pubsub/QuickstartSample.java @@ -19,11 +19,7 @@ // [START pubsub_quickstart] // Imports the Google Cloud client library -import com.google.api.gax.core.RpcFuture; -import com.google.cloud.pubsub.spi.v1.Publisher; import com.google.cloud.pubsub.spi.v1.PublisherClient; -import com.google.protobuf.ByteString; -import com.google.pubsub.v1.PubsubMessage; import com.google.pubsub.v1.TopicName; public class QuickstartSample { @@ -36,26 +32,8 @@ public static void main(String... args) throws Exception { try (PublisherClient publisherClient = PublisherClient.create()) { publisherClient.createTopic(topic); } - System.out.printf("Topic %s:%s created.\n", topic.getProject(), topic.getTopic()); - // Creates a publisher - Publisher publisher = null; - try { - publisher = Publisher.newBuilder(topic).build(); - - //Publish a message asynchronously - String message = "my-message"; - ByteString data = ByteString.copyFromUtf8(message); - PubsubMessage pubsubMessage = PubsubMessage.newBuilder().setData(data).build(); - RpcFuture messageIdFuture = publisher.publish(pubsubMessage); - - //Print message id of published message - System.out.println("published with message ID: " + messageIdFuture.get()); - } finally { - if (publisher != null) { - publisher.shutdown(); - } - } + System.out.printf("Topic %s:%s created.\n", topic.getProject(), topic.getTopic()); } } // [END pubsub_quickstart] diff --git a/pubsub/cloud-client/src/test/java/com/example/pubsub/QuickstartSampleIT.java b/pubsub/cloud-client/src/test/java/com/example/pubsub/QuickstartSampleIT.java index 59cb5fcbc54..1f67b86a20d 100644 --- a/pubsub/cloud-client/src/test/java/com/example/pubsub/QuickstartSampleIT.java +++ b/pubsub/cloud-client/src/test/java/com/example/pubsub/QuickstartSampleIT.java @@ -75,6 +75,5 @@ public void testQuickstart() throws Exception { QuickstartSample.main(projectId); String got = bout.toString(); assertThat(got).contains("my-new-topic created."); - assertThat(got).contains("published with message ID"); } }