Забота с клиентом не удастся сначала сделать резервную копию брокераJAVA

Программисты JAVA общаются здесь
Anonymous
Забота с клиентом не удастся сначала сделать резервную копию брокера

Сообщение Anonymous »

Я изо всех сил пытаюсь заставить своего клиента отключить сбой, как я ожидал в своем кластере. топология. Однако то, что я вижу, так это то, что мой клиент переходит к другому первичному узлу. У меня есть все 6 узлов, которые работают локально с смещением портов. Конечной целью будет 3 сервера, но сейчас это так, как я могу протестировать вещи. DO добавить «HA» и «ReconnectAttempts» в мой URL Factory Connection Factory.public ActiveMQConnectionFactory activeMQConnectionFactory() throws NamingException{
ArtemisTargetConfig config = (ArtemisTargetConfig) new InitialContext().lookup("java:comp/env/bean/ArtemisConfig");
ActiveMQConnectionFactory cf = new ActiveMQConnectionFactory("udp://" + config.getGroupAddress() + ":" + config.getGroupPort() + "?ha=true&reconnectAttempts=10");
cf.setUser(config.getUserName());
cf.setPassword(config.getPassword());

return cf;
}

Строка URL выше превращается в UDP: //231.7.7.7: 9876? Ha = true & Reconnectattempts = 10 .
Первичный и резервный брокер.xml , который я обрезал, чтобы содержать только области, которые, по моему мнению, могут быть актуальными.
primary1: < /p>
localhost


tcp://localhost:61616



tcp://localhost:61616?tcpSendBufferSize=1048576;tcpReceiveBufferSize=1048576;amqpMinLargeMessageSize=102400;protocols=CORE,AMQP,STOMP,HORNETQ,MQTT,OPENWIRE;useEpoll=true;amqpCredits=1000;amqpLowCredits=300;amqpDuplicateDetection=true;supportAdvisory=false;suppressInternalManagementObjects=false



cluster-admin
apassword

231.7.7.7
9876

5000
artemis





231.7.7.7
9876
10000





artemis
ON_DEMAND
1







true
true



< /code>
backup1: < /pbr /> localhost


tcp://localhost:61617




tcp://localhost:61617?tcpSendBufferSize=1048576;tcpReceiveBufferSize=1048576;amqpMinLargeMessageSize=102400;protocols=CORE,AMQP,STOMP,HORNETQ,MQTT,OPENWIRE;useEpoll=true;amqpCredits=1000;amqpLowCredits=300;amqpDuplicateDetection=true;supportAdvisory=false;suppressInternalManagementObjects=false



cluster-admin
aPassword

231.7.7.7
9876

5000
artemis





231.7.7.7
9876
10000





artemis
ON_DEMAND
1







true






Подробнее здесь: https://stackoverflow.com/questions/794 ... oker-first

Вернуться в «JAVA»