2

クロニクルの接続インターフェースについて本当に混乱しています。それに関するテストコードやソースコードが見つかりませんでした。

切断および接続中のイベントをキャッチしたい。

私のセットアップは(バニラクロニクル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();
4

0 に答える 0