클러스터형 Camel 애플리케이션을 보호하고 하나의 활성 노드에서만 파일을 사용할 수 있습니다.
// the file endpoint we want to consume from
String url = "file:target/inbox?delete=true";
// use the zookeeper master component in the clustered group named myGroup
// to run a master/slave mode in the following Camel url
from("zookeeper-master:myGroup:" + url)
.log(name + " - Received file: ${file:name}")
.delay(delay)
.log(name + " - Done file: ${file:name}")
.to("file:target/outbox");
// the file endpoint we want to consume from
String url = "file:target/inbox?delete=true";
// use the zookeeper master component in the clustered group named myGroup
// to run a master/slave mode in the following Camel url
from("zookeeper-master:myGroup:" + url)
.log(name + " - Received file: ${file:name}")
.delay(delay)
.log(name + " - Done file: ${file:name}")
.to("file:target/outbox");
Copy to ClipboardCopied!Toggle word wrapToggle overflow
zookeeper는 기본적으로 localhost:2181 에 연결하지만 구성 요소 수준에서 이를 구성할 수 있습니다.
MasterComponent master = new MasterComponent();
master.setZooKeeperUrl("myzookeeper:2181");
MasterComponent master = new MasterComponent();
master.setZooKeeperUrl("myzookeeper:2181");
Copy to ClipboardCopied!Toggle word wrapToggle overflow
그러나 환경 변수를 사용하여 ZooKeeper의 URL을 구성할 수도 있습니다.
export ZOOKEEPER_URL = "myzookeeper:2181"
export ZOOKEEPER_URL = "myzookeeper:2181"
Copy to ClipboardCopied!Toggle word wrapToggle overflow