diff options
| author | Matthew Sackman <matthew@lshift.net> | 2009-08-19 12:17:47 +0100 |
|---|---|---|
| committer | Matthew Sackman <matthew@lshift.net> | 2009-08-19 12:17:47 +0100 |
| commit | 3c3ed97162b330cdf7b43a90625555e683d2fef3 (patch) | |
| tree | 632c7923db6feb7f0ff98591b8db5cca405cbfab /src | |
| parent | 69f592b88940cfe2981cc54cbc4ec256f5431829 (diff) | |
| parent | 511ef37aa14feacba3673cbbf0f19dc5380603bb (diff) | |
| download | rabbitmq-server-git-3c3ed97162b330cdf7b43a90625555e683d2fef3.tar.gz | |
merging in bug21426
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 fdf73729bd..1d9f8c53cd 100644 --- a/src/rabbit_amqqueue.erl +++ b/src/rabbit_amqqueue.erl @@ -317,10 +317,10 @@ basic_cancel(#amqqueue{pid = QPid}, ChPid, ConsumerTag, OkMsg) -> infinity). notify_sent(QPid, ChPid) -> - gen_server2:pcast(QPid, 10, {notify_sent, ChPid}). + gen_server2:pcast(QPid, 8, {notify_sent, ChPid}). unblock(QPid, ChPid) -> - gen_server2:pcast(QPid, 10, {unblock, ChPid}). + gen_server2:pcast(QPid, 8, {unblock, ChPid}). internal_delete(QueueName) -> rabbit_misc:execute_mnesia_transaction( |