Enum Queue

pub enum Queue {
    Amqp(AmqpQueue),
    Mqtt(MqttQueue),
}

Variants

Amqp(AmqpQueue)

Mqtt(MqttQueue)

Implementations

impl Queue

pub fn new(opts: QueueOptions<'_>) -> Result<Self, String>

Trait Implementations

impl Clone for Queue

fn clone(&self) -> Queue

Returns a copy of the value.

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

Performs copy-assignment from source.

impl GmqQueue for Queue

fn name(&self) -> &str

To get the queue name.

fn is_recv(&self) -> bool

Is the queue a receiver.

fn status(&self) -> Status

To get the connection status.

fn set_handler(&mut self, handler: Arc<dyn EventHandler>)

To set the queue event handler.

fn clear_handler(&mut self)

To remove the queue event handler.

fn set_msg_handler(&mut self, handler: Arc<dyn MessageHandler>)

To set the queue message handler.

fn connect(&mut self) -> Result<(), Box<dyn StdError>>

To connect to the message queue. The GmqQueue will connect to the queue using another runtime task and report status with Statuss.

fn close<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<(), Box<dyn StdError + Send + Sync>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

To close the queue.

fn send_msg<'life0, 'async_trait>( &'life0 self, payload: Vec<u8>, ) -> Pin<Box<dyn Future<Output = Result<(), Box<dyn StdError + Send + Sync>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

To send a message (for senders only).