Struct AllocateMessageQueueByMachineRoomNearby 

pub struct AllocateMessageQueueByMachineRoomNearby { /* private fields */ }

Prefers queues local to a consumer and shares queues from rooms without consumers.

Implementations

impl AllocateMessageQueueByMachineRoomNearby

pub fn new( strategy: Box<dyn AllocateMessageQueueStrategy>, resolver: Box<dyn MachineRoomResolver>, ) -> Self

Trait Implementations

impl AllocateMessageQueueStrategy for AllocateMessageQueueByMachineRoomNearby

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

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