165.4. 事前定義されたフィルター
Camel バージョン 2 .13.0 以降、JGroups コンポーネントには JGroupsFilters という名前の事前定義されたフィルターファクトリークラスが同梱されています。
クラスターのコーディネーターに送信される変更通知のみを消費する(また「スレーブ」ノードに送信される)は、JGroupsFilters.dropNonCoordinatorViews()
フィルターを使用します。このフィルターは、特定のノードがクラスターのコーディネーターになると、単一の Camel ノードがクラスターでマスターになる必要がある場合に特に便利です。以下のスニペットは、マスターノードが受信したメッセージのみを収集する方法を示しています。
import static org.apache.camel.component.jgroups.JGroupsFilters.dropNonCoordinatorViews; ... from("jgroups:clusterName?enableViewMessages=true"). filter(dropNonCoordinatorViews()). to("seda:masterNodeEventsQueue");
import static org.apache.camel.component.jgroups.JGroupsFilters.dropNonCoordinatorViews;
...
from("jgroups:clusterName?enableViewMessages=true").
filter(dropNonCoordinatorViews()).
to("seda:masterNodeEventsQueue");