rocketmq_client_rust::consumer::mq_consumer

Trait MQConsumer

Source 
pub trait MQConsumer: MQAdmin {
    // Required methods
    async fn send_message_back(
        &mut self,
        msg: MessageExt,
        delay_level: i32,
        broker_name: &str,
    ) -> RocketMQResult<()>;
    async fn fetch_subscribe_message_queues(
        &mut self,
        topic: &str,
    ) -> RocketMQResult<Vec<MessageQueue>>;
}

Required Methods§

Source

async fn send_message_back( &mut self, msg: MessageExt, delay_level: i32, broker_name: &str, ) -> RocketMQResult<()>

Source

async fn fetch_subscribe_message_queues( &mut self, topic: &str, ) -> RocketMQResult<Vec<MessageQueue>>

Dyn Compatibility§

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.

Implementors§