feat: add port as a parameter for the bigtable emulator (#2645)

mutianf · andre-sampaio · cloud-java-bot · web-flow · commit 5acd3dc01c36 · 2025-07-30T15:31:53.000-04:00
* feat: add port as a parameter for the bigtable emulator

* chore: generate libraries at Wed Jul 16 21:29:57 UTC 2025

* set the port in emulator class

---------

Co-authored-by: André Barbosa Sampaio &lt;andrebsamp@gmail.com&gt;
Co-authored-by: cloud-java-bot &lt;cloud-java-bot@google.com&gt;
diff --git a/google-cloud-bigtable-emulator-core/src/main/java/com/google/cloud/bigtable/emulator/core/EmulatorController.java b/google-cloud-bigtable-emulator-core/src/main/java/com/google/cloud/bigtable/emulator/core/EmulatorController.java
@@ -93,11 +93,13 @@ public synchronized boolean isRunning() {
   }
 
   /** Starts the emulator process and waits for it to be ready. */
-  public synchronized void start() throws IOException, TimeoutException, InterruptedException {
+  public synchronized void start(int port)
+      throws IOException, TimeoutException, InterruptedException {
     if (!isStopped) {
       throw new IllegalStateException("Emulator is already started");
     }
-    this.port = getAvailablePort();
+
+    this.port = port;
 
     // Try to align the localhost address across java & golang emulator
     // This should fix issues on systems that default to ipv4 but the jvm is started with
@@ -143,6 +145,11 @@ public synchronized void start() throws IOException, TimeoutException, Interrupt
     waitForPort(port);
   }
 
+  /** Starts the emulator process and waits for it to be ready. */
+  public synchronized void start() throws IOException, TimeoutException, InterruptedException {
+    start(getAvailablePort());
+  }
+
   /** Stops the emulator process. */
   public synchronized void stop() {
     if (isStopped) {
diff --git a/google-cloud-bigtable-emulator/src/main/java/com/google/cloud/bigtable/emulator/v2/Emulator.java b/google-cloud-bigtable-emulator/src/main/java/com/google/cloud/bigtable/emulator/v2/Emulator.java
@@ -62,6 +62,11 @@ public synchronized void start() throws IOException, TimeoutException, Interrupt
     controller.start();
   }
 
+  public synchronized void start(int port)
+      throws IOException, TimeoutException, InterruptedException {
+    controller.start(port);
+  }
+
   /** Stops the emulator process. */
   public synchronized void stop() {
     controller.stop();
