Ich versuche, einen HA-amqp-Client einzurichten. Derzeit gibt es 3 Amqps-Broker. Derzeit ist meine Client-Konfiguration ist wie folgt:Verbinden mit mehreren AMQP-Brokern
<property name="remoteURI" value="amqps://node1:9551?jms.username=XXXXXXXX&jms.password=XXXXXXXXX&transport.trustStoreLocation=etc/keystore.jks" />
Jetzt, da ich 2 weiteren AMQP-Broker zu haben, im sie versuchen, zu verbinden. Erstens ist es möglich? Ich kann nach documentation, für Python versuchen so etwas wie:
connection = qpid.messaging.Connection.establish("node1", reconnect=True, reconnect_urls=["node1", "node2", "node3"])
Aber für JMS verwandte Verbindung, heißt es:
connectionfactory.qpidConnectionfactory = amqp://guest:[email protected]/test?brokerlist='tcp://localhost:5672'&failover='failover_exchange'
Aber ich sehe nicht, einen Hinweis, wie man andere Makler verbinden.
Eine Idee, wie dies von der Client-Seite erreicht werden kann?
Es ist nicht ganz klar, auf welche AMQP JMS-Clients Sie sich hier beziehen, daher ist eine Antwort schwierig. Auch Ihre Frage ist verwirrend, da unklar ist, ob Sie eine Failover- oder eine Fanout-Verbindung wünschen. –
Also verwende ich Servicemix, um Nachrichten zwischen Warteschlangen zu routen. In meiner SMX-Konfiguration verbinde ich mich direkt mit einem der 3 Broker, indem ich amqps benutze, aber ich möchte die Verbindung zu allen 3 herstellen, wenn einer von ihnen fehlschlägt. Und ja, ich möchte Failover konfigurieren. –
Welche noch fehlt Klärung, welche AMQP JMS Client Sie verwenden –