Dispatch

Struct Dispatch 

Source
pub struct Dispatch { /* private fields */ }
Expand description

Represents an outgoing RabbitMQ message.

This dispatch owns only the encoded bytes of the outgoing payload, but not the payload itself. Furthermore, this dispatch provides no facilities for encoding the payload.

It is possible to directly create a DispatchBuilder from an [Envelope].

Implementations§

Source§

impl Dispatch

Source

pub fn builder() -> DispatchBuilder

Creates a new DispatchBuilder.

Source

pub fn from_bytes(bytes: Vec<u8>) -> Self

Shorthand for creating a Dispatch with the payload set to the given bytes.

This method is specifically made to take an owned Vec<u8>, to make sure no copying occurs and the bytes are simply moved into this dispatch.

When copying of bytes is acceptable or desired, use from_byte_ref.

Source

pub fn from_byte_ref(bytes: impl AsRef<[u8]>) -> Self

Shorthand for creating a Dispatch by copying the given bytes to the payload.

Source§

impl Dispatch

Source

pub fn bytes(&self) -> &[u8]

Exposes the encoded content of this message.

Source

pub fn routing_key(&self) -> Option<&str>

Exposes the routing key that is to be used just for this message.

Trait Implementations§

Source§

impl Debug for Dispatch

Source§

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

Formats the value using the given formatter. Read more
Source§

impl From<&[u8]> for Dispatch

Source§

fn from(value: &[u8]) -> Self

Converts to this type from the input type.
Source§

impl From<&str> for Dispatch

Source§

fn from(value: &str) -> Self

Converts to this type from the input type.
Source§

impl From<Box<[u8]>> for Dispatch

Source§

fn from(value: Box<[u8]>) -> Self

Converts to this type from the input type.
Source§

impl<'a> From<Cow<'a, [u8]>> for Dispatch

Source§

fn from(value: Cow<'a, [u8]>) -> Self

Converts to this type from the input type.
Source§

impl<'a> From<Cow<'a, str>> for Dispatch

Source§

fn from(value: Cow<'a, str>) -> Self

Converts to this type from the input type.
Source§

impl From<String> for Dispatch

Source§

fn from(value: String) -> Self

Converts to this type from the input type.
Source§

impl From<Vec<u8>> for Dispatch

Source§

fn from(value: Vec<u8>) -> Self

Converts to this type from the input type.

Auto Trait Implementations§

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<'a, T, E> AsTaggedExplicit<'a, E> for T
where T: 'a,

Source§

fn explicit(self, class: Class, tag: u32) -> TaggedParser<'a, Explicit, Self, E>

Source§

impl<'a, T, E> AsTaggedImplicit<'a, E> for T
where T: 'a,

Source§

fn implicit( self, class: Class, constructed: bool, tag: u32, ) -> TaggedParser<'a, Implicit, Self, E>

Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T> Instrument for T

Source§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
Source§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T> Same for T

Source§

type Output = T

Should always be Self
Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
Source§

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

Source§

fn vzip(self) -> V

Source§

impl<T> WithSubscriber for T

Source§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

impl<T> ErasedDestructor for T
where T: 'static,