anchor.diff:                                        KeyBin::binary(),
                                         MessageBin::binary()).
   publish(Id, KeyBin, MessageBin) ->
  -    gen_server:cast(Id, {publish, KeyBin, MessageBin}).
  +    gen_server:call(Id, {publish, KeyBin, MessageBin}, ?DEF_TIMEOUT).
   
   
   %% @doc Retrieve the current state from the queue.
  
positive.code: 
  
  %% @doc gen_server callback - Module:handle_call(Request, From, State) -> Result
  handle_call(status, _From, #state{mq_properties = MQProps,
                                    consumer_status = ConsumerStatus,
                                    consumer_batch_of_msgs = BatchOfMsgs,
  
negative.code: 
  
  %% @doc gen_server callback - Module:handle_cast(Request, State) -> Result
  handle_cast({update_consumer_stats, CnsStatus, CnsBatchOfMsgs, CnsIntervalBetweenBatchProcs}, State) ->
      {noreply, State#state{consumer_status = CnsStatus,
                            consumer_batch_of_msgs = CnsBatchOfMsgs,
  