Cassandra: Add support for creating Cluster objects without JMX reporting (#1199)

Author: brasse

modules/cassandra/src/main/java/org/testcontainers/containers/CassandraContainer.java

@@ -32,6 +32,7 @@ public class CassandraContainer<SELF extends CassandraContainer<SELF>> extends G
 
     private String configLocation;
     private String initScriptPath;
+    private boolean enableJmxReporting;
 
     public CassandraContainer() {
         this(IMAGE + ":3.11.2");
@@ -41,6 +42,7 @@ public CassandraContainer(String dockerImageName) {
         super(dockerImageName);
         addExposedPort(CQL_PORT);
         setStartupAttempts(3);
+        this.enableJmxReporting = false;
     }
 
     @Override
@@ -116,6 +118,14 @@ public SELF withInitScript(String initScriptPath) {
         return self();
     }
 
+    /**
+     * Initialize Cassandra client with JMX reporting enabled or disabled
+     */
+    public SELF withJmxReporting(boolean enableJmxReporting) {
+        this.enableJmxReporting = enableJmxReporting;
+        return self();
+    }
+
     /**
      * Get username
      *
@@ -146,14 +156,21 @@ public String getPassword() {
      * Can be used to obtain connections to Cassandra in the container
      */
     public Cluster getCluster() {
-        return getCluster(this);
+        return getCluster(this, enableJmxReporting);
     }
 
-    public static Cluster getCluster(ContainerState containerState) {
-        return Cluster.builder()
+    public static Cluster getCluster(ContainerState containerState, boolean enableJmxReporting) {
+        final Cluster.Builder builder = Cluster.builder()
             .addContactPoint(containerState.getContainerIpAddress())
-            .withPort(containerState.getMappedPort(CQL_PORT))
-            .build();
+            .withPort(containerState.getMappedPort(CQL_PORT));
+        if (!enableJmxReporting) {
+            builder.withoutJMXReporting();
+        }
+        return builder.build();
+    }
+
+    public static Cluster getCluster(ContainerState containerState) {
+        return getCluster(containerState, false);
     }
 
     private DatabaseDelegate getDatabaseDelegate() {