diff options
| author | Alexandru Scvortov <alexandru@rabbitmq.com> | 2011-01-14 12:18:11 +0000 |
|---|---|---|
| committer | Alexandru Scvortov <alexandru@rabbitmq.com> | 2011-01-14 12:18:11 +0000 |
| commit | 50a71233462074d78d85c6fa71e253373d5be496 (patch) | |
| tree | b2cd18f93b611e19a2ae2a6185fb990597bb530f /src | |
| parent | 98c7ee913093c6bf80ba7e2a3ecd23b13c2ac942 (diff) | |
| download | rabbitmq-server-git-50a71233462074d78d85c6fa71e253373d5be496.tar.gz | |
cosmetic
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_channel.erl | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/src/rabbit_channel.erl b/src/rabbit_channel.erl index 45e21a5a10..28980b7015 100644 --- a/src/rabbit_channel.erl +++ b/src/rabbit_channel.erl @@ -1244,17 +1244,17 @@ is_message_persistent(Content) -> IsPersistent end. -process_routing_result(unroutable, _, XName, MsgSeqNo, Msg, State) -> +process_routing_result(unroutable, _, XName, MsgSeqNo, Msg, State) -> ok = basic_return(Msg, State#ch.writer_pid, no_route), send_confirms([MsgSeqNo], XName, State); -process_routing_result(not_delivered, _, XName, MsgSeqNo, Msg, State) -> +process_routing_result(not_delivered, _, XName, MsgSeqNo, Msg, State) -> ok = basic_return(Msg, State#ch.writer_pid, no_consumers), send_confirms([MsgSeqNo], XName, State); -process_routing_result(routed, [], XName, MsgSeqNo, _, State) -> +process_routing_result(routed, [], XName, MsgSeqNo, _, State) -> send_confirms([MsgSeqNo], XName, State); -process_routing_result(routed, _, _, undefined, _, State) -> +process_routing_result(routed, _, _, undefined, _, State) -> State; -process_routing_result(routed, QPids, XName, MsgSeqNo, _, State) -> +process_routing_result(routed, QPids, XName, MsgSeqNo, _, State) -> #ch{queues_for_msg = QFM, unconfirmed = UC, exchange_for_msg = EFM} = State, [maybe_monitor(QPid) || QPid <- QPids], |