Пример Python STOMP ActiveMQ: взаимодействие с ActiveMQ с использованием Python и STOMP

Вот пример фрагмента кода Python, использующего протокол STOMP для подключения и взаимодействия с ActiveMQ:

import stomp
# Create a connection
conn = stomp.Connection()
# Connect to the ActiveMQ broker
conn.connect()
# Subscribe to a destination
conn.subscribe(destination='/queue/example', id=1, ack='auto')
# Send a message
conn.send(body='Hello, ActiveMQ!', destination='/queue/example')
# Receive messages
while True:
    message = conn.receive()
    print(f'Received message: {message.body}')
    conn.ack(message.headers['message-id'])
# Disconnect from the broker
conn.disconnect()

В этом примере мы импортируем модуль stomp, создаем соединение с помощью stomp.Connection(), подключаемся к брокеру ActiveMQ с помощью conn.connect( ), подписаться на пункт назначения с помощью conn.subscribe(), отправить сообщение с помощью conn.send(), получить и обработать сообщения с помощью conn.receive()и, наконец, отключитесь от брокера с помощью conn.disconnect().