ActiveMQ STOMP Client for Python
Project description
amqstompclient
A stomp client in python3 for ActiveMQ using the stomp.py library. The client reconnects automatically when ActiveMQ misses heartbeats. As of version 2.0 it is linked against stomp.py 8
Example 1:
from amqstompclient import amqstompclient
import logging
import time
logging.basicConfig(level=logging.INFO, format='%(asctime)s.%(msecs)03d %(levelname)s %(module)s - %(funcName)s: %(message)s', datefmt="%Y-%m-%d %H:%M:%S")
logger = logging.getLogger()
server={"ip":"127.0.0.1","port":"61613","login":"admin","password":"*****","heartbeats":(30000,30000)}
conn=amqstompclient.AMQClient(server
, {"name":"TEST","version":"1.0.0","lifesign":"/topic/COUCOU"}
,["/queue/QTEST1","/queue/QTEST2","/topic/TTEST1","/topic/TTEST2"])
while True:
time.sleep(5)
conn.send_life_sign()
Example 2:
Using a message received callback.
from amqstompclient import amqstompclient
import logging
import time
def callback(destination, message,headers):
logger.info("Received:"+message)
conn.send_message("/topic/TTEST2","FROMCALLBACK")
logging.basicConfig(level=logging.INFO, format='%(asctime)s.%(msecs)03d %(levelname)s %(module)s - %(funcName)s: %(message)s', datefmt="%Y-%m-%d %H:%M:%S")
logger = logging.getLogger()
server={"ip":"127.0.0.1","port":"61613","login":"admin","password":"*****","heartbeats":(30000,30000)}
conn=amqstompclient.AMQClient(server
, {"name":"TEST","version":"1.0.0","lifesign":"/topic/HELLO"}
,["/queue/QTEST1","/queue/QTEST2","/topic/HELLO"]
,callback=callback)
while True:
time.sleep(5)
conn.send_life_sign()
Early Ack
It is possible to set earlyack to True in order to ack the message before calling the callback. This way, the message will not be rolled back if the callback fails.
{"ip":activemq_address,"port":activemq_port,"login":activemq_user, "password":activemq_password,"heartbeats":(30000,30000),"earlyack":True}
Project details
Release history Release notifications | RSS feed
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
amqstompclient-2.0.3.tar.gz
(8.2 kB
view details)
File details
Details for the file amqstompclient-2.0.3.tar.gz
.
File metadata
- Download URL: amqstompclient-2.0.3.tar.gz
- Upload date:
- Size: 8.2 kB
- Tags: Source
- Uploaded using Trusted Publishing? No
- Uploaded via: twine/6.1.0 CPython/3.11.13
File hashes
Algorithm | Hash digest | |
---|---|---|
SHA256 |
2940594016084764192ef49d6ce75c18d81dc69ef307e7082817e5dd7e81e419
|
|
MD5 |
52654d98c9d332c58f3c5dbcf9eeb3a0
|
|
BLAKE2b-256 |
5f2a99cf12522b5162d78e23b7862dbce433cfa34523bef3b6c2ff3a49f84a54
|