mseemann · September 3, 2021 15:03
diff --git a/MongoStats.java b/MongoStats.java
 Query tailQ = new Query().addCriteria(Criteria.where("ns").is("streams.user"));
 reactiveMongoTemplate.tail(tailQ, OplogEntry.class, "oplog.rs")
        .retryWhen(Retry.indefinitely().doAfterRetryAsync(signal -> Mono.delay(Duration.ofSeconds(10)).then()))
        .subscribe(entry -> {
            log.info("tailed entry: {}", entry);
            lastOplogAt.set(entry.ts().getTime() * 1000L);
        });
	Query tailQ = new Query().addCriteria(Criteria.where("ns").is("streams.user"));
	reactiveMongoTemplate.tail(tailQ, OplogEntry.class, "oplog.rs")
	.retryWhen(Retry.indefinitely().doAfterRetryAsync(signal -> Mono.delay(Duration.ofSeconds(10)).then()))
	.subscribe(entry -> {
	log.info("tailed entry: {}", entry);
	lastOplogAt.set(entry.ts().getTime() * 1000L);
	});