anchor.diff:      process_flag(trap_exit, true), %% NOTE In order to clean up properly.
       PoolName = proplists:get_value(pool_name, WorkerArgs),
       Size = proplists:get_value(<<"size">>, PoolArgs),
  +    %% NOTE This won't spawn more connections, but rather will increase
  +    %% NOTE the maximal request queue size.
  +    Overflow = proplists:get_value(<<"overflow">>, PoolArgs),
       Port = proplists:get_value(<<"port">>, WorkerArgs),
       State = #tcp_state{
                  pool_name = PoolName,
                  workers = [],
                  workers_queue = queue:new(),
                  froms = queue:new(),
  -               froms_len = 0
  +               froms_len = 0,
  +               froms_limit = Size + Overflow
                 },
       case ranch:start_listener(PoolName, Size,
                                 ranch_tcp, [{port, Port}],
  
positive.code:           pool_name,
            froms,
            froms_len,
            workers,
            workers_queue
           }).
  
negative.code:         retry_later ->
              Queue = State#tcp_state.froms,
              Len = State#tcp_state.froms_len,
              Limit = State#tcp_state.froms_limit,
              case Len of
                  Limit ->
                      ?inc(?CONN_TCP_ERRORS),
                      ErrorMsg = hive_error_utils:format("Hive TCP Connector ~s's request queue is full.",
                                                         [State#tcp_state.pool_name]),
                      lager:error(ErrorMsg),
                      {reply, {error, {tcp_error, ErrorMsg}}, State};
  
                  _Otherwise ->
                      {noreply, State#tcp_state{froms = queue:in({From, Transaction}, Queue), froms_len = Len + 1}}
              end;
  
  
  
          {ok, Worker, NewState} ->
              Reply = Transaction(Worker),
  