Struct Engine 

pub struct Engine { /* private fields */ }

Implementations

impl Engine

pub async fn start( settings: &Settings, app: Arc<dyn Application>, store_factory: Arc<dyn MessageStoreFactory>, log_factory: Arc<dyn LogFactory>, ) -> Result<Engine>

Create all configured sessions and start their network activity: acceptors listen, initiators dial (and keep re-dialing).

pub fn session( &self, begin_string: &str, sender_comp_id: &str, target_comp_id: &str, ) -> Option<SessionHandle>

Handle for the session matching this BeginString + CompID pair.

pub fn sessions(&self) -> impl Iterator<Item = &SessionHandle>

pub async fn stop(self)

Graceful shutdown: log out every session, stop their tasks, and stop listening/dialing.