Struct Message 

pub struct Message {
    pub properties: MessageProperties,
    pub headers: MessageHeaders,
    pub raw_body: Vec<u8>,
}

A Message is the core of the Celery protocol and is built on top of a Broker’s protocol. Every message corresponds to a task.

Note that the raw_body field is the serialized form of a MessageBody so that a worker can read the meta data of a message without having to deserialize the body first.

Fields

properties: MessageProperties

Message properties correspond to the equivalent AMQP delivery properties.

headers: MessageHeaders

Message headers contain additional meta data pertaining to the Celery protocol.

raw_body: Vec<u8>

A serialized MessageBody.

Implementations

impl Message

pub fn body<T: Task>(&self) -> Result<MessageBody<T>, ProtocolError>

Try deserializing the body.

pub fn task_id(&self) -> &str

Get the task ID.

pub fn json_serialized( &self, delivery_info: Option<DeliveryInfo>, ) -> Result<Vec<u8>, ProtocolError>

Trait Implementations

impl Clone for Message

fn clone(&self) -> Message

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Message

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl PartialEq for Message

fn eq(&self, other: &Message) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl<T> TryFrom<Signature<T>> for Message

where T: Task,

fn try_from(task_sig: Signature<T>) -> Result<Self, Self::Error>

Get a new MessageBuilder from a task signature.

type Error = ProtocolError

The type returned in the event of a conversion error.

impl Eq for Message

impl StructuralPartialEq for Message