diff options
| author | Matthias Radestock <matthias@lshift.net> | 2010-02-03 19:24:10 +0000 |
|---|---|---|
| committer | Matthias Radestock <matthias@lshift.net> | 2010-02-03 19:24:10 +0000 |
| commit | c2d4432ee5f331dcab315347574ee09745cb1486 (patch) | |
| tree | cd0b7e4172cac27007e2556a491196a5dda65928 /src | |
| parent | ff5f2a0169cc98414a2509b11088bcf0b496b66f (diff) | |
| download | rabbitmq-server-git-c2d4432ee5f331dcab315347574ee09745cb1486.tar.gz | |
minor refactor
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_channel.erl | 11 |
1 files changed, 5 insertions, 6 deletions
diff --git a/src/rabbit_channel.erl b/src/rabbit_channel.erl index 2035d5611c..0477cfb13d 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}) -> |