diff options
| author | Matthias Radestock <matthias@rabbitmq.com> | 2013-01-20 13:20:53 +0000 |
|---|---|---|
| committer | Matthias Radestock <matthias@rabbitmq.com> | 2013-01-20 13:20:53 +0000 |
| commit | 488057258e8bd53a62348bd82ae0c70c268638ad (patch) | |
| tree | 7c82a3b5bed8bc6b5a6e63121aa0d982973999c5 | |
| parent | 1e9492f35c5d13f8a49be16c4649cddd95bd32b7 (diff) | |
| download | rabbitmq-server-488057258e8bd53a62348bd82ae0c70c268638ad.tar.gz | |
cosmetic: move spec of internal function and make it more precise
| -rw-r--r-- | src/rabbit_mirror_queue_slave.erl | 13 |
1 files changed, 5 insertions, 8 deletions
diff --git a/src/rabbit_mirror_queue_slave.erl b/src/rabbit_mirror_queue_slave.erl index 9f12b34e..867aa2ed 100644 --- a/src/rabbit_mirror_queue_slave.erl +++ b/src/rabbit_mirror_queue_slave.erl @@ -37,18 +37,10 @@ -include("rabbit.hrl"). -%%---------------------------------------------------------------------------- - -include("gm_specs.hrl"). --ifdef(use_specs). -%% Shut dialyzer up --spec(promote_me/2 :: (_, _) -> no_return()). --endif. - %%---------------------------------------------------------------------------- - -define(CREATION_EVENT_KEYS, [pid, name, @@ -79,6 +71,8 @@ depth_delta }). +%%---------------------------------------------------------------------------- + start_link(Q) -> gen_server2:start_link(?MODULE, Q, []). set_maximum_since_use(QPid, Age) -> @@ -469,6 +463,9 @@ confirm_messages(MsgIds, State = #state { msg_id_status = MS }) -> handle_process_result({ok, State}) -> noreply(State); handle_process_result({stop, State}) -> {stop, normal, State}. +-ifdef(use_specs). +-spec(promote_me/2 :: ({pid(), term()}, #state{}) -> no_return()). +-endif. promote_me(From, #state { q = Q = #amqqueue { name = QName }, gm = GM, backing_queue = BQ, |