diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2013-07-24 14:07:13 +0100 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2013-07-24 14:07:13 +0100 |
| commit | 31675d9fc8b6947b88441580e0973ed45d76d715 (patch) | |
| tree | 2c533d60af848de3d48ba1e126ff9f529ff04e44 | |
| parent | a6cc463997862e19b81582e51b1a44c243dfbb0c (diff) | |
| download | rabbitmq-server-31675d9fc8b6947b88441580e0973ed45d76d715.tar.gz | |
Slightly clearer names?
| -rw-r--r-- | src/rabbit_amqqueue_process.erl | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/rabbit_amqqueue_process.erl b/src/rabbit_amqqueue_process.erl index 136168f6..1244d640 100644 --- a/src/rabbit_amqqueue_process.erl +++ b/src/rabbit_amqqueue_process.erl @@ -554,7 +554,7 @@ run_message_queue(State) -> {_IsEmpty1, State1} = deliver_msgs_to_consumers( fun deliver_from_queue_deliver/2, is_empty(State), State), - notify_decorators(queue_finished, [], State1), + notify_decorators(queue_run_finished, [], State1), State1. consumer_priority({_ChPid, #consumer{args = Args}}) -> @@ -1410,7 +1410,7 @@ handle_cast({credit, ChPid, CTag, Credit, Drain}, end); handle_cast(notify_decorators, State) -> - notify_decorators(on_demand, [], State), + notify_decorators(notification_requested, [], State), noreply(State); handle_cast(wake_up, State) -> |