我真的对chronicle的连接界面感到困惑。我找不到任何关于它的测试代码或源代码。
我想捕捉断开和连接事件。
我的设置看起来像(香草编年史 3.6.2。);
两个相同的过程,相互连接。
资源::
chronicle = ChronicleQueueBuilder.vanilla(journalerPath).build();
source = ChronicleQueueBuilder
.source(chronicle)
.bindAddress("127.0.0.1", port)
.connectionListener(connListener)
.build();
appender = source.createAppender();
localReader = chronicle.createTailer();
裁缝::
remoteChronicle = ChronicleQueueBuilder
.remoteTailer()
.connectAddress(remoteSourceHost, remoteSourcePort)
.connectionListener(connListener)
.build();
remoteTailer = remoteChronicle.createTailer();