anchor.diff:      ?inc(?CONN_TCP_ERRORS),
       lager:warning("Unhandled Hive TCP Connector call: ~p", [Message]),
       {reply, ok, State}.
  +
  +handle_cast({checkin, Worker}, State) ->
  +    case checkin_worker(Worker, State) of
  +        {ok, NewState} ->
  +            {noreply, NewState};
  +
  +        {error, Error} ->
  +            lager:error("Hive TCP Connector encountered an error: ~p", [Error]),
  +            {noreply, State}
  +    end;
   
   handle_cast({add, Worker}, State) ->
       Workers = State#tcp_state.workers,
  
positive.code:     Args = proplists:get_value(<<"args">>, Descriptor),
      case jesse:validate_with_schema(jsonx:decode(Schema), Args) of
          {ok, _Args} ->
              %% NOTE TCP connetor is used to listen on the hive side. It's assumed to be fine.
              ok;
  
          {error, Error} ->
  
negative.code:             {reply, {error, Error}, State}
      end;
  
  handle_call({transaction, Transaction}, From, State) ->
      case checkout_worker(State) of
          retry_later ->
  