Merge pull request GoogleCloudPlatform#530 from GoogleCloudPlatform/pubsub_quickstart

jabubake · web-flow · commit 5e7373873c2a · 2017-02-21T09:04:15.000-08:00
removing publish from quickstart
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
@@ -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<String> 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
@@ -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");
   }
 }

Original file line number	Diff line number	Diff line change
`@@ -75,6 +75,5 @@ public void testQuickstart() throws Exception {`
`75`	`75`	`QuickstartSample.main(projectId);`
`76`	`76`	`String got = bout.toString();`
`77`	`77`	`assertThat(got).contains("my-new-topic created.");`
`78`		`- assertThat(got).contains("published with message ID");`
`79`	`78`	`}`
`80`	`79`	`}`