diff options
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_msg_store.erl | 7 |
1 files changed, 3 insertions, 4 deletions
diff --git a/src/rabbit_msg_store.erl b/src/rabbit_msg_store.erl index 6be4358cf8..10e325e985 100644 --- a/src/rabbit_msg_store.erl +++ b/src/rabbit_msg_store.erl @@ -280,10 +280,9 @@ read(MsgId, CState) -> %% 2. Check the cur file cache case ets:lookup(?CUR_FILE_CACHE_ETS_NAME, MsgId) of [] -> - Defer = - fun() -> {gen_server2:call( - ?SERVER, {read, MsgId}, infinity), CState} - end, + Defer = fun() -> {gen_server2:pcall( + ?SERVER, 2, {read, MsgId}, infinity), + CState} end, case index_lookup(MsgId, CState) of not_found -> Defer(); MsgLocation -> client_read1(MsgLocation, Defer, CState) |