Struct tokio_nsq::NSQConsumer
source · [−]pub struct NSQConsumer { /* private fields */ }
Expand description
An NSQD consumer corresponding to multiple NSQD instances.
A consumer will automatically restart and maintain connections to multiple
NSQD instances. As connections die, and restart REQ
will automatically be
rebalanced to the active connections.
Implementations
Consume events from NSQ connections including status events.
Consume events from NSQ connections ignoring all connection status events.
Indicates if any connections are blocked on processing before being able to receive more messages. This can be useful for determining when to process a batch of messages.
Trait Implementations
Auto Trait Implementations
impl !RefUnwindSafe for NSQConsumer
impl Send for NSQConsumer
impl Sync for NSQConsumer
impl Unpin for NSQConsumer
impl !UnwindSafe for NSQConsumer
Blanket Implementations
Mutably borrows from an owned value. Read more
pub fn vzip(self) -> V
Attaches the provided Subscriber
to this type, returning a
WithDispatch
wrapper. Read more
Attaches the current default Subscriber
to this type, returning a
WithDispatch
wrapper. Read more