diff options
author | Marek Majkowski <marek@rabbitmq.com> | 2010-12-08 13:36:11 +0000 |
---|---|---|
committer | Marek Majkowski <marek@rabbitmq.com> | 2010-12-08 13:36:11 +0000 |
commit | 79a6cc8f2b0adc5956fe4ff4df62aff6f81e1451 (patch) | |
tree | dd2490aec0ad2a89bb7dc293d495d40ed016bc95 | |
parent | a782032665224f63bbc64ceb155cd6cc5fe2a759 (diff) | |
download | rabbitmq-server-79a6cc8f2b0adc5956fe4ff4df62aff6f81e1451.tar.gz |
cosmetic: move unpacking around in channel:deliver
-rw-r--r-- | src/rabbit_channel.erl | 12 |
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; |