Red Hat Summit Red Hat Summit지원콘솔개발자평가판 시작연락처

174.7. 예

174.7.1. send (receiving) 메시지를 (from)으로 전송(ceiving)
링크 복사

아래 코드 조각에 표시된 것과 마찬가지로ECDHE 클러스터에 메시지를 보내려면 생산자 끝점을 사용합니다. 

from("direct:start").to("jgroups:myCluster");
...
producerTemplate.sendBody("direct:start", "msg")
Copy to Clipboard Toggle word wrap

위의 코드 조각에서 메시지를 수신하려면 아래 코드 조각에 표시된 것처럼 (동일하거나 다른 물리적 시스템에서) 지정된 클러스터에서 들어오는 메시지를 청취합니다. 

mockEndpoint.setExpectedMessageCount(1);
mockEndpoint.message(0).body().isEqualTo("msg");
...
from("jgroups:myCluster").to("mock:messagesFromTheCluster");
...
mockEndpoint.assertIsSatisfied();
Copy to Clipboard Toggle word wrap

174.7.2. 클러스터 보기 변경 알림 수신
링크 복사

아래 스니펫에서는 클러스터 멤버십 변경에 대한 알림을 수신 대기하는 소비자 엔드포인트를 생성하는 방법을 보여줍니다. 기본적으로 엔드포인트에서 일반 메시지만 사용합니다. 

mockEndpoint.setExpectedMessageCount(1);
mockEndpoint.message(0).body().isInstanceOf(org.jgroups.View.class);
...
from("jgroups:clusterName?enableViewMessages=true").to(mockEndpoint);
...
mockEndpoint.assertIsSatisfied();
Copy to Clipboard Toggle word wrap

174.7.3. 클러스터 내에서 singleton 경로 유지
링크 복사

아래 스니펫에서는 Camel 컨텍스트 클러스터에서 singleton 소비자 경로를 유지하는 방법을 보여줍니다. 마스터 노드가 종료되면 슬레이브 중 하나가 새 마스터로 선택되고 시작됩니다. 이 특정 예에서 singleton jetty 인스턴스가 주소 http://localhost:8080/orders` 의 요청을 수신 대기 상태로 유지하려고 합니다. 

JGroupsLockClusterService service = new JGroupsLockClusterService();
service.setId("uniqueNodeId");
...
context.addService(service);

from("master:mycluster:jetty:http://localhost:8080/orders").to("jms:orders");
Copy to Clipboard Toggle word wrap
맨 위로 이동
Red Hat logoGithubredditYoutubeTwitter

자세한 정보

평가판, 구매 및 판매

커뮤니티

Red Hat 문서 정보

Red Hat을 사용하는 고객은 신뢰할 수 있는 콘텐츠가 포함된 제품과 서비스를 통해 혁신하고 목표를 달성할 수 있습니다. 최신 업데이트를 확인하세요.

보다 포괄적 수용을 위한 오픈 소스 용어 교체

Red Hat은 코드, 문서, 웹 속성에서 문제가 있는 언어를 교체하기 위해 최선을 다하고 있습니다. 자세한 내용은 다음을 참조하세요.Red Hat 블로그.

Red Hat 소개

Red Hat은 기업이 핵심 데이터 센터에서 네트워크 에지에 이르기까지 플랫폼과 환경 전반에서 더 쉽게 작업할 수 있도록 강화된 솔루션을 제공합니다.

Theme

© 2025 Red Hat