Struct QueueRouter 

pub struct QueueRouter { /* private fields */ }

Registry for named queue backends (multi-backend hosts).

Implementations

impl QueueRouter

pub fn new() -> Self

Empty registry.

pub fn with_default(backend: Arc<dyn QueueBackend>) -> Self

Register a single default backend under DEFAULT_BACKEND_NAME.

pub fn register(&mut self, name: &str, backend: Arc<dyn QueueBackend>)

Register during initial setup (mutable bootstrap).

Panics

Panics if the internal lock is poisoned.

pub fn register_runtime( &self, name: &str, backend: Arc<dyn QueueBackend>, ) -> Result<()>

Register after Self::set_global (runtime registration).

Errors

Returns BosonError::Internal if the lock is poisoned.

pub fn resolve(&self, name: &str) -> Result<Arc<dyn QueueBackend>>

Resolve a backend by logical name.

Errors

Returns BosonError::Internal if the lock is poisoned, or BosonError::UnknownBackend when name is not registered.

pub fn set_global(router: Self)

Install the process-global router (call once at host boot).

pub fn global() -> Arc<Self>

Global router (panics if Self::set_global was not called).

Panics

Panics when Self::set_global was not called before this function.

pub fn try_global() -> Option<Arc<Self>>

Optional global router.

Trait Implementations

impl Debug for QueueRouter

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

Formats the value using the given formatter.

impl Default for QueueRouter

fn default() -> Self

Returns the “default value” for a type.