Skip to main content

AllocateMessageQueueStrategy

rocketmq_client_rust

Trait AllocateMessageQueueStrategy 

Source 
pub trait AllocateMessageQueueStrategy: Send + Sync {
    // Required methods
    fn allocate(
        &self,
        consumer_group: &CheetahString,
        current_cid: &CheetahString,
        mq_all: &[MessageQueue],
        cid_all: &[CheetahString],
    ) -> Result<Vec<MessageQueue>, Error>;
    fn get_name(&self) -> &'static str;
}
Expand description

Runtime-neutral queue allocation contract.

Required Methods§

Source

fn allocate( &self, consumer_group: &CheetahString, current_cid: &CheetahString, mq_all: &[MessageQueue], cid_all: &[CheetahString], ) -> Result<Vec<MessageQueue>, Error>

Source

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

Dyn Compatibility§

This trait is dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors§