diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2011-02-10 12:54:57 +0000 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2011-02-10 12:54:57 +0000 |
| commit | 18e02d755fa9d0d5279b76fcfbedc40bb06cc036 (patch) | |
| tree | cef87e02fd10283561b13318f0fbc9fa7cfb777a | |
| parent | 3fd2ad4953f0b120c3b0cb4967ff380e87e70c39 (diff) | |
| parent | 086240048ba0500bc5d802a1876207ce707b5ddc (diff) | |
| download | rabbitmq-server-git-18e02d755fa9d0d5279b76fcfbedc40bb06cc036.tar.gz | |
Merged bug23811 (no need for amqqueue:notify_sent to use delegate)
| -rw-r--r-- | src/rabbit_amqqueue.erl | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/rabbit_amqqueue.erl b/src/rabbit_amqqueue.erl index 1d42380959..6e5aae27c7 100644 --- a/src/rabbit_amqqueue.erl +++ b/src/rabbit_amqqueue.erl @@ -422,7 +422,7 @@ basic_cancel(#amqqueue{pid = QPid}, ChPid, ConsumerTag, OkMsg) -> infinity). notify_sent(QPid, ChPid) -> - delegate_cast(QPid, {notify_sent, ChPid}). + gen_server2:cast(QPid, {notify_sent, ChPid}). unblock(QPid, ChPid) -> delegate_cast(QPid, {unblock, ChPid}). |