anchor.diff:  
   
   init(_) ->
  -    {ok, #state{}}.
  +    %% TODO Leverage os_mon to discover available memory in the system
  +    Max = list_to_integer(config:get("rexi", "buffer_count", "2000")),
  +    {ok, #state{max_count = Max}}.
  +
  +handle_call(erase_buffer, _From, State) ->
  +    {reply, ok, State#state{buffer = queue:new(), count = 0}, 0};
   
   handle_call(get_buffered_count, _From, State) ->
       {reply, State#state.count, State, 0}.
  
positive.code: handle_cast({deliver, Dest, Msg}, #state{buffer = Q, count = C} = State) ->
      margaret_counter:increment([erlang, rexi, buffered]),
      Q2 = queue:in({Dest, Msg}, Q),
      case should_drop() of
      true ->
              {noreply, State#state{buffer = queue:drop(Q2)}, 0};
      false ->
  
negative.code:     count = 0
  }).
  
  start_link(ServerId) ->
      gen_server:start_link({local, ServerId}, ?MODULE, nil, []).
  
  