diff options
| author | Matthias Radestock <matthias@lshift.net> | 2009-08-20 10:52:21 +0100 |
|---|---|---|
| committer | Matthias Radestock <matthias@lshift.net> | 2009-08-20 10:52:21 +0100 |
| commit | bc7e3c07d4c262946f07ac5af28d8fa7016491fd (patch) | |
| tree | ef0edf36410b92792cd259724419de05dc65e2ce | |
| parent | eaf338cc804446f80ba7d30b80e642cb2efa0f82 (diff) | |
| parent | e1992a9114aaea2e4b2528a96dff16f4330f5ca9 (diff) | |
| download | rabbitmq-server-bc7e3c07d4c262946f07ac5af28d8fa7016491fd.tar.gz | |
merge bug21426 into default
| -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( |