summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorAlexandru Scvortov <alexandru@rabbitmq.com>2011-08-19 14:18:04 +0100
committerAlexandru Scvortov <alexandru@rabbitmq.com>2011-08-19 14:18:04 +0100
commit04a22b6eba57696c4e5abd5048ee698682ae926e (patch)
treeebd237ac3911473b9d70e98d54ef87195782c09a
parentc701762cd663b39ccb18cca77cd0f6b24eac5c18 (diff)
parent2cafe7eb2f135bca631d150b1d70600e827326a6 (diff)
downloadrabbitmq-server-04a22b6eba57696c4e5abd5048ee698682ae926e.tar.gz
merge bug24354 into default (test_refresh_events/1 sometimes fails)
-rw-r--r--src/rabbit_tests.erl6
1 files changed, 5 insertions, 1 deletions
diff --git a/src/rabbit_tests.erl b/src/rabbit_tests.erl
index bbca55b4..cd5d9be0 100644
--- a/src/rabbit_tests.erl
+++ b/src/rabbit_tests.erl
@@ -1471,7 +1471,11 @@ expect_events(Pid, Type) ->
expect_event(Pid, Type).
expect_event(Pid, Type) ->
- receive #event{type = Type, props = Props} -> Pid = pget(pid, Props)
+ receive #event{type = Type, props = Props} ->
+ case pget(pid, Props) of
+ Pid -> ok;
+ _ -> expect_event(Pid, Type)
+ end
after 1000 -> throw({failed_to_receive_event, Type})
end.