diff options
Diffstat (limited to 'include')
| -rw-r--r-- | include/rabbit_internal_queue_type_spec.hrl | 55 | ||||
| -rw-r--r-- | include/rabbit_queue.hrl | 44 |
2 files changed, 55 insertions, 44 deletions
diff --git a/include/rabbit_internal_queue_type_spec.hrl b/include/rabbit_internal_queue_type_spec.hrl new file mode 100644 index 0000000000..6409efb6f8 --- /dev/null +++ b/include/rabbit_internal_queue_type_spec.hrl @@ -0,0 +1,55 @@ +%% The contents of this file are subject to the Mozilla Public License +%% Version 1.1 (the "License"); you may not use this file except in +%% compliance with the License. You may obtain a copy of the License at +%% http://www.mozilla.org/MPL/ +%% +%% Software distributed under the License is distributed on an "AS IS" +%% basis, WITHOUT WARRANTY OF ANY KIND, either express or implied. See the +%% License for the specific language governing rights and limitations +%% under the License. +%% +%% The Original Code is RabbitMQ. +%% +%% The Initial Developers of the Original Code are LShift Ltd, +%% Cohesive Financial Technologies LLC, and Rabbit Technologies Ltd. +%% +%% Portions created before 22-Nov-2008 00:00:00 GMT by LShift Ltd, +%% Cohesive Financial Technologies LLC, or Rabbit Technologies Ltd +%% are Copyright (C) 2007-2008 LShift Ltd, Cohesive Financial +%% Technologies LLC, and Rabbit Technologies Ltd. +%% +%% Portions created by LShift Ltd are Copyright (C) 2007-2009 LShift +%% Ltd. Portions created by Cohesive Financial Technologies LLC are +%% Copyright (C) 2007-2009 Cohesive Financial Technologies +%% LLC. Portions created by Rabbit Technologies Ltd are Copyright +%% (C) 2007-2009 Rabbit Technologies Ltd. +%% +%% All Rights Reserved. +%% +%% Contributor(s): ______________________________________. +%% + +-spec(init/2 :: (queue_name(), pid() | atom()) -> state()). +-spec(terminate/1 :: (state()) -> state()). +-spec(publish/2 :: (basic_message(), state()) -> state()). +-spec(publish_delivered/2 :: (basic_message(), state()) -> {ack(), state()}). +-spec(set_queue_ram_duration_target/2 :: + (('undefined' | 'infinity' | number()), state()) -> state()). +-spec(remeasure_rates/1 :: (state()) -> state()). +-spec(ram_duration/1 :: (state()) -> number()). +-spec(fetch/1 :: (state()) -> + {('empty'|{basic_message(), boolean(), ack(), non_neg_integer()}), + state()}). +-spec(ack/2 :: ([ack()], state()) -> state()). +-spec(len/1 :: (state()) -> non_neg_integer()). +-spec(is_empty/1 :: (state()) -> boolean()). +-spec(purge/1 :: (state()) -> {non_neg_integer(), state()}). +-spec(delete_and_terminate/1 :: (state()) -> state()). +-spec(requeue/2 :: ([{basic_message(), ack()}], state()) -> state()). +-spec(tx_publish/2 :: (basic_message(), state()) -> state()). +-spec(tx_rollback/2 :: ([msg_id()], state()) -> state()). +-spec(tx_commit/4 :: ([msg_id()], [ack()], {pid(), any()}, state()) -> + {boolean(), state()}). +-spec(needs_sync/1 :: (state()) -> ('undefined' | {atom(), [any()]})). +-spec(handle_pre_hibernate/1 :: (state()) -> state()). +-spec(status/1 :: (state()) -> [{atom(), any()}]). diff --git a/include/rabbit_queue.hrl b/include/rabbit_queue.hrl deleted file mode 100644 index 66966ba80b..0000000000 --- a/include/rabbit_queue.hrl +++ /dev/null @@ -1,44 +0,0 @@ -%% The contents of this file are subject to the Mozilla Public License -%% Version 1.1 (the "License"); you may not use this file except in -%% compliance with the License. You may obtain a copy of the License at -%% http://www.mozilla.org/MPL/ -%% -%% Software distributed under the License is distributed on an "AS IS" -%% basis, WITHOUT WARRANTY OF ANY KIND, either express or implied. See the -%% License for the specific language governing rights and limitations -%% under the License. -%% -%% The Original Code is RabbitMQ. -%% -%% The Initial Developers of the Original Code are LShift Ltd, -%% Cohesive Financial Technologies LLC, and Rabbit Technologies Ltd. -%% -%% Portions created before 22-Nov-2008 00:00:00 GMT by LShift Ltd, -%% Cohesive Financial Technologies LLC, or Rabbit Technologies Ltd -%% are Copyright (C) 2007-2008 LShift Ltd, Cohesive Financial -%% Technologies LLC, and Rabbit Technologies Ltd. -%% -%% Portions created by LShift Ltd are Copyright (C) 2007-2010 LShift -%% Ltd. Portions created by Cohesive Financial Technologies LLC are -%% Copyright (C) 2007-2010 Cohesive Financial Technologies -%% LLC. Portions created by Rabbit Technologies Ltd are Copyright -%% (C) 2007-2010 Rabbit Technologies Ltd. -%% -%% All Rights Reserved. -%% -%% Contributor(s): ______________________________________. -%% - --record(delta, - { start_seq_id, - count, - end_seq_id %% note the end_seq_id is always >, not >= - }). - --ifdef(use_specs). - --type(delta() :: #delta { start_seq_id :: non_neg_integer(), - count :: non_neg_integer (), - end_seq_id :: non_neg_integer() }). - --endif. |