diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2013-08-20 15:29:46 +0100 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2013-08-20 15:29:46 +0100 |
| commit | e8237d531a62b7ad5b787fcf8c301082ed507917 (patch) | |
| tree | a7ae04a3af5c253793ac3dce898bcb71a147969a | |
| parent | 81080c1b4388dae2420e6e32406d943f884a2e30 (diff) | |
| download | rabbitmq-server-e8237d531a62b7ad5b787fcf8c301082ed507917.tar.gz | |
Tighter and slightly more self-documenting.
| -rw-r--r-- | src/rabbit_queue_decorator.erl | 9 |
1 files changed, 8 insertions, 1 deletions
diff --git a/src/rabbit_queue_decorator.erl b/src/rabbit_queue_decorator.erl index d3dec9dc..a0d0cca5 100644 --- a/src/rabbit_queue_decorator.erl +++ b/src/rabbit_queue_decorator.erl @@ -8,6 +8,13 @@ -ifdef(use_specs). +-type(notify_event() :: 'consumer_blocked' | + 'consumer_unblocked' | + 'queue_run_finished' | + 'basic_consume' | + 'basic_cancel' | + 'notification_requested'). + -callback startup(rabbit_types:amqqueue()) -> 'ok'. -callback shutdown(rabbit_types:amqqueue()) -> 'ok'. @@ -17,7 +24,7 @@ -callback active_for(rabbit_types:amqqueue()) -> boolean(). --callback notify(rabbit_types:amqqueue(), atom(), any()) -> 'ok'. +-callback notify(rabbit_types:amqqueue(), notify_event(), any()) -> 'ok'. -else. |