Hmm, tweak some more. Is this a real problem?
This commit is contained in:
parent
cf95e6f5a3
commit
1df32db65a
|
@ -33,7 +33,7 @@ test_messages_not_dropped_on_disconnect() ->
|
||||||
[integer_to_list(Count)]) || Count <- lists:seq(1, 1000)],
|
[integer_to_list(Count)]) || Count <- lists:seq(1, 1000)],
|
||||||
rabbit_stomp_client:disconnect(Client),
|
rabbit_stomp_client:disconnect(Client),
|
||||||
QName = rabbit_misc:r(<<"/">>, queue, <<"bulk-test">>),
|
QName = rabbit_misc:r(<<"/">>, queue, <<"bulk-test">>),
|
||||||
timer:sleep(2000),
|
timer:sleep(3000),
|
||||||
rabbit_amqqueue:with(
|
rabbit_amqqueue:with(
|
||||||
QName, fun(Q) ->
|
QName, fun(Q) ->
|
||||||
1000 = pget(messages, rabbit_amqqueue:info(Q, [messages]))
|
1000 = pget(messages, rabbit_amqqueue:info(Q, [messages]))
|
||||||
|
|
Loading…
Reference in New Issue