[Java] Surface the clusterId in the ConsensusModuleControl interface.

real-logic · Nov 25, 2024 · c444784 · c444784
1 parent 1dd7404
commit c444784
Show file tree

Hide file tree

Showing 2 changed files with 16 additions and 0 deletions.
diff --git a/aeron-cluster/src/main/java/io/aeron/cluster/ConsensusModuleAgent.java b/aeron-cluster/src/main/java/io/aeron/cluster/ConsensusModuleAgent.java
@@ -518,6 +518,14 @@ public int commitPositionCounterId()
         return ctx.commitPositionCounter().id();
     }
 
+    /**
+     * {@inheritDoc}
+     */
+    public int clusterId()
+    {
+        return ctx.clusterId();
+    }
+
     public void onLoadBeginSnapshot(
         final int appVersion, final TimeUnit timeUnit, final DirectBuffer buffer, final int offset, final int length)
     {

diff --git a/aeron-cluster/src/main/java/io/aeron/cluster/ConsensusModuleControl.java b/aeron-cluster/src/main/java/io/aeron/cluster/ConsensusModuleControl.java
@@ -109,4 +109,12 @@ public interface ConsensusModuleControl
      * @return commit position counter id.
      */
     int commitPositionCounterId();
+
+    /**
+     * Numeric id for the cluster (used when running multiple clusters on the same media driver).
+     *
+     * @return numeric id for the cluster.
+     * @see ConsensusModule.Context#clusterId(int)
+     */
+    int clusterId();
 }