Struct nats::Message [−][src]
pub struct Message {
pub subject: String,
pub reply: Option<String>,
pub data: Vec<u8>,
pub headers: Option<Headers>,
// some fields omitted
}Expand description
A message received on a subject.
Fields
subject: StringThe subject this message came from.
reply: Option<String>Optional reply subject that may be used for sending a response to this message.
data: Vec<u8>The message contents.
headers: Option<Headers>Optional headers associated with this Message.
Implementations
Acknowledge a JetStream message with a default acknowledgement.
See AckKind documentation for details of what other types of
acks are available. If you need to send a non-default ack, use
the ack_kind method below. If you need to block until the
server acks your ack, use the double_ack method instead.
Returns immediately if this message has already been double-acked.
Acknowledge a JetStream message. See AckKind documentation for
details of what each variant means. If you need to block until the
server acks your ack, use the double_ack method instead.
Does not check whether this message has already been double-acked.
Acknowledge a JetStream message and wait for acknowledgement from the server
that it has received our ack. Retry acknowledgement until we receive a response.
See AckKind documentation for details of what each variant means.
Returns immediately if this message has already been double-acked.
Returns the JetStream message ID
if this is a JetStream message.
Returns None if this is not
a JetStream message with headers
set.
Trait Implementations
Auto Trait Implementations
impl !RefUnwindSafe for Message
impl !UnwindSafe for Message
Blanket Implementations
Mutably borrows from an owned value. Read more
type Output = T
type Output = T
Should always be Self