anchor.diff:  -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").
  +-include("logplex.hrl").
  +-include("logplex_logging.hrl").
   
   -record(state, {
       dropped_stat_key,
  
positive.code:                 {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()]),
              State#state{accepting=true, num_dropped=0};
          false ->
              State
  
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"),
  