Struct event_driven_core::messagebus::ContextManager

pub struct ContextManager {
    pub sender: Sender<Box<dyn Message>>,
}

Task Local Context Manager This is called for every time Messagebus.handle is invoked within which it manages events raised in service. It spawns out Executor that manages transaction.

Fields

sender: Sender<Box<dyn Message>>

Implementations

impl ContextManager

pub fn new() -> (Arc<RwLock<Self>>, Receiver<Box<dyn Message>>)

Creation of context manager returns context manager AND event receiver