anchor.diff:                   {ok, LKs} = ?MODULE:list_keys(Pid, Bucket),
                    ?assertEqual(Ks, lists:sort(LKs))
                end)}
  -    ].
  +,
  +
  +     {"queue test",
  +      ?_test(begin
  +                 %% Would really like this in a nested {setup, blah} structure
  +                 %% but eunit does not allow
  +                 {ok, Pid} = start_link(?TEST_IP, ?TEST_PORT),
  +                 pause_riak_pb_sockets(),
  +                 Me = self(),
  +                 %% this request will block as 
  +                 spawn(fun() -> Me ! {1, ping(Pid)} end), 
  +                 %% this request should be queued as socket will not be created
  +                 spawn(fun() -> Me ! {2, ping(Pid)} end),
  +                 resume_riak_pb_sockets(),
  +                 receive {1,Ping1} -> ?assertEqual(Ping1, pong) end,
  +                 receive {2,Ping2} -> ?assertEqual(Ping2, pong) end
  +             end)}
  +     ].
   
   -endif.
   
  
positive.code:          put/2, put/3,
           delete/3, delete/4,
           list_buckets/1,
           stream_list_buckets/1,
           list_keys/2,
           stream_list_keys/2]).
  
  
negative.code: %% @doc List all buckets on the server
  -spec list_buckets(pid()) -> {ok, [bucket()]} | {error, term()}. 
  list_buckets(Pid) ->
      gen_server:call(Pid, {req, rpblistbucketsreq}).
   
  %% @doc List all keys in a bucket
  -spec list_keys(pid(), bucket()) -> {ok, [key()]}.
  list_keys(Pid, Bucket) ->
  