Самая жесткая реализация отработки отказа - PullRequest
0 голосов
/ 01 октября 2019

Я пытаюсь настроить аварийное соединение с помощью пакета 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
...