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 | e1992a9114aaea2e4b2528a96dff16f4330f5ca9 (patch) | |
| tree | eaf5d4f90c61c5be249ae0ba7858f4f2f5ecf647 | |
| parent | e4862945d91dd5fead85a8db6a48c480a31746ac (diff) | |
| download | rabbitmq-server-bug21426.tar.gz | |
New branch for bug 21426bug21426
| -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 4903c2c5..f05f7880 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( |