RAII handle for a NATS subscription. More...
#include <subscription.hpp>
Collaboration diagram for subscription:
Public Member Functions | |
| subscription (subscription &&) noexcept | |
| subscription & | operator= (subscription &&) noexcept |
| subscription (const subscription &)=delete | |
| subscription & | operator= (const subscription &)=delete |
| std::string | subject () const |
| Returns the NATS subject this subscription is listening on. | |
| void | drain () |
| Drain the subscription. | |
| subscription (std::unique_ptr< impl > i) | |
Detailed Description
RAII handle for a NATS subscription.
Automatically unsubscribes and frees cnats resources when destroyed. Move-only — subscriptions cannot be shared or copied.
A subscription must not outlive the client that created it.
// ... sub unsubscribes automatically at end of scope
subscription queue_subscribe(std::string_view subject, std::string_view queue_group, message_handler handler)
Queue-group subscribe (competing consumers).
Definition client.cpp:386
Member Function Documentation
◆ drain()
| void drain | ( | ) |
Drain the subscription.
Stops new message delivery and waits for all in-flight messages to be processed before unsubscribing.
