Trait rocketmq::producer::selector::QueueSelect

pub trait QueueSelect {
    pub fn select(
        &self, 
        msg: &Message, 
        mqs: &[MessageQueue]
    ) -> Option<MessageQueue>;
}

Required methods

pub fn select(
    &self,
    msg: &Message,
    mqs: &[MessageQueue]
) -> Option<MessageQueue>

Loading content...

Implementors

impl QueueSelect for QueueSelector

pub fn select(
    &self,
    msg: &Message,
    mqs: &[MessageQueue]
) -> Option<MessageQueue>

impl QueueSelect for HashQueueSelector

pub fn select(
    &self,
    msg: &Message,
    mqs: &[MessageQueue]
) -> Option<MessageQueue>

impl QueueSelect for ManualQueueSelector

pub fn select(
    &self,
    msg: &Message,
    _mqs: &[MessageQueue]
) -> Option<MessageQueue>

impl QueueSelect for RandomQueueSelector

pub fn select(
    &self,
    _msg: &Message,
    mqs: &[MessageQueue]
) -> Option<MessageQueue>

impl QueueSelect for RoundRobinQueueSelector

pub fn select(
    &self,
    msg: &Message,
    mqs: &[MessageQueue]
) -> Option<MessageQueue>

Loading content...