[−][src]Trait mcai_worker_sdk::processor::Process

pub trait Process<P, ME> {
    pub fn new(
        message_event: Arc<Mutex<ME>>, 
        response_sender: McaiChannel, 
        worker_configuration: WorkerConfiguration
    ) -> Self;

    pub fn handle(
        &mut self, 
        message_event: Arc<Mutex<ME>>, 
        order_message: OrderMessage
    ) -> Result<()>;

    pub fn get_current_job_id(
        &self, 
        message_event: Arc<Mutex<ME>>
    ) -> Option<u64>;
}

Required methods

pub fn new(
    message_event: Arc<Mutex<ME>>,
    response_sender: McaiChannel,
    worker_configuration: WorkerConfiguration
) -> Self[src]

pub fn handle(
    &mut self,
    message_event: Arc<Mutex<ME>>,
    order_message: OrderMessage
) -> Result<()>[src]

pub fn get_current_job_id(&self, message_event: Arc<Mutex<ME>>) -> Option<u64>[src]

Loading content...

Implementors

Loading content...