クロニクルの接続インターフェースについて本当に混乱しています。それに関するテストコードやソースコードが見つかりませんでした。
切断および接続中のイベントをキャッチしたい。
私のセットアップは(バニラクロニクル3.6.2。)のようになります。
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();