Я пытаюсь настроить аварийное соединение с помощью пакета stompest python. Я использовал пример из async_client_test.py, поставляемого с пакетом:
config = StompConfig(uri='failover:(tcp://localhost:%d,tcp://localhost:%d)?startupMaxReconnectAttempts=0,initialReconnectDelay=0,randomize=false,maxReconnectAttempts=1' % ports)
client = Stomp(config)
Я ожидаю, что при потере соединения с брокером сообщений библиотека начнет попытки подключиться к нему, но ничего не происходит:
2019-10-01 12:05:20+0100 [-] Stopping factory <stompest.twisted.protocol.StompFactory object at 0x0000029183303630>
INFO:stompest.twisted.listener:Disconnected: Connection was closed cleanly.
ERROR:stompest.twisted.listener:Disconnect because of failure: Unexpected connection loss [Connection was closed cleanly.]
DEBUG:stompest.twisted.listener:Calling disconnected errback: Unexpected connection loss [Connection was closed cleanly.]
после этого больше ничего.
Где может быть проблема?
PS: версии:
- Stompest: 2.3.0
- Витая: 19.7.0
- Python: 3.6.7
- Брокер сообщений: Rabbitmq 3.7.18