MongoDatabase db = mongoClient.getDatabase("local");
MongoCollection<Document> oplogCollection = db.getCollection("oplog.$main");

MongoCursor<Document> cursor = oplogCollection.find(aFilter())
                .cursorType(CursorType.Tailable)
                //will throw MongoExecutionTimeoutException after ~ 10s -30s
                .maxTime(300, MILLISECONDS)
                .iterator();

//following code will produce an exception after like 10-30s:
cursor.hasNext();