diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2014-01-08 10:36:50 +0000 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2014-01-08 10:36:50 +0000 |
| commit | 581e8e0716e2f55b73369644260f1875eb599236 (patch) | |
| tree | 8efbde48c0d22720415b934e7cb55b105c6e63bb | |
| parent | 880b5d98c0b89a05a0b7349dca0f014bead8e071 (diff) | |
| download | rabbitmq-server-bug25937.tar.gz | |
Rename this againbug25937
| -rw-r--r-- | src/rabbit_amqqueue_process.erl | 2 | ||||
| -rw-r--r-- | src/rabbit_queue_decorator.erl | 4 |
2 files changed, 3 insertions, 3 deletions
diff --git a/src/rabbit_amqqueue_process.erl b/src/rabbit_amqqueue_process.erl index 8bc50bf7..426b0bb2 100644 --- a/src/rabbit_amqqueue_process.erl +++ b/src/rabbit_amqqueue_process.erl @@ -220,7 +220,7 @@ notify_decorators(State = #q{consumers = Consumers, backing_queue = BQ, backing_queue_state = BQS}) -> P = rabbit_queue_consumers:max_active_priority(Consumers), - decorator_callback(qname(State), active_consumers_changed, + decorator_callback(qname(State), consumer_state_changed, [P, BQ:is_empty(BQS)]). decorator_callback(QName, F, A) -> diff --git a/src/rabbit_queue_decorator.erl b/src/rabbit_queue_decorator.erl index 994c9060..6205e2dc 100644 --- a/src/rabbit_queue_decorator.erl +++ b/src/rabbit_queue_decorator.erl @@ -18,7 +18,7 @@ -callback active_for(rabbit_types:amqqueue()) -> boolean(). %% called with Queue, MaxActivePriority, IsEmpty --callback active_consumers_changed( +-callback consumer_state_changed( rabbit_types:amqqueue(), integer(), boolean()) -> 'ok'. -else. @@ -27,7 +27,7 @@ behaviour_info(callbacks) -> [{description, 0}, {startup, 1}, {shutdown, 1}, {policy_changed, 2}, - {active_for, 1}, {active_consumers_changed, 3}]; + {active_for, 1}, {consumer_state_changed, 3}]; behaviour_info(_Other) -> undefined. |