anchor.diff:  -export([start_link/2, start_link/3,
            start/2, start/3,
            stop/1,
  +         set_options/2, set_options/3,
            is_connected/1, is_connected/2,
            ping/1, ping/2,
            get_client_id/1, get_client_id/2,
  
positive.code:         _ ->
              {reply, true, State}
      end;
  handle_call(stop, _From, State) ->
      disconnect(State),
      {stop, normal, ok, State}.
  
negative.code:       ?_test( begin
                    {ok, Pid} = start_link(?TEST_IP, ?TEST_PORT),
                    ?assertEqual(pong, ?MODULE:ping(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
  