Struct DefaultMessageBroker 

pub struct DefaultMessageBroker { /* private fields */ }

Implementations

impl DefaultMessageBroker

pub fn new() -> Self

Examples found in repository

examples/simple.rs (line 117)

fn main() {
    let tb: Arc<dyn MessageBroker> = Arc::new(DefaultMessageBroker::new());

    let mut s0 = TestSubsciber0::new();
    s0.subscribe(Arc::clone(&tb));

    let mut s1 = TestSubsciber1::new();
    s1.subscribe(Arc::clone(&tb));

    let p0 = TestPublisher::new(Arc::clone(&tb));
    let p1 = TestPublisher::new(Arc::clone(&tb));

    p0.publish(Arc::new(TestMsg0(2)));
    s1.deactivate();
    p1.publish(Arc::new(TestMsg0(5)));
    s1.activate();
    p1.publish(Arc::new(TestMsg1(3)));
    p1.publish(Arc::new(TestMsg1(6)));

    s0.process_messages();
    s1.process_messages();
}

Trait Implementations

impl MessageBroker for DefaultMessageBroker

fn get_message_topic(&self, msg_type_id: MessageTypeId) -> Arc<MessageTopic>

Gets MessageTopic which is responsible for handling messages of the given type.

fn register_subscription( self: Arc<Self>, sub: &mut dyn ErasedSubscription, ) -> Result<(), MessageBrokerError>

Registers the subscription in the broker.

fn unregister_subscription( &self, sub: &mut dyn ErasedSubscription, ) -> Result<(), MessageBrokerError>

Unregisters the subscription in the broker.

fn publish_message( &self, msg: Arc<dyn Message>, ) -> Result<(), MessageBrokerError>

Sends the given message to all subscribers which are listening for messages of its type.