Add method to set listeners in ClusterSettings, ServerSettings and ConnectionPoolSettings builders (#839)

JAVA-4317

Author: ramasai1

driver-core/src/main/com/mongodb/connection/ClusterSettings.java

@@ -268,6 +268,19 @@ public Builder addClusterListener(final ClusterListener clusterListener) {
             return this;
         }
 
+        /**
+         * Sets the cluster listeners.
+         *
+         * @param clusterListeners list of cluster listeners
+         * @return this
+         * @since 4.5
+         */
+        public Builder clusterListenerList(final List<ClusterListener> clusterListeners) {
+            notNull("clusterListeners", clusterListeners);
+            this.clusterListeners = new ArrayList<>(clusterListeners);
+            return this;
+        }
+
         /**
          * Takes the settings from the given {@code ConnectionString} and applies them to the builder
          *

driver-core/src/main/com/mongodb/connection/ConnectionPoolSettings.java

@@ -215,6 +215,19 @@ public Builder addConnectionPoolListener(final ConnectionPoolListener connection
             return this;
         }
 
+        /**
+         * Sets the connection pool listeners.
+         *
+         * @param connectionPoolListeners list of connection pool listeners
+         * @return this
+         * @since 4.5
+         */
+        public Builder connectionPoolListenerList(final List<ConnectionPoolListener> connectionPoolListeners) {
+            notNull("connectionPoolListeners", connectionPoolListeners);
+            this.connectionPoolListeners = new ArrayList<>(connectionPoolListeners);
+            return this;
+        }
+
         /**
          * The maximum number of connections a pool may be establishing concurrently.
          *

driver-core/src/main/com/mongodb/connection/ServerSettings.java

@@ -130,6 +130,19 @@ public Builder addServerListener(final ServerListener serverListener) {
             return this;
         }
 
+        /**
+         * Sets the server listeners.
+         *
+         * @param serverListeners list of server listeners
+         * @return this
+         * @since 4.5
+         */
+        public Builder serverListenerList(final List<ServerListener> serverListeners) {
+            notNull("serverListeners", serverListeners);
+            this.serverListeners = new ArrayList<>(serverListeners);
+            return this;
+        }
+
         /**
          * Adds a server monitor listener.
          *
@@ -143,6 +156,19 @@ public Builder addServerMonitorListener(final ServerMonitorListener serverMonito
             return this;
         }
 
+        /**
+         * Sets the server monitor listeners.
+         *
+         * @param serverMonitorListeners list of server monitor listeners
+         * @return this
+         * @since 4.5
+         */
+        public Builder serverMonitorListenerList(final List<ServerMonitorListener> serverMonitorListeners) {
+            notNull("serverMonitorListeners", serverMonitorListeners);
+            this.serverMonitorListeners = new ArrayList<>(serverMonitorListeners);
+            return this;
+        }
+
         /**
          * Takes the settings from the given {@code ConnectionString} and applies them to the builder
          *

driver-core/src/test/unit/com/mongodb/connection/ClusterSettingsSpecification.groovy

@@ -48,6 +48,7 @@ class ClusterSettingsSpecification extends Specification {
         when:
         def listenerOne = Mock(ClusterListener)
         def listenerTwo = Mock(ClusterListener)
+        def listenerThree = Mock(ClusterListener)
         def settings = ClusterSettings.builder()
                                       .hosts(hosts)
                                       .mode(ClusterConnectionMode.MULTIPLE)
@@ -68,6 +69,12 @@ class ClusterSettingsSpecification extends Specification {
         settings.serverSelector == serverSelector
         settings.getServerSelectionTimeout(TimeUnit.MILLISECONDS) == 1000
         settings.clusterListeners == [listenerOne, listenerTwo]
+
+        when:
+        settings = ClusterSettings.builder(settings).clusterListenerList([listenerThree]).build()
+
+        then:
+        settings.clusterListeners == [listenerThree]
     }
 
     def 'should apply settings'() {

driver-core/src/test/unit/com/mongodb/connection/ConnectionPoolSettingsSpecification.groovy

@@ -170,6 +170,7 @@ class ConnectionPoolSettingsSpecification extends Specification {
 
     def 'should apply settings'() {
         given:
+        def connectionPoolListener = Mock(ConnectionPoolListener)
         def defaultSettings = ConnectionPoolSettings.builder().build()
         def customSettings = ConnectionPoolSettings
                 .builder()
@@ -187,6 +188,12 @@ class ConnectionPoolSettingsSpecification extends Specification {
         expect:
         ConnectionPoolSettings.builder().applySettings(customSettings).build() == customSettings
         ConnectionPoolSettings.builder(customSettings).applySettings(defaultSettings).build() == defaultSettings
+
+        when:
+        customSettings = ConnectionPoolSettings.builder(customSettings).connectionPoolListenerList([connectionPoolListener]).build()
+
+        then:
+        customSettings.connectionPoolListeners == [connectionPoolListener]
     }
 
     def 'toString should be overridden'() {

driver-core/src/test/unit/com/mongodb/connection/ServerSettingsSpecification.groovy

@@ -40,8 +40,10 @@ class ServerSettingsSpecification extends Specification {
         given:
         def serverListenerOne = new ServerListenerAdapter() { }
         def serverListenerTwo = new ServerListenerAdapter() { }
+        def serverListenerThree = new ServerListenerAdapter() { }
         def serverMonitorListenerOne = new ServerMonitorListenerAdapter() { }
         def serverMonitorListenerTwo = new ServerMonitorListenerAdapter() { }
+        def serverMonitorListenerThree = new ServerMonitorListenerAdapter() { }
 
         when:
         def settings = ServerSettings.builder()
@@ -59,6 +61,15 @@ class ServerSettingsSpecification extends Specification {
         settings.getMinHeartbeatFrequency(MILLISECONDS) == 1000
         settings.serverListeners == [serverListenerOne, serverListenerTwo]
         settings.serverMonitorListeners == [serverMonitorListenerOne, serverMonitorListenerTwo]
+
+        when:
+        settings = ServerSettings.builder()
+                .serverListenerList([serverListenerThree])
+                .serverMonitorListenerList([serverMonitorListenerThree]).build()
+
+        then:
+        settings.serverListeners == [serverListenerThree]
+        settings.serverMonitorListeners == [serverMonitorListenerThree]
     }
 
     def 'when connection string is applied to builder, all properties should be set'() {