NH feedback

Author: rachel-mack

source/includes/monitoring_JMX.kt

@@ -1,4 +1,5 @@
 import com.mongodb.kotlin.client.MongoClient
+import org.bson.Document
 import com.mongodb.MongoClientSettings
 import com.mongodb.ConnectionString
 import com.mongodb.management.JMXConnectionPoolListener
@@ -16,15 +17,20 @@ fun main() {
             it.addConnectionPoolListener(connectionPoolListener)
         }
         .build()
-    val mongoClient: MongoClient = MongoClient.create(settings)
 
-// Pause execution
     try {
+// Connect to your database
+        val mongoClient = MongoClient.create(settings)
+        val database = mongoClient.getDatabase("sample_mflix")
+        val collection = database.getCollection<Document>("movies")
+        collection.find().firstOrNull()
+        collection.find().firstOrNull()
         println("Navigate to JConsole to see your connection pools...")
+
+// Pause execution
         Thread.sleep(Long.MAX_VALUE)
+        mongoClient.close()
     } catch (e: Exception) {
         e.printStackTrace()
     }
-
-    mongoClient.close()
 }

source/includes/monitoring_counter.kt

@@ -1,5 +1,5 @@
 import com.mongodb.kotlin.client.MongoClient
-import org.bson.json.JsonWriterSettings
+import org.bson.Document
 import com.mongodb.event.*
 import com.mongodb.MongoClientSettings
 import com.mongodb.ConnectionString

source/includes/monitoring_librarian.kt

@@ -1,5 +1,5 @@
 import com.mongodb.kotlin.client.MongoClient
-import org.bson.json.JsonWriterSettings
+import org.bson.Document
 import com.mongodb.event.*
 import com.mongodb.MongoClientSettings
 import com.mongodb.ConnectionString
@@ -23,7 +23,9 @@ val cpListener = ConnectionPoolLibrarian()
 // Include the listener in your client settings
     val settings = MongoClientSettings.builder()
         .applyConnectionString(ConnectionString(uri))
-        .addCommandListener(cpListener)
+        .applyToConnectionPoolSettings({
+            it.addConnectionPoolListener(cpListener)
+            })
         .build()
 
 // Connect to your database        

source/includes/monitoring_writable.kt

@@ -1,5 +1,5 @@
 import com.mongodb.kotlin.client.MongoClient
-import org.bson.json.JsonWriterSettings
+import org.bson.Document
 import com.mongodb.event.*
 import com.mongodb.MongoClientSettings
 import com.mongodb.ConnectionString