diff options
| author | Matthias Radestock <matthias@lshift.net> | 2009-03-13 08:58:45 +0000 |
|---|---|---|
| committer | Matthias Radestock <matthias@lshift.net> | 2009-03-13 08:58:45 +0000 |
| commit | 8cdc8193dfec21a659bb5417650312545db6c8d6 (patch) | |
| tree | 36c52e06e12d8902857724af6fd60a9c845181a7 /src | |
| parent | de5f50f4d73f6768f810d8aaa0f354ca785c89de (diff) | |
| download | rabbitmq-server-git-8cdc8193dfec21a659bb5417650312545db6c8d6.tar.gz | |
do not use priorities for notify_sent and unblock
since the benefit is unproven
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_amqqueue.erl | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/rabbit_amqqueue.erl b/src/rabbit_amqqueue.erl index 3018582f94..59b4d039e7 100644 --- a/src/rabbit_amqqueue.erl +++ b/src/rabbit_amqqueue.erl @@ -200,10 +200,10 @@ list(VHostPath) -> map(VHostPath, F) -> rabbit_misc:filter_exit_map(F, list(VHostPath)). info(#amqqueue{ pid = QPid }) -> - gen_server2:call(QPid, info). + gen_server2:pcall(QPid, 9, info). info(#amqqueue{ pid = QPid }, Items) -> - case gen_server2:call(QPid, {info, Items}) of + case gen_server2:pcall(QPid, 9, {info, Items}) of {ok, Res} -> Res; {error, Error} -> throw(Error) end. |