Struct SelectMessageQueueByHash 

pub struct SelectMessageQueueByHash;

A message queue selector that uses hash-based routing.

Routes messages to queues by computing a hash of the provided argument and applying modulo against the available queue count. Messages with identical argument values are consistently routed to the same queue, preserving ordering semantics.

Performance

Selection operates in O(1) time with no heap allocations. The select method is inlined to eliminate function call overhead.

Examples

use rocketmq_client_rust::SelectMessageQueueByHash;
use rocketmq_client_rust::MessageQueueSelector;

let selector = SelectMessageQueueByHash;
let order_id = 12345;
let queue = selector.select(&message_queues, &message, &order_id);

Implementations

impl SelectMessageQueueByHash

pub fn new() -> Self

Returns a new instance.

Trait Implementations

impl Clone for SelectMessageQueueByHash

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for SelectMessageQueueByHash

impl Debug for SelectMessageQueueByHash

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for SelectMessageQueueByHash

fn default() -> Self

Returns the “default value” for a type.

impl<M, A> MessageQueueSelector<M, A> for SelectMessageQueueByHash

where M: MessageTrait, A: JavaHashCode,

fn select( &self, mqs: &[MessageQueue], _msg: &M, arg: &A, ) -> Option<MessageQueue>

Selects a message queue by hashing the argument.

Returns None if the queue list is empty.