stan.py
stan.py copied to clipboard
nats-io
Python Asyncio NATS Streaming Client
Hi there, We were trying to implement automatic reconnection to STAN when the connection was lost, and ran into an issue with the `conn_lost_cb`. If you have a couple of...
Hello! I'm new to nats/stan and sometimes I **lost part of messages** from NATS. Approximative 10 minutes of data every day (messages in 10-minute interval). I'm using this python code...
Can you provide a canonical example of subscriber (with no publication) for systemd?
Similar to https://github.com/nats-io/stan.go#connection-status Example: https://gist.github.com/wallyqs/31215101fc6ed18e49664eb0f64252c5#file-reconnec-streaming-example-py-L50
Is there a method to retrieve the `guid` that is returned when you publish the message on the subscription end?
Do you support the subscription with no ack timeout? RabbitMQ has no timeout for ack, and the messages are considered failed on disconnects.
hey guys, so looking at the pending_limits variable for a subscription, what would happen if someone theoretically sets it to one. I ask because for my use case I need...
Is there a way to figure out if a subscriber has drained all the messages in a given channel and is caught up? I would still want to process all...
Hi there, So looking at the usage w/ closing channels, it'd be really swell to have context managers to ensure that the channels always close even if there's an error:...