Struct QueueChannel 

pub struct QueueChannel { /* private fields */ }

Implementations

impl QueueChannel

pub fn with_id<S>(id: S) -> QueueChannel

where S: Into<String>,

Create a new queue channel with an explicit identifier.

pub fn with_random_id() -> QueueChannel

Create a new queue channel with a randomly generated UUID-based identifier.

pub fn id(&self) -> &str

Returns the channel identifier.

Trait Implementations

impl Channel for QueueChannel

fn id(&self) -> &str

fn send<'life0, 'async_trait>( &'life0 self, exchange: Exchange, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, QueueChannel: 'async_trait,

fn kind(&self) -> &'static str

fn as_any(&self) -> &(dyn Any + 'static)

impl Clone for QueueChannel

fn clone(&self) -> QueueChannel

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl CorrelationSupport for QueueChannel

fn send_with_correlation<'life0, 'async_trait>( &'life0 self, exchange: Exchange, ) -> Pin<Box<dyn Future<Output = Result<String, Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, QueueChannel: 'async_trait,

fn receive_by_correlation<'life0, 'life1, 'async_trait>( &'life0 self, corr_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Option<Exchange>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, QueueChannel: 'async_trait,

impl Debug for QueueChannel

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

Formats the value using the given formatter.

impl PollableChannel for QueueChannel

fn try_receive<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Option<Exchange>> + Send + 'async_trait>>

where 'life0: 'async_trait, QueueChannel: 'async_trait,