Enum OutgoingMessage 

pub enum OutgoingMessage<T>
where
    T: Serialize,
{
    Event(OutgoingEvent<T>),
    Request(OutgoingRequest<T>),
    Response(OutgoingResponse<T>),
}

A generic received message.

Variants

Event(OutgoingEvent<T>)

Request(OutgoingRequest<T>)

Response(OutgoingResponse<T>)

Trait Implementations

impl<T> Debug for OutgoingMessage<T>

where T: Serialize + Debug,

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

Formats the value using the given formatter.

impl<T> IntoEnvelope for OutgoingMessage<T>

where T: Serialize,

fn into_envelope(self) -> Result<OutgoingEnvelope, Error>

Wraps an outgoing message into envelope format.

impl<T: Serialize> IntoPublishableMessage for OutgoingMessage<T>

fn into_dump( self: Box<Self>, publisher: &Address, ) -> Result<PublishableMessage, Error>

Serializes the object into dump that can be directly published.

impl<T: Serialize> Publishable for OutgoingMessage<T>

fn destination_topic(&self, publisher: &Address) -> Result<String, Error>

Returns a destination topic as string.

fn qos(&self) -> QoS

Returns QoS for publishing.