move watch file

Author: rachel-mack

source/includes/usage-examples/code-snippets/Watch.java renamed to source/includes/crud/Watch.java

@@ -5,6 +5,13 @@
  * to only filter for "insert" and "update" events.
  */
 
+/**
+ * This file demonstrates how to open a change stream by using the Java driver.
+ * It connects to a MongoDB deployment, accesses the "sample_mflix" database, and listens
+ * to change events in the "movies" collection. The code uses a change stream with a pipeline
+ * to only filter for "insert" and "update" events.
+ */
+
 package usage.examples;
 
 import java.util.Arrays;
@@ -26,29 +33,29 @@ public class Watch {
     public static void main( String[] args ) {
 
         // Replace the uri string with your MongoDB deployment's connection string
-        String uri = "<connection string uri>";
+        String uri = "<connection string URI>";
 
         try (MongoClient mongoClient = MongoClients.create(uri)) {
             MongoDatabase database = mongoClient.getDatabase("sample_mflix");
             MongoCollection<Document> collection = database.getCollection("movies");
 
             // Creates instructions to match insert and update operations
             List<Bson> pipeline = Arrays.asList(
-                Aggregates.match(
-                        Filters.in("operationType",
-                                Arrays.asList("insert", "update"))));
-            
+                    Aggregates.match(
+                            Filters.in("operationType",
+                                    Arrays.asList("insert", "update"))));
+
             // Creates a change stream that receives change events for the specified operations
             ChangeStreamIterable<Document> changeStream = database.watch(pipeline)
-                .fullDocument(FullDocument.UPDATE_LOOKUP);
-           
+                    .fullDocument(FullDocument.UPDATE_LOOKUP);
+
             final int[] numberOfEvents = {0};
 
             // Prints a message each time the change stream receives a change event, until it receives two events
             changeStream.forEach(event -> {
-            System.out.println("Received a change to the collection: " + event);
+                System.out.println("Received a change to the collection: " + event);
                 if (++numberOfEvents[0] >= 2) {
-                  System.exit(0);
+                    System.exit(0);
                 }
             });
         }

source/logging-monitoring/change-streams.txt

@@ -90,14 +90,14 @@ An insert operation on the collection produces the following output:
       ...
    }
 
-watch() Example: Full File 
-~~~~~~~~~~~~~~~~~~~~~~~~~~~
+Watch Example: Full File 
+~~~~~~~~~~~~~~~~~~~~~~~~
+
+.. include:: /includes/crud/example-intro.rst
 
 The following code is a complete, standalone file that performs an ordered bulk
 write operation. 
 
-.. include:: /includes/crud/example-intro.rst
-
 .. io-code-block::
 
    .. input:: /includes/crud/Watch.java