anchor.diff:  %% @doc after processing of consumption messages
   %% @private
   after_execute(Ret, #state{id = Id} = State) ->
  -    _ = defer_consume(Id, ?DEF_CHECK_MAX_INTERVAL_2,
  -                      ?DEF_CHECK_MIN_INTERVAL_2),
  +    ok = defer_consume(Id, ?DEF_CHECK_MAX_INTERVAL_2, ?DEF_CHECK_MIN_INTERVAL_2),
       {Ret, State}.
   
   
  
positive.code:     Interval_1 = decr_interval_fun(Interval, StepInterval),
  
      %% To the next status
      timer:apply_after(timer:seconds(1), ?MODULE, run, [Id]),
      NextStatus = ?ST_RUNNING,
      ok = leo_mq_server:update_consumer_stats(
             PublisherId, NextStatus, BatchOfMsgs_1, Interval_1),
  
negative.code:                                                   {publisher_id, PublisherId},
                                                    {interval, Interval},
                                                    {batch_of_msgs, BatchOfMsgs}]}]),
      ok = defer_consume(Id, ?DEF_CHECK_MAX_INTERVAL_1, ?DEF_CHECK_MIN_INTERVAL_1),
      NamedPid = list_to_atom(atom_to_list(MqDbId)
                              ++ "_"
                              ++ integer_to_list(WorkerSeqNum)),
  