Поддерживает ли 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?

0 ответов

Другие вопросы по тегам