Trait mcai_worker_sdk::message_exchange::InternalExchange[−][src]

pub trait InternalExchange {
    fn send_response(&mut self, message: ResponseMessage) -> Result<()>;
    fn get_response_sender(&self) -> Arc<Mutex<dyn ResponseSender + Send>>;
    fn get_worker_response_sender(&self) -> McaiChannel;
    fn get_order_receiver(&self) -> Arc<Mutex<Receiver<OrderMessage>>>;
}

Required methods

`fn send_response(&mut self, message: ResponseMessage) -> Result<()>`[src]

`fn get_response_sender(&self) -> Arc<Mutex<dyn ResponseSender + Send>>`[src]

`fn get_worker_response_sender(&self) -> McaiChannel`[src]

`fn get_order_receiver(&self) -> Arc<Mutex<Receiver<OrderMessage>>>`[src]

Loading content...

Implementors

`impl InternalExchange for LocalExchange`[src]

`fn send_response(&mut self, message: ResponseMessage) -> Result<()>`[src]

`fn get_worker_response_sender(&self) -> McaiChannel`[src]

`fn get_response_sender(&self) -> Arc<Mutex<dyn ResponseSender + Send>>`[src]

`fn get_order_receiver(&self) -> Arc<Mutex<Receiver<OrderMessage>>>`[src]

`impl InternalExchange for RabbitmqExchange`[src]

`fn send_response(&mut self, response: ResponseMessage) -> Result<()>`[src]

`fn get_response_sender(&self) -> Arc<Mutex<dyn ResponseSender + Send>>`[src]

`fn get_worker_response_sender(&self) -> McaiChannel`[src]

`fn get_order_receiver(&self) -> Arc<Mutex<Receiver<OrderMessage>>>`[src]

Loading content...