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 | ec6c9a607d1f4c3d59d19fb56cd87e9f79ed6ae5 (patch) | |
| tree | 36c52e06e12d8902857724af6fd60a9c845181a7 | |
| parent | 3592e4dafe2b32f6afe2143afc6fd327a3eb1cd5 (diff) | |
| download | rabbitmq-server-ec6c9a607d1f4c3d59d19fb56cd87e9f79ed6ae5.tar.gz | |
do not use priorities for notify_sent and unblock
since the benefit is unproven
| -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 3018582f..59b4d039 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. |