anchor.diff:  -spec(suspend(Id) ->
                ok | {error, any()} when Id::atom()).
   suspend(Id) ->
  -    suspend(Id, 8).
  +    exec_sub_fun(Id, fun suspend/2).
   suspend(_Id, 0) ->
       ok;
   suspend(Id, Seq) ->
  
positive.code: -spec(resume(Id) ->
               ok | {error, any()} when Id::atom()).
  resume(Id) ->
      resume(Id, 8).
  resume(_Id, 0) ->
      ok;
  resume(Id, Seq) ->
  
negative.code: -spec(decr_batch_of_msgs(Id) ->
               ok | {error, any()} when Id::atom()).
  decr_batch_of_msgs(Id) ->
      exec_sub_fun(Id, fun decr_batch_of_msgs/2).
  decr_batch_of_msgs(_Id, 0) ->
      ok;
  decr_batch_of_msgs(Id, Seq) ->
      Id_1 = ?consumer_id(Id, Seq),
      leo_mq_consumer:decr_batch_of_msgs(Id_1),
      decr_batch_of_msgs(Id, Seq - 1).
  
  
  %%--------------------------------------------------------------------
  