Struct tokio_nsq::NSQMessage
source · [−]pub struct NSQMessage {
pub body: Vec<u8>,
pub attempt: u16,
pub id: [u8; 16],
pub timestamp: u64,
/* private fields */
}
Expand description
An NSQ message. If this message is dropped with being finished and the respective NSQ daemon connection still exists the message will automatically by requeued.
Fields
body: Vec<u8>
attempt: u16
id: [u8; 16]
timestamp: u64
Implementations
Trait Implementations
Auto Trait Implementations
impl !RefUnwindSafe for NSQMessage
impl Send for NSQMessage
impl Sync for NSQMessage
impl Unpin for NSQMessage
impl !UnwindSafe for NSQMessage
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