Struct MessageSubsystem 

pub struct MessageSubsystem {
    dispatchers: Mutex<HashMap<&'static str, Arc<dyn MessageDispatcherInterface>>>,
    metering_limit: Mutex<u64>,
}

Generic publish/subscribe class that maintains a list of dispatchers.

Dispatchers transmit messages to subscribers and are specific to one message type.

Additionally, holds a global metering limit, which is the sum of each dispatcher MeteringQueue threshold, to drop the connection if passed.

Fields

dispatchers: Mutex<HashMap<&'static str, Arc<dyn MessageDispatcherInterface>>>

metering_limit: Mutex<u64>

Implementations

impl MessageSubsystem

pub fn new() -> Self

Create a new message subsystem.

pub async fn add_dispatch<M: Message>(&self)

Add a new dispatcher for specified Message.

pub async fn subscribe<M: Message>(&self) -> Result<MessageSubscription<M>>

Subscribes to a Message. Using the Message name, the method returns the associated MessageDispatcher from the list of dispatchers and calls subscribe().

pub async fn notify( &self, command: &str, reader: &mut ReadHalf<Box<dyn PtStream + 'static>>, ) -> Result<()>

Transmits a payload to a dispatcher. Returns an error if the payload fails to transmit.

pub async fn trigger_error(&self, err: Error)

Concurrently transmits an error message across dispatchers.

Trait Implementations

impl Default for MessageSubsystem

fn default() -> MessageSubsystem

Returns the “default value” for a type.