diff options
| author | Matthew Sackman <matthew@lshift.net> | 2009-10-19 13:20:30 +0100 |
|---|---|---|
| committer | Matthew Sackman <matthew@lshift.net> | 2009-10-19 13:20:30 +0100 |
| commit | 13f0c5c47a83473dc6f7fbfa89e150eeaa3e70e8 (patch) | |
| tree | e8690034fd3583f0aa88b004557a2b5ca0f40864 /src | |
| parent | 689e6891d261cef91868966d070e5d2474aa68ac (diff) | |
| download | rabbitmq-server-git-13f0c5c47a83473dc6f7fbfa89e150eeaa3e70e8.tar.gz | |
now() -> make_ref()
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_tests.erl | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/src/rabbit_tests.erl b/src/rabbit_tests.erl index db54b6d39a..15ba5122e1 100644 --- a/src/rabbit_tests.erl +++ b/src/rabbit_tests.erl @@ -838,12 +838,12 @@ msg_store_contains(Atom, MsgIds) -> rabbit_msg_store:contains(MsgId) end, Atom, MsgIds). msg_store_sync(MsgIds) -> - Now = now(), + Ref = make_ref(), Self = self(), ok = rabbit_msg_store:sync(MsgIds, - fun () -> Self ! {sync, Now} end), + fun () -> Self ! {sync, Ref} end), receive - {sync, Now} -> ok + {sync, Ref} -> ok after 10000 -> io:format("Sync from msg_store missing for msg_ids ~p~n", [MsgIds]), |