2

我真的对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();
4

0 回答 0