anchor.diff:                  {ok, Fun} -> Fun(self(), start_accepting);
                   error -> ok
               end,
  -            io:format("logplex_queue accepting=true num_dropped=~w key=~p queue=~p~n", [NumDropped, Key, which_queue()]),
  +            ?INFO("at=enable_producer accepting=true num_dropped=~w key=~p queue=~p~n", [NumDropped, Key, which_queue()]),
               State#state{accepting=true, num_dropped=0};
           false ->
               State
  
positive.code: -export([in/2, out/1, out/2, info/1, get/2, set_max_length/2, stop/1]).
  -export([register/2, all_workers/1]).
  
  -include_lib("logplex.hrl").
  
  -record(state, {
      dropped_stat_key,
  
negative.code: init([Props]) ->
      Name = proplists:get_value(name, Props),
      Self = self(),
      ?INFO("at=init name=~p", [Name]),
      State = #state{
          dropped_stat_key = build_stat_key(Name, "dropped"),
          length_stat_key = build_stat_key(Name, "length"),
  