Поддерживает ли py-amqp AMQP 0-10?
Мой клиент использует qpid-cpp-broker для обмена сообщениями AMQP. Наше приложение построено на Python 3, поэтому я не смог использовать API обмена сообщениями Python Qpid (он поддерживает только Python 2.7).
Я пытаюсь использовать py-amqp для отправки AMQP qpid-cpp-broker, он не работает.
import amqp
# connect to server
lConnection = amqp.Connection(host="172.17.0.2:5672", userid="", password="", virtual_host="/", insist=False)
lConnection.connect()
lChannel = lConnection.channel()
# Create a message
lMessage = amqp.Message("Test message!")
# Send message as persistant. This means it will survive a reboot.
lMessage.properties["delivery_mode"] = 2
# publish the message on the exchange
lChannel.basic_publish(lMessage, exchange="myExchange", routing_key="Test")
# Close connection
lChannel.close()
lConnection.close()
Это дает ниже ошибку:
Traceback (most recent call last):
File "sample.py", line 6, in <module>
lConnection.connect()
File "/opt/app/py-amqp/amqp/connection.py", line 308, in connect
self.drain_events(timeout=self.connect_timeout)
File "/opt/app/py-amqp/amqp/connection.py", line 491, in drain_events
while not self.blocking_read(timeout):
File "/opt/app/py-amqp/amqp/connection.py", line 496, in blocking_read
frame = self.transport.read_frame()
File "/opt/app/py-amqp/amqp/transport.py", line 253, in read_frame
payload = read(size)
File "/opt/app/py-amqp/amqp/transport.py", line 426, in _read
raise IOError('Socket closed')
OSError: Socket closed
У меня под вопросом,
- py-amqp поддерживает AMQP 0-10?
- Если нет, то есть ли какая-либо библиотека Python 3 для отправки сообщений AMQP 0-10?