Struct Delivery 

pub struct Delivery<B> { /* private fields */ }

A message that contains a payload associated with a bus

Implementations

impl<'i, 'b, 'f, B> Delivery<B>

where B: RpcCommBus, B::InitialPayload: Deserialize<'i> + Serialize, B::BackPayload: Deserialize<'b> + Serialize, B::ForthPayload: Deserialize<'f> + Serialize,

pub async fn reply_recv_many( &self, back_payload: &B::BackPayload, rpc_chan: &RpcChannel, ) -> Result<impl Stream<Item = Delivery<ForthReply<B>>>>

Reply to a message that was sent by the receiver of the initial message and await multiple replies from the receiver. The messages can be obtained by calling futures::StreamExt::next on the returned Stream.

pub async fn reply_recv( &self, back_payload: &B::BackPayload, rpc_chan: &RpcChannel, ) -> Result<impl Future<Output = Delivery<ForthReply<B>>>>

Reply to a message that was sent by the receiver of the initial message and await one reply from the receiver. The message can be obtained by awaiting the returned Future.

impl<'p, 'r, B> Delivery<B>

where B: RpcBus, B::PublishPayload: Deserialize<'p> + Serialize, B::ReplyPayload: Deserialize<'r> + Serialize,

pub async fn reply( &self, reply_payload: &B::ReplyPayload, chan: &impl Channel, ) -> Result<()>

Reply to a Delivery.

impl<'p, 'r, B> Delivery<B>

where B: Bus, B::PublishPayload: Deserialize<'p> + Serialize,

pub fn get_payload(&'p self) -> Result<B::PublishPayload>

Deserialize and return the payload from the Delivery

pub fn get_uuid(&self) -> Option<Result<Uuid>>

Get the message correlation Uuid

pub fn get_reply_uuid(&self) -> Option<Result<Uuid>>

Get the correlation Uuid of the message this message is a reply to

pub fn routing_key(&self) -> &str

Get routing key of this message

pub async fn ack(&self, multiple: bool) -> Result<()>

Ack the message

pub fn redelivered(&self) -> bool

Get whether this message was redelivered or not

pub async fn nack(&self, multiple: bool, requeue: bool) -> Result<()>

Nack the message

Trait Implementations

impl<B: Debug> Debug for Delivery<B>

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

Formats the value using the given formatter.

impl<B> From<Delivery> for Delivery<B>

fn from(delivery: Delivery) -> Self

Converts to this type from the input type.