diff options
| author | Alexandru Scvortov <alexandru@rabbitmq.com> | 2011-07-26 14:40:15 +0100 |
|---|---|---|
| committer | Alexandru Scvortov <alexandru@rabbitmq.com> | 2011-07-26 14:40:15 +0100 |
| commit | 97da9158e24c914ff0748795b4e49e2f51243170 (patch) | |
| tree | e505c76fe87addca56228e1ad85eb1bd289c060d | |
| parent | 34cb601fc4d0d2d46c661e1e3d746da501a586fc (diff) | |
| download | rabbitmq-server-97da9158e24c914ff0748795b4e49e2f51243170.tar.gz | |
don't needlessly notify queues
| -rw-r--r-- | src/rabbit_channel.erl | 8 |
1 files changed, 6 insertions, 2 deletions
diff --git a/src/rabbit_channel.erl b/src/rabbit_channel.erl index 925e1f26..7e9e1b29 100644 --- a/src/rabbit_channel.erl +++ b/src/rabbit_channel.erl @@ -1088,8 +1088,12 @@ handle_method(#'channel.flow'{active = true}, _, State#ch{limiter = Limiter2}}; handle_method(#'channel.flow'{active = false}, _, - State = #ch{consumer_mapping = Consumers}) -> - Limiter1 = enable_limiter(State), + State = #ch{consumer_mapping = Consumers, + limiter = Limiter}) -> + Limiter1 = case rabbit_limiter:is_enabled(Limiter) of + true -> Limiter; + false -> enable_limiter(State) + end, State1 = State#ch{limiter = Limiter1}, ok = rabbit_limiter:block(Limiter1), case consumer_queues(Consumers) of |