anchor.diff:        ?_test( begin
                     {ok, Pid} = start_link(?TEST_IP, ?TEST_PORT),
                     ?assertEqual(pong, ?MODULE:ping(Pid)),
  -                  ?assertEqual(true, is_connected(Pid))
  +                  ?assertEqual(true, is_connected(Pid)),
  +                  stop(Pid)
                 end)},
  +     {"reconnect test",
  +      ?_test( begin
  +                  %% Make sure originally there
  +                  {ok, Pid} = start_link(?TEST_IP, ?TEST_PORT),
  +                  
  +                  %% Change the options to allow reconnection/queueing
  +                  set_options(Pid, [queue_if_disconnected]),
  +                  
  +                  %% Kill the socket
  +                  kill_riak_pb_sockets(),
  +                  ?assertEqual(pong, ?MODULE:ping(Pid)),
  +                  stop(Pid)
  +              end)},
  +
        {"set client id",
         ?_test(
            begin
  
positive.code: %% @doc Disconnect the socket and stop the process
  stop(Pid) ->
      gen_server:call(Pid, stop).
  
  %% @doc Return true if connected to the remote server and {false, [{Reason,integer()}]}
  %%      with a list of failed connect reasons
  
negative.code:         _ ->
              {reply, true, State}
      end;
  handle_call({set_options, Options}, _From, State) ->
      {reply, ok, parse_options(Options, State)};
  handle_call(stop, _From, State) ->
      disconnect(State),
      {stop, normal, ok, State}.
  