Как подключиться к сети брокеров activemq из клиентского приложения?

Question

Я настроил сеть брокеров в activemq, как мне подключиться к ней из моего клиентского приложения

Я пытался с

сеть: статическая: (tcp: //master1.IP: 61616, tcp: //master2.IP: 61617) и

но я получаю следующее исключение

javax.jms.JMSException: Uncategorized exception occured during JMS processing; nested exception is javax.jms.JMSException: Could not create Transport. Reason: java.io.IOException: Transport scheme NOT recognized: [network]; 

С

статические (TCP: //master1.IP: 61616, ТСР: //master2.IP: 61617)

Я получаю исключение

javax.jms.JMSException: Uncategorized exception occured during JMS processing; nested exception is javax.jms.JMSException: Could not create Transport. Reason: java.io.IOException: Transport scheme NOT recognized: [static]; 

Спасибо

Answer 1

"Клиенты, желающие переключиться на статический список экземпляров брокера, должны вместо этого использовать failover: // transport." (от: http://activemq.apache.org/static-transport-reference.html)

так что правильный синтаксис будет:

отказоустойчивый: (ТСР: //master1.IP: 61616, ТСР: //master2.IP: 61617)

Answer 2

Для подключения в сети брокеров мы можем использовать Multicast следующим образом: В ActiveMQ.xml:

<transportConnectors>
<transportConnector name="openwire"  uri="tcp://IP1:61616" discoveryUri="multicast://default?group=GROUPNAME"/>
</transportConnectors>

<networkConnectors>
<networkConnector uri="multicast://default?group=GROUPNAME"/>
</networkConnectors>

А в API на стороне клиента:

discovery:(multicast://default?group=GROUPNAME)