diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2012-02-24 13:50:26 +0000 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2012-02-24 13:50:26 +0000 |
| commit | 64c16f9c30c24e79f9d51c0aab9f08a88a795454 (patch) | |
| tree | 40766cf48ea1b884afcc293d95d40d53b9a6c2a7 | |
| parent | 88932ab6393c7ec7a92a12bb97a4001e6b5002d0 (diff) | |
| download | rabbitmq-server-bug24605.tar.gz | |
Marginally tidierbug24605
| -rw-r--r-- | src/rabbit_channel.erl | 7 |
1 files changed, 4 insertions, 3 deletions
diff --git a/src/rabbit_channel.erl b/src/rabbit_channel.erl index a54494b5..24cfbcf8 100644 --- a/src/rabbit_channel.erl +++ b/src/rabbit_channel.erl @@ -1498,6 +1498,7 @@ i(user, #ch{user = User}) -> User#user.username; i(vhost, #ch{virtual_host = VHost}) -> VHost; i(transactional, #ch{tx_status = TE}) -> TE =/= none; i(confirm, #ch{confirm_enabled = CE}) -> CE; +i(name, State) -> name(State); i(consumer_count, #ch{consumer_mapping = ConsumerMapping}) -> dict:size(ConsumerMapping); i(messages_unconfirmed, #ch{unconfirmed_mq = UMQ}) -> @@ -1512,12 +1513,12 @@ i(prefetch_count, #ch{limiter = Limiter}) -> rabbit_limiter:get_limit(Limiter); i(client_flow_blocked, #ch{limiter = Limiter}) -> rabbit_limiter:is_blocked(Limiter); -i(name, #ch{conn_name = ConnName, - channel = Channel}) -> - list_to_binary(rabbit_misc:format("~s (~p)", [ConnName, Channel])); i(Item, _) -> throw({bad_argument, Item}). +name(#ch{conn_name = ConnName, channel = Channel}) -> + list_to_binary(rabbit_misc:format("~s (~p)", [ConnName, Channel])). + maybe_incr_redeliver_stats(true, QPid, State) -> maybe_incr_stats([{QPid, 1}], redeliver, State); maybe_incr_redeliver_stats(_, _, _State) -> |