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 | 02f308b38e41b516691e99dd782f9a7ef83b34fa (patch) | |
| tree | ef0edf36410b92792cd259724419de05dc65e2ce | |
| parent | a0cd42787325be33f62c66705edb064cbb116db6 (diff) | |
| parent | 511ef37aa14feacba3673cbbf0f19dc5380603bb (diff) | |
| download | rabbitmq-server-git-02f308b38e41b516691e99dd782f9a7ef83b34fa.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 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( |