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:     ok = rpc:call(?TEST_RIAK_NODE, application, set_env, [riak_kv, storage_backend, riak_kv_ets_backend]),
      ok = supervisor:terminate_child({riak_kv_sup, ?TEST_RIAK_NODE}, riak_kv_vnode_sup),
      {ok, _} = supervisor:restart_child({riak_kv_sup, ?TEST_RIAK_NODE}, riak_kv_vnode_sup).
  
  pause_riak_pb_sockets() ->
      Children = supervisor:which_children({riak_kv_pb_socket_sup, ?TEST_RIAK_NODE}),
      Pids = [Pid || {_,Pid,_,_} <- Children],
      [rpc:call(?TEST_RIAK_NODE, sys, suspend, [Pid]) || Pid <- Pids].
  
  resume_riak_pb_sockets() ->
      Children = supervisor:which_children({riak_kv_pb_socket_sup, ?TEST_RIAK_NODE}),
      Pids = [Pid || {_,Pid,_,_} <- Children],
      [rpc:call(?TEST_RIAK_NODE, sys, resume, [Pid]) || Pid <- Pids].
  
  maybe_start_network() ->
      %% Try to spin up net_kernel
  