diff options
| author | Ben Hood <0x6e6562@gmail.com> | 2008-12-18 17:37:45 +0000 |
|---|---|---|
| committer | Ben Hood <0x6e6562@gmail.com> | 2008-12-18 17:37:45 +0000 |
| commit | dba384837ef7b6312a8264aed290d8f767c05e5b (patch) | |
| tree | 479860963d90dd327196ad3285502ba5de12e857 | |
| parent | c0f9c53586bf0876e135410876b813bee5476993 (diff) | |
| download | rabbitmq-server-git-dba384837ef7b6312a8264aed290d8f767c05e5b.tar.gz | |
Got rid of superfluous PD read
| -rw-r--r-- | src/rabbit_amqqueue_process.erl | 3 |
1 files changed, 1 insertions, 2 deletions
diff --git a/src/rabbit_amqqueue_process.erl b/src/rabbit_amqqueue_process.erl index b2c619d3b8..d26b0bb441 100644 --- a/src/rabbit_amqqueue_process.erl +++ b/src/rabbit_amqqueue_process.erl @@ -180,7 +180,7 @@ deliver_immediately(Message, Delivered, RoundRobinTail} -> % Use Qos Limits if an ack is required % Query the limiter to find out if a limit has been breached - #cr{limiter_pid = LimiterPid} = ch_record(ChPid), + C = #cr{limiter_pid = LimiterPid} = ch_record(ChPid), case rabbit_limiter:can_send(LimiterPid, self()) of true -> really_deliver(AckRequired, ChPid, ConsumerTag, @@ -189,7 +189,6 @@ deliver_immediately(Message, Delivered, false -> % Have another go by cycling through the consumer % queue - C = ch_record(ChPid), store_ch_record(C#cr{is_limit_active = true}), NewConsumers = block_consumers(ChPid, RoundRobinTail), deliver_immediately(Message, Delivered, |