summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMatthias Radestock <matthias@lshift.net>2010-02-03 19:24:10 +0000
committerMatthias Radestock <matthias@lshift.net>2010-02-03 19:24:10 +0000
commit67d7af76f167c6751b317b2504da159f61b6d94c (patch)
treecd0b7e4172cac27007e2556a491196a5dda65928
parentf9d60633a99361adcdcfd7ac7d4e2b641c0efde9 (diff)
downloadrabbitmq-server-67d7af76f167c6751b317b2504da159f61b6d94c.tar.gz
minor refactor
-rw-r--r--src/rabbit_channel.erl11
1 files changed, 5 insertions, 6 deletions
diff --git a/src/rabbit_channel.erl b/src/rabbit_channel.erl
index 2035d561..0477cfb1 100644
--- a/src/rabbit_channel.erl
+++ b/src/rabbit_channel.erl
@@ -1001,12 +1001,11 @@ terminate(#ch{writer_pid = WriterPid, limiter_pid = LimiterPid}) ->
infos(Items, State) -> [{Item, i(Item, State)} || Item <- Items].
-i(pid, _) -> self();
-i(connection, #ch{reader_pid = ReaderPid}) -> ReaderPid;
-i(user, #ch{username = Username}) -> Username;
-i(vhost, #ch{virtual_host = VHost}) -> VHost;
-i(transactional, #ch{transaction_id = none}) -> false;
-i(transactional, #ch{transaction_id = _}) -> true;
+i(pid, _) -> self();
+i(connection, #ch{reader_pid = ReaderPid}) -> ReaderPid;
+i(user, #ch{username = Username}) -> Username;
+i(vhost, #ch{virtual_host = VHost}) -> VHost;
+i(transactional, #ch{transaction_id = TxnKey}) -> TxnKey =/= none;
i(consumer_count, #ch{consumer_mapping = ConsumerMapping}) ->
dict:size(ConsumerMapping);
i(messages_unacknowledged, #ch{unacked_message_q = UAMQ}) ->