diff options
author | Alexandru Scvortov <alexandru@rabbitmq.com> | 2010-12-08 12:57:23 +0000 |
---|---|---|
committer | Alexandru Scvortov <alexandru@rabbitmq.com> | 2010-12-08 12:57:23 +0000 |
commit | b8c1c445ff4dd26c8827bcfeb25a4c4628af3fb8 (patch) | |
tree | c546a5acc3ef73c9589f60a4d695522962933ff2 | |
parent | 20657361da97b619a8ccfa56acc315c64d2e65da (diff) | |
download | rabbitmq-server-bug23581.tar.gz |
cosmeticbug23581
-rw-r--r-- | src/rabbit_channel.erl | 14 |
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, |