{"repo":"community-of-python/stompman","free":true,"listed":false,"github":"https://github.com/community-of-python/stompman","clone":"git clone https://github.com/community-of-python/stompman.git","description":"Good Python STOMP client & FastStream broker","language":"Python","stars":23,"topics":["activemq","artemis","artemis-mq","jms","messaging","stomp","stomp-client","faststream"],"license":"MIT","category":"chat-messaging","readme_excerpt":"stompman A Python client for STOMP asynchronous messaging protocol that is: - asynchronous, - not abandoned, - has typed, modern, comprehensible API. How To Use Before you start using stompman, make sure you have it installed. If you optionally want to use stompman over a websocket, you can install with stompman[ws] instead of stompman : Initialize a client: Initialize a client with a custom connection class, for example, connecting to a stomp producer over websocket: Sending Messages To send a message, use the following code: Or, to send messages in a transaction: Listening for Messages Now, let's subscribe to a destination and listen for messages: Entered stompman.Client will block forever waiting for messages if there are any active subscriptions. Sometimes it's useful to avoid that: By default, subscription have ACK mode \"client-individual\". If handler successfully processes the message, an ACK frame will be sent. If handler raises an exception, a NACK frame will be sent. You can catch (and log) exceptions using on suppressed exception parameter: You can change the ack mode used by specifying the ack parameter: You can pass custom headers to client.subscribe() : Handling ACK/NACKs yourself If you want to send ACK and NACK frames yourself, you can use client.subscribe with manual ack() : Note that this way exceptions won't be suppressed automatically. Cleaning Up stompman takes care of cleaning up resources automatically. When you leave the context of async context manager","default_branch":null,"files":null,"tree":[],"storefront":"/r/community-of-python","claimed":false,"request_supported":{"post":"https://gitbuyer.com/r/community-of-python/stompman/request-supported","requests":0},"note":"indexed from public GitHub; nothing is for sale on this page. Clone it from GitHub. Paid listings live at /search."}