Struct MqttQueue

pub struct MqttQueue { /* private fields */ }

Manages a MQTT queue.

Implementations

impl MqttQueue

pub fn new( opts: MqttQueueOptions, conn: &MqttConnection, ) -> Result<MqttQueue, String>

Create a queue instance.

Trait Implementations

impl Clone for MqttQueue

fn clone(&self) -> MqttQueue

Returns a copy of the value.

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

Performs copy-assignment from source.

impl GmqQueue for MqttQueue

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).