2017-11-16 23 views
0

HA amqp 클라이언트를 설정하려고합니다. 현재 3 amqps 중개인이 있습니다. 현재 내 클라이언트 설정은 다음과 같습니다 : 이제여러 AMQP 중개인에 연결

<property name="remoteURI" value="amqps://node1:9551?jms.username=XXXXXXXX&amp;jms.password=XXXXXXXXX&amp;transport.trustStoreLocation=etc/keystore.jks" /> 

내가 메신저가 너무 그들에게 연결을 시도, 너무 다른 2 AMQP 브로커를 가지고 있기 때문이다. 첫째로 가능한가?

connection = qpid.messaging.Connection.establish("node1", reconnect=True, reconnect_urls=["node1", "node2", "node3"]) 

그러나 JMS 관련 연결

, 그것은 상태 : documentation에 따르면, 파이썬에 대해 내가 좋아하는 뭔가를 시도 할 수 있습니다

connectionfactory.qpidConnectionfactory = amqp://guest:[email protected]/test?brokerlist='tcp://localhost:5672'&failover='failover_exchange' 

을하지만 다른 브로커에 연결하는 방법에 대한 표시를 참조니까.

클라이언트 측에서 어떻게 구현할 수 있습니까?

+0

여기에 어떤 AMQP JMS 클라이언트가 언급되어 있는지 명확하지 않아 답변이 까다 롭습니다. 또한 장애 조치 또는 팬 아웃 연결을 원할 경우 명확하지 않으므로 질문이 혼동 스럽습니다. –

+0

그래서 servicemix를 사용하여 큐간에 메시지를 라우팅합니다. 내 SMX 구성에서 amqps를 사용하여 직접 3 브로커 중 하나에 연결하고 있지만 그 중 하나에 모두 연결할 수있는 기능이 필요합니다. 그리고 네, 장애 조치 구성을 찾고 있습니다. –

+0

어떤 AMQP JMS 클라이언트를 사용하고 있는지 명확히 알 수없는 –

답변

0

내 생각에 다른 정보를 더 잘 추측하지 못했기 때문에 Apache Qpid 프로젝트의 QpidJMS AMQP v1.0 기반 클라이언트를 사용하고 있다고 가정합니다.

failover://(amqp://host1:5672,amqp://host2:5672)?jms.username.... 

당신은 물론 documentation를 읽고 이러한 것들을 찾을 수 있습니다 : 클라이언트가 장애 조치 구성을 처리 할 것이라고 방법은 같은 연결 URI에 있습니다.

+0

감사합니다. @Tim. 예, Qpid JMS AMSQPS 클라이언트를 사용하고 있습니다. 나는이 해결책을 시도 할 것이다. –