anchor.diff:              msg_delay_queues = [],
               status = stopped,
               passed_state = passed_state_new(TraceId, {proto_sched, Logger}),
  -            num_possible_executions = 1
  +            num_possible_executions = 1,
  +            callback_on_deliver = fun(_From, _To, _Msg) -> ok end
             }.
   
   %% @doc Sends out all messages remaining in queues
  
positive.code:     %% stop sending epidemic messages
      erlang:erase(trace_mpath),
      ok.
  
  -spec get_infos() -> [tuple()].
  get_infos() -> get_infos(default).
  
negative.code: -type delay_queue_key()  :: {Dest :: comm:mypid()}.
  -type msg_queues()       :: [queue_key()].
  -type msg_delay_queues() :: [delay_queue_key()].
  
  -type callback_on_deliver() ::
          fun((Src::comm:mypid(), Dest::comm:mypid(), Msg::comm:message()) -> ok).
  
  -record(state,
          {msg_queues              = ?required(state, msg_queues)
  