Trait MessageQueueSelector 

pub trait MessageQueueSelector: Send + Sync {
    // Required method
    fn select(
        &self,
        mqs: &[MessageQueue],
        msg: &Message,
        arg: &dyn Any,
    ) -> MessageQueue;
}

A trait for selecting a message queue.

This trait defines a method for selecting a message queue from a list of available queues based on the provided message and an additional argument.

Required Methods

fn select( &self, mqs: &[MessageQueue], msg: &Message, arg: &dyn Any, ) -> MessageQueue

Selects a message queue from the provided list.

Arguments

• mqs - A reference to a vector of MessageQueue from which to select.
• msg - A reference to the Message for which the queue is being selected.
• arg - An additional argument that can be used in the selection process.

Returns

The selected MessageQueue.

Implementors