Update LocalPubsubHelper to be compatible with beta emulators. (#992)

googleapis · May 6, 2016 · 6bc34ff · 6bc34ff
1 parent 7857986
commit 6bc34ff
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/gcloud-java-pubsub/src/main/java/com/google/cloud/pubsub/testing/LocalPubsubHelper.java b/gcloud-java-pubsub/src/main/java/com/google/cloud/pubsub/testing/LocalPubsubHelper.java
@@ -71,7 +71,7 @@ public class LocalPubsubHelper {
   public LocalPubsubHelper() {
     port = LocalServiceHelper.findAvailablePort(DEFAULT_PORT);
     List<String> gcloudCommand = new ArrayList<>(Arrays.asList(GCLOUD_CMD_TEXT.split(" ")));
-    gcloudCommand.add(GCLOUD_CMD_PORT_FLAG + port);
+    gcloudCommand.add(GCLOUD_CMD_PORT_FLAG + "localhost:" + port);
     GCloudEmulatorRunner gcloudRunner =
         new GCloudEmulatorRunner(gcloudCommand, VERSION_PREFIX, MIN_VERSION);
     DownloadableEmulatorRunner downloadRunner =
@@ -89,7 +89,7 @@ public LocalPubsubHelper() {
    * @throws IOException
    */
   public void start() throws IOException, InterruptedException {
-    String blockUntilOutput = Integer.toString(port);
+    String blockUntilOutput = "Server started, listening on " + port;
     serviceHelper.start(blockUntilOutput);
   }