anchor.diff:  
   %% gauge for spawned workers for cast requests
   -define(async_workers, async_workers).
  +
  +%% internal counters for overflow events
  +-define(max_processes_reached, max_processes_reached).
  +-define(max_messages_reached, max_messages_reached).
   
   %% ----------------------------------------------------------------------
   %% Erlang interface definitions
  
positive.code:             end
      end.
  
  %% @doc Return current message queue length.
  -spec get_message_queue_len() -> non_neg_integer().
  get_message_queue_len() ->
  
negative.code:     QOSP = proplists:get_value(queue_overflow_suspend_period, Options),
      %% initialize gauge for spawned cast workers
      undefined = put(?async_workers, 0),
      %% initialize internal counters
      undefined = put(?max_processes_reached, 0),
      undefined = put(?max_messages_reached, 0),
      {ok,
       #state{socket = Socket,
              ready = false, %% will wait for 'ready' signal
  