0

나는 rabbimq를 염두에 두면서 프레임 워크를 디자인하고 구현했으며 거의 ​​완료되었지만 마지막 상태에서는 activeMQ로 옮겨야한다. 현재는 모든 기능의 동등성을 찾고있다.)를 activeMQ에서 사용할 수도 있습니다. bried는 게시자가 있었으며 라우팅 키 (주제)가있는 메시지를 브로커에 게시 할 수 있습니다. 이제는 그 관심사 (주제)로 대기열을 묶은 구독자를 여러 명 보유 할 수 있습니다. 즉, 모든 구독자는 자체 대기열을 가지지 만 동일한 주제가있는 경우 브로커는 게시 된 주제 메시지에 바인딩 된 모든 대기열로 전달합니다. 와. 또한, 내 가입자 중 누구든지 죽을 수 있고 다시 돌아올 수 있으며 여전히 소비되지 않은 메시지를보고 소비 할 수 있습니다. 이제 ActiveMQ에는 주제와 대기열의 개념이 있으며 기능이 다릅니다. 주제를 사용하여 위와 같이 달성 할 수 있지만 내 구독자는 브로커가 게시 된 메시지를 수신 할 때마다 깨야합니다. 그렇지 않으면 해당 메시지가 느슨해집니다. 대기열을 사용하면 부하가 분산되므로 모든 가입자가 모든 메시지를 수신하지는 않습니다. 어떤 생각, ActiveMQ의 경우에도 동일한 기능을 어떻게 얻을 수 있습니까? 또한. C++에서 develped되는 프레임 워크 용 CMS API를 사용하고 있습니다.ActiveMQ CMS : 둘 이상의 소비자가 동일한 대기열에서 같은 메시지를 수신 할 수있는 방법 (로드 균형 조정을 원하지 않습니까?)

감사 디팍

당신은 그렇지 않으면 원하는 시나리오에 대한 라우팅을 정의하기 위해 아파치 Camel을 사용으로 보는 AMQ documentation에 미러 대기열 및 가상 목적지를 살펴 할 수 있습니다

답변

0

.

+0

나는 또한이 가상 목적지를 얻었고 그것이 나의 문제를 해결 하는지를보기 위해 그것을 읽었다. 그 외에도, 나는 또한 주제와 함께 createDurableConsumer를 사용할 수있는 것을 볼 수 있는데, 소비자가 다시 시작되면 다시 놓친 메시지를받을 때 동일한 clientID를 지정해야한다. – Deepak

+1

그래, 내 createConnection (uri, 사용자, 암호, clientId) 및 createDurableConsumer (topic, clientId, "") 위의 목표를 달성하기 위해 일했다. – Deepak

0

JMS 구현 공급자 구성을 확인하십시오. 우선 순위가 가장 높은 소비자를 지정할 수 있으며 활성 상태가되지 않는 한 다른 사람이 얻지 못하는 메시지 수신을 시작합니다.

관련 문제