Mongo-Connect

bitte forken: mongo-connect on github

Mongo-Connect vereinfacht die Verwendung des Monogdb Changestreams.

Eine einzelne Collection überwachen und auf Insert-Events reagieren.

MongoDatabase database = mongoClient.getDatabase("test-database");

MongoConnect mongoConnect = new MongoConnect();
mongoConnect.open(() -> database.getCollection("test-collection").watch());

mongoConnect.register(Event.INSERT, (databaseName, collectionName, document) -> {
	System.out.println("new document inserted into collection %s".format(collectionName));
});