public void handle(@Nonnull ReplicationRequest request) {
writeEvent(writer, request);
}
};
try {
replicationTrigger.register(replicationRequestHandler);
try {
Thread.sleep(seconds * 1000);
} catch (InterruptedException e) {
log.error("thread interrupted", e);