summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMarek Majkowski <marek@rabbitmq.com>2010-12-08 13:36:11 +0000
committerMarek Majkowski <marek@rabbitmq.com>2010-12-08 13:36:11 +0000
commit79a6cc8f2b0adc5956fe4ff4df62aff6f81e1451 (patch)
treedd2490aec0ad2a89bb7dc293d495d40ed016bc95
parenta782032665224f63bbc64ceb155cd6cc5fe2a759 (diff)
downloadrabbitmq-server-79a6cc8f2b0adc5956fe4ff4df62aff6f81e1451.tar.gz
cosmetic: move unpacking around in channel:deliver
-rw-r--r--src/rabbit_channel.erl12
1 files changed, 5 insertions, 7 deletions
diff --git a/src/rabbit_channel.erl b/src/rabbit_channel.erl
index 36db5a94..a1db2ccf 100644
--- a/src/rabbit_channel.erl
+++ b/src/rabbit_channel.erl
@@ -260,18 +260,17 @@ handle_cast({command, Msg}, State = #ch{writer_pid = WriterPid}) ->
ok = rabbit_writer:send_command(WriterPid, Msg),
noreply(State);
-handle_cast({deliver, ConsumerTag, AckRequired, Msg},
+handle_cast({deliver, ConsumerTag, AckRequired,
+ Msg = {_QName, QPid, _MsgId, Redelivered,
+ #basic_message{exchange_name = ExchangeName,
+ routing_key = RoutingKey,
+ content = Content}}},
State = #ch{writer_pid = WriterPid,
next_tag = DeliveryTag}) ->
State1 = lock_message(AckRequired,
ack_record(DeliveryTag, ConsumerTag, Msg),
State),
- {_QName, QPid, _MsgId, Redelivered,
- #basic_message{exchange_name = ExchangeName,
- routing_key = RoutingKey,
- content = Content}} = Msg,
-
M = #'basic.deliver'{consumer_tag = ConsumerTag,
delivery_tag = DeliveryTag,
redelivered = Redelivered,
@@ -279,7 +278,6 @@ handle_cast({deliver, ConsumerTag, AckRequired, Msg},
routing_key = RoutingKey},
rabbit_writer:send_command_and_notify(WriterPid, QPid, self(), M, Content),
- {_QName, QPid, _MsgId, _Redelivered, _Msg} = Msg,
maybe_incr_stats([{QPid, 1}],
case AckRequired of
true -> deliver;