diff options
| author | Matthew Sackman <matthew@lshift.net> | 2009-08-19 11:23:54 +0100 |
|---|---|---|
| committer | Matthew Sackman <matthew@lshift.net> | 2009-08-19 11:23:54 +0100 |
| commit | 511ef37aa14feacba3673cbbf0f19dc5380603bb (patch) | |
| tree | eaf5d4f90c61c5be249ae0ba7858f4f2f5ecf647 /src | |
| parent | d1cb178e854bc7943953019c8535c7bda4ce6783 (diff) | |
| download | rabbitmq-server-git-511ef37aa14feacba3673cbbf0f19dc5380603bb.tar.gz | |
New branch for bug 21426
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 4903c2c57f..f05f7880b7 100644 --- a/src/rabbit_amqqueue.erl +++ b/src/rabbit_amqqueue.erl @@ -303,10 +303,10 @@ basic_cancel(#amqqueue{pid = QPid}, ChPid, ConsumerTag, OkMsg) -> infinity). notify_sent(QPid, ChPid) -> - gen_server2:cast(QPid, {notify_sent, ChPid}). + gen_server2:pcast(QPid, 8, {notify_sent, ChPid}). unblock(QPid, ChPid) -> - gen_server2:cast(QPid, {unblock, ChPid}). + gen_server2:pcast(QPid, 8, {unblock, ChPid}). internal_delete(QueueName) -> rabbit_misc:execute_mnesia_transaction( |