Struct ProcessingJobAfterCreateHandler3 

pub struct ProcessingJobAfterCreateHandler3 {
    pub event_publisher: Option<Arc<ProcessingJobEventPublisher>>,
    pub action_executor: Option<Arc<ProcessingJobActionExecutor>>,
}

AfterCreate handler

Fields

event_publisher: Option<Arc<ProcessingJobEventPublisher>>

Event publisher for emitting domain events

action_executor: Option<Arc<ProcessingJobActionExecutor>>

Action executor for side effects

Implementations

impl ProcessingJobAfterCreateHandler3

pub fn new() -> Self

pub fn with_event_publisher( self, publisher: Arc<ProcessingJobEventPublisher>, ) -> Self

pub fn with_action_executor( self, executor: Arc<ProcessingJobActionExecutor>, ) -> Self

Trait Implementations

impl TriggerHandler<TriggerContext<ProcessingJob>, TriggerEvent> for ProcessingJobAfterCreateHandler3

fn events(&self) -> Vec<ProcessingJobTriggerEvent>

Events this handler responds to.

fn handle<'life0, 'life1, 'async_trait>( &'life0 self, ctx: &'life1 ProcessingJobTriggerContext, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Handle the trigger event.

fn priority(&self) -> i32

Execution priority — lower values run first. Default: 0.

fn continue_on_error(&self) -> bool

Whether to keep dispatching after this handler errors. Default: false.