anchor.diff:  handle_call({remove, Worker}, _From, State) ->
       {reply, ok, remove_worker(Worker, State)};
   
  -handle_call({add, Worker}, _From, State) ->
  +handle_call(stop, _From, State) ->
  +    {stop, shutdown, State};
  +
  +handle_call(Message, _From, State) ->
  +    ?inc(?CONN_TCP_ERRORS),
  +    lager:warning("Unhandled Hive TCP Connector call: ~p", [Message]),
  +    {reply, ok, State}.
  +
  +handle_cast({add, Worker}, State) ->
       Workers = State#tcp_state.workers,
       case checkin_worker(Worker, State#tcp_state{workers = [Worker | Workers]}) of
           {ok, NewState} ->
  -            {reply, ok, NewState};
  -
  -        {error, Error} ->
  -            {reply, {error, Error}, State}
  -    end;
  -
  -handle_call(stop, _From, State) ->
  -    {stop, shutdown, State};
  -
  -handle_call(Message, _From, State) ->
  -    ?inc(?CONN_TCP_ERRORS),
  -    lager:warning("Unhandled Hive TCP Connector cast: ~p", [Message]),
  -    {reply, ok, State}.
  +            {noreply, NewState};
  +
  +        {error, Error} ->
  +            lager:error("Hive TCP Connector encountered an error: ~p", [Error]),
  +            {noreply, State}
  +    end;
   
   handle_cast(Message, State) ->
       ?inc(?CONN_TCP_ERRORS),
  
positive.code:     gen_server:call(Pool, {remove, Worker}).
  
  add(Pool, Worker) ->
      gen_server:call(Pool, {add, Worker}).
  
  %% Gen Server callbacks:
  init({PoolArgs, WorkerArgs}) ->
  
negative.code:     case queue:out(Froms) of
          %% NOTE We have an ongoing transaction which has to be carried out...
          {{value, {From, Transaction}}, NewFroms} when is_function(Transaction, 1) ->
              %% FIXME This shouldn't run here as it may clog the entire connector up.
              gen_server:reply(From, Transaction(Worker)),
              checkin_worker(Worker, State#tcp_state{froms = NewFroms});
  
          %% NOTE ...or an ongoing checkout request...
          {{value, {From, Timer}}, NewFroms} ->
  