/* Ċ Ġ* ĠCopyright ĠÂ© Ġ 2 0 2 0 - 2 0 2 1 , ĠSimp lex ion , ĠH ung ary Ġand Ġcontributors . ĠUse Ġof Ġthis Ġsource Ġcode Ġis Ġgoverned Ġby Ġthe ĠApache Ġ 2 . 0 Ġlicense . Ċ Ġ*/ Ċ package Ġz ak ad ab ar . lib . schedule . business Ċ Ċ import Ġkotlinx . datetime . Instant Ċ import Ġz ak ad ab ar . core . data . EntityId Ċ import Ġz ak ad ab ar . core . util . UUID Ċ import Ġz ak ad ab ar . lib . schedule . data . Job Ċ import Ġz ak ad ab ar . lib . schedule . data . Subscription Ċ Ċ interface ĠDispatcher Event Ġ{ ĊĠĠĠ Ġval Ġaction Namespace : ĠString ? ĊĠĠĠ Ġval Ġaction Type : ĠString ? Ċ } Ċ Ċ interface ĠJob Event Ġ: ĠDispatcher Event Ġ{ ĊĠĠĠ Ġoverride Ġval Ġaction Namespace : ĠString ĊĠĠĠ Ġoverride Ġval Ġaction Type : ĠString ĊĠĠĠ Ġval Ġjob Id : ĠEntity Id < Job > ĊĠĠĠ Ġval Ġspecific : ĠBoolean Ċ } Ċ Ċ open Ġclass ĠJob Create Event ( ĊĠĠĠ Ġoverride Ġval Ġaction Namespace : ĠString , ĊĠĠĠ Ġoverride Ġval Ġaction Type : ĠString , ĊĠĠĠ Ġoverride Ġval Ġjob Id : ĠEntity Id < Job >, ĊĠĠĠ Ġoverride Ġval Ġspecific : ĠBoolean , ĊĠĠĠ Ġval Ġaction Data Ġ: ĠString , ĊĠĠĠ Ġval Ġstart At : ĠInstant ? Ċ ) Ġ: ĠJob Event Ċ Ċ open Ġclass ĠJob Success Event ( ĊĠĠĠ Ġoverride Ġval Ġaction Namespace : ĠString , ĊĠĠĠ Ġoverride Ġval Ġaction Type : ĠString , ĊĠĠĠ Ġoverride Ġval Ġjob Id : ĠEntity Id < Job >, ĊĠĠĠ Ġoverride Ġval Ġspecific : ĠBoolean , Ċ ) Ġ: ĠJob Event Ċ Ċ open Ġclass ĠJob Fail Event ( ĊĠĠĠ Ġoverride Ġval Ġaction Namespace : ĠString , ĊĠĠĠ Ġoverride Ġval Ġaction Type : ĠString , ĊĠĠĠ Ġoverride Ġval Ġjob Id : ĠEntity Id < Job >, ĊĠĠĠ Ġoverride Ġval Ġspecific : ĠBoolean , ĊĠĠĠ Ġval Ġretry At : ĠInstant ?, ĊĠĠĠ Ġval Ġaction Data Ġ: ĠString Ċ ) Ġ: ĠJob Event Ċ Ċ open Ġclass ĠJob Cancel Event ( ĊĠĠĠ Ġoverride Ġval Ġaction Namespace : ĠString , ĊĠĠĠ Ġoverride Ġval Ġaction Type : ĠString , ĊĠĠĠ Ġoverride Ġval Ġjob Id : ĠEntity Id < Job >, ĊĠĠĠ Ġoverride Ġval Ġspecific : ĠBoolean Ċ ) Ġ: ĠJob Event Ċ Ċ open Ġclass ĠRequest Job Cancel Event ( ĊĠĠĠ Ġoverride Ġval Ġaction Namespace : ĠString , ĊĠĠĠ Ġoverride Ġval Ġaction Type : ĠString , ĊĠĠĠ Ġoverride Ġval Ġjob Id : ĠEntity Id < Job >, ĊĠĠĠ Ġoverride Ġval Ġspecific : ĠBoolean Ċ ) Ġ: ĠJob Event Ċ Ċ open Ġclass ĠSubscription Create Event ( ĊĠĠĠ Ġoverride Ġval Ġaction Namespace : ĠString ?, ĊĠĠĠ Ġoverride Ġval Ġaction Type : ĠString ?, ĊĠĠĠ Ġvar Ġsubscription Id : ĠEntity Id < Subscription >, ĊĠĠĠ Ġvar Ġnode Url : ĠString , ĊĠĠĠ Ġvar ĠnodeId : ĠUUID , Ċ ) Ġ: ĠDispatcher Event Ċ Ċ open Ġclass ĠSubscription Delete Event ( ĊĠĠĠ Ġoverride Ġval Ġaction Namespace : ĠString ?, ĊĠĠĠ Ġoverride Ġval Ġaction Type : ĠString ?, ĊĠĠĠ Ġvar Ġsubscription Id : ĠEntity Id < Subscription > Ċ ) Ġ: ĠDispatcher Event Ċ Ċ open Ġclass ĠPush Fail Event ( ĊĠĠĠ Ġoverride Ġval Ġaction Namespace : ĠString , ĊĠĠĠ Ġoverride Ġval Ġaction Type : ĠString , ĊĠĠĠ Ġoverride Ġval Ġjob Id : ĠEntity Id < Job >, ĊĠĠĠ Ġoverride Ġval Ġspecific : ĠBoolean Ċ ) Ġ: ĠJob Event Ċ Ċ open Ġclass ĠPending Check Event ( ĊĠĠĠ Ġoverride Ġval Ġaction Namespace : ĠString ? Ġ= Ġnull , ĊĠĠĠ Ġoverride Ġval Ġaction Type : ĠString ? Ġ= Ġnull Ċ ) Ġ: ĠDispatcher Event Ċ