summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorAlexandru Scvortov <alexandru@rabbitmq.com>2010-12-08 12:57:23 +0000
committerAlexandru Scvortov <alexandru@rabbitmq.com>2010-12-08 12:57:23 +0000
commitb8c1c445ff4dd26c8827bcfeb25a4c4628af3fb8 (patch)
treec546a5acc3ef73c9589f60a4d695522962933ff2
parent20657361da97b619a8ccfa56acc315c64d2e65da (diff)
downloadrabbitmq-server-bug23581.tar.gz
cosmeticbug23581
-rw-r--r--src/rabbit_channel.erl14
1 files changed, 7 insertions, 7 deletions
diff --git a/src/rabbit_channel.erl b/src/rabbit_channel.erl
index 2b779bd6..4957d777 100644
--- a/src/rabbit_channel.erl
+++ b/src/rabbit_channel.erl
@@ -532,13 +532,13 @@ handle_method(#'basic.publish'{exchange = ExchangeNameBin,
DecodedContent = rabbit_binary_parser:ensure_content_decoded(Content),
IsPersistent = is_message_persistent(DecodedContent),
{MsgSeqNo, State1}
- = case Duration =/= none of
- false -> {undefined, State};
- true -> SeqNo = State#ch.publish_seqno,
- {SeqNo,
- State#ch{publish_seqno = SeqNo + 1,
- unconfirmed =
- gb_sets:add(SeqNo, State#ch.unconfirmed)}}
+ = case Duration of
+ none -> {undefined, State};
+ _ -> SeqNo = State#ch.publish_seqno,
+ {SeqNo,
+ State#ch{publish_seqno = SeqNo + 1,
+ unconfirmed =
+ gb_sets:add(SeqNo, State#ch.unconfirmed)}}
end,
Message = #basic_message{exchange_name = ExchangeName,
routing_key = RoutingKey,