anchor.diff:  
   
   %% @doc gen_server callback - Module:handle_call(Request, From, State) -> Result
  +handle_call({publish, KeyBin, MessageBin}, _From, State) ->
  +    Reply = put_message(KeyBin, MessageBin, State),
  +    {reply, Reply, State};
  +
   handle_call(status, _From, #state{mq_properties = MQProps,
                                     consumer_status = ConsumerStatus,
                                     consumer_batch_of_msgs = BatchOfMsgs,
  
positive.code:                                       KeyBin::binary(),
                                        MessageBin::binary()).
  publish(Id, KeyBin, MessageBin) ->
      gen_server:cast(Id, {publish, KeyBin, MessageBin}).
  
  
  %% @doc Retrieve the current state from the queue.
  
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,
  