Как мы подключаемся к ActiveMQ с использованием URI с отказоустойчивым током в Go? Используя клиент Go-Stomp, я попытался под кодом и не смог подключиться.failover URI для ActiveMQ в go stomp client
if conn, err = stomp.Dial("tcp", "failover:(tcp://10.01.02.03:61613,tcp://10.04.05.06:61613)?startupMaxReconnectAttempts=2"); err != nil {
panic(fmt.Sprintf("Could not connect to ActiveMQ using brokerUri %v. Can not continue.", Config.Broker.URI))
}
ActiveMQ имеет концепцию отказоустойчивого. http://activemq.apache.org/nms/stomp-uri-configuration.html. Я использовал URI, о котором я упомянул в вопросе для клиента Java ActiveMQ, и он отлично работает. Попытка того же в клиенте Go. Но я не нашел ссылку на использование протокола отказоустойчивости в Go-Stomp. Либо он не поддерживается, либо я могу использовать его неправильно. –
NMS - это топающий клиент. Он поддерживает синтаксис отказоустойчивости. Этот инструмент обеспечивает стоп-протокол или библиотеку go-stomp. – animal