Polished replica set examples

Author: ttrelle

mongodriver/src/main/java/de/codecentric/Connection.java

@@ -0,0 +1,12 @@
+package de.codecentric;
+
+import com.mongodb.MongoClientURI;
+
+abstract public class Connection {
+
+	public static final MongoClientURI URI = new MongoClientURI(
+			"mongodb://mongo1:27001,mongo2:27002,mongo3:27003/test?replicatSet=dev0"
+			// "mongodb://localhost:27001,localhost:27002,localhost:27003/test?replicatSet=dev0"
+			);
+	
+}

mongodriver/src/main/java/de/codecentric/notifications/DocumentProducer.java

@@ -3,17 +3,17 @@
 import org.bson.Document;
 
 import com.mongodb.MongoClient;
-import com.mongodb.MongoClientURI;
 import com.mongodb.client.MongoCollection;
 
+import de.codecentric.Connection;
+
 public class DocumentProducer  {
 
 	public static void main(String[] args) throws Exception {
 
-		MongoCollection<Document> eventCollection = 
-				new MongoClient(
-						new MongoClientURI("mongodb://localhost:27001,localhost:27002,localhost:27003/test?replicatSet=demo-dev")
-				).getDatabase("test").getCollection("events");    		
+		try (MongoClient client = new MongoClient(Connection.URI)) {
+    		MongoCollection<Document> eventCollection = 
+    				client.getDatabase("test").getCollection("events");   		
 
     		long i = 0;
     		while (true) {
@@ -24,5 +24,6 @@ public static void main(String[] args) throws Exception {
     			//System.out.println("inserted: " + doc);
     			Thread.sleep(2000L + (long)(1000*Math.random()));
     		}
+		}
     }
 }

mongodriver/src/main/java/de/codecentric/notifications/EventListener.java

@@ -1,37 +1,35 @@
 package de.codecentric.notifications;
 
+import static com.mongodb.client.model.Filters.and;
+import static com.mongodb.client.model.Filters.eq;
+import static com.mongodb.client.model.Filters.in;
 import static java.util.Arrays.asList;
 
 import org.bson.Document;
 
-import com.mongodb.Block;
 import com.mongodb.MongoClient;
-import com.mongodb.MongoClientURI;
 import com.mongodb.client.ChangeStreamIterable;
 import com.mongodb.client.MongoCollection;
 import com.mongodb.client.model.Aggregates;
-import static com.mongodb.client.model.Filters.*;
-import com.mongodb.client.model.changestream.ChangeStreamDocument;
+
+import de.codecentric.Connection;
 
 public class EventListener  {
+	
     public static void main(String[] args) throws Exception {
-    	
+		try (MongoClient client = new MongoClient(Connection.URI)) {
     		MongoCollection<Document> eventCollection = 
-    				new MongoClient(
-    						new MongoClientURI("mongodb://localhost:27001,localhost:27002,localhost:27003/test?replicatSet=demo-dev")
-    				).getDatabase("test").getCollection("events");
+    				client.getDatabase("test").getCollection("events");
 
     		ChangeStreamIterable<Document> changes = eventCollection.watch(asList( 
     				Aggregates.match( and( asList( 
     					in("operationType", asList("insert")),
     					eq("fullDocument.even", 1L)))
     	    )));
 
-    		changes.forEach(new Block<ChangeStreamDocument<Document>>() {
-				@Override
-				public void apply(ChangeStreamDocument<Document> t) {
-					System.out.println("received: " + t.getFullDocument());
-				}
-    		});
+    		changes.iterator().forEachRemaining(
+    				change -> System.out.println("received: " + change.getFullDocument())
+    		);
+		}
     }
 }

mongodriver/src/main/java/de/codecentric/transaction/SimpleTransaction.java

@@ -6,12 +6,13 @@
 import org.bson.Document;
 
 import com.mongodb.MongoClient;
-import com.mongodb.MongoClientURI;
 import com.mongodb.MongoException;
 import com.mongodb.client.ClientSession;
 import com.mongodb.client.MongoCollection;
 import com.mongodb.client.MongoDatabase;
 
+import de.codecentric.Connection;
+
 /**
  * Simple transaction example.
  */
@@ -27,10 +28,7 @@ public class SimpleTransaction {
 	 * @throws UnsupportedEncodingException
 	 */
 	public static void main(String[] argv) throws UnknownHostException, MongoException, UnsupportedEncodingException {
-		try (MongoClient client = new MongoClient(
-				// Replica set
-				new MongoClientURI("mongodb://mongo1:27001,mongo2:27002,mongo3:27003/replicaSet=dev0")
-			 )) {
+		try (MongoClient client = new MongoClient(Connection.URI)) {
 			// use database "test"
 			MongoDatabase db = client.getDatabase("test");
 			// collection must be created beforehand *outside* the transaction!