diff options
| author | Marek Majkowski <marek@rabbitmq.com> | 2010-12-08 12:45:31 +0000 |
|---|---|---|
| committer | Marek Majkowski <marek@rabbitmq.com> | 2010-12-08 12:45:31 +0000 |
| commit | fc66ac0ce08ee64f241b00f03732c942a01acb04 (patch) | |
| tree | 04489cd2eaafc2efccf8ac4cb01ee5e6e004b5c6 /src | |
| parent | 11453d216582907ba8355d6bd360877e435f7b22 (diff) | |
| download | rabbitmq-server-git-fc66ac0ce08ee64f241b00f03732c942a01acb04.tar.gz | |
cosmetic: Simplify channel:internal_deliver, notify is always true
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_channel.erl | 11 |
1 files changed, 4 insertions, 7 deletions
diff --git a/src/rabbit_channel.erl b/src/rabbit_channel.erl index 0c8ad00ae3..27dbe61172 100644 --- a/src/rabbit_channel.erl +++ b/src/rabbit_channel.erl @@ -266,7 +266,7 @@ handle_cast({deliver, ConsumerTag, AckRequired, Msg}, State1 = lock_message(AckRequired, ack_record(DeliveryTag, ConsumerTag, Msg), State), - ok = internal_deliver(WriterPid, true, ConsumerTag, DeliveryTag, Msg), + ok = internal_deliver(WriterPid, ConsumerTag, DeliveryTag, Msg), {_QName, QPid, _MsgId, _Redelivered, _Msg} = Msg, maybe_incr_stats([{QPid, 1}], case AckRequired of @@ -1240,7 +1240,7 @@ lock_message(true, MsgStruct, State = #ch{unacked_message_q = UAMQ}) -> lock_message(false, _MsgStruct, State) -> State. -internal_deliver(WriterPid, Notify, ConsumerTag, DeliveryTag, +internal_deliver(WriterPid, ConsumerTag, DeliveryTag, {_QName, QPid, _MsgId, Redelivered, #basic_message{exchange_name = ExchangeName, routing_key = RoutingKey, @@ -1250,11 +1250,8 @@ internal_deliver(WriterPid, Notify, ConsumerTag, DeliveryTag, redelivered = Redelivered, exchange = ExchangeName#resource.name, routing_key = RoutingKey}, - ok = case Notify of - true -> rabbit_writer:send_command_and_notify( - WriterPid, QPid, self(), M, Content); - false -> rabbit_writer:send_command(WriterPid, M, Content) - end. + rabbit_writer:send_command_and_notify(WriterPid, QPid, self(), M, Content), + ok. terminate(State) -> stop_confirm_timer(State), |