diff options
| author | Emile Joubert <emile@rabbitmq.com> | 2011-05-27 09:33:14 +0100 |
|---|---|---|
| committer | Emile Joubert <emile@rabbitmq.com> | 2011-05-27 09:33:14 +0100 |
| commit | c5bb4d5055b01bf6bf6920d9ef7c01a3b9fc8cf5 (patch) | |
| tree | c610e5d543a8606b29d83c6f650ccf8f1ed2e395 /src | |
| parent | 0dde8d8491c22dc4bfe1bd09be9aab9f6c25bbcf (diff) | |
| download | rabbitmq-server-git-c5bb4d5055b01bf6bf6920d9ef7c01a3b9fc8cf5.tar.gz | |
Remove rabbit_consumer.erl
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_consumer.erl | 42 |
1 files changed, 0 insertions, 42 deletions
diff --git a/src/rabbit_consumer.erl b/src/rabbit_consumer.erl deleted file mode 100644 index 1c9d106467..0000000000 --- a/src/rabbit_consumer.erl +++ /dev/null @@ -1,42 +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 Developer of the Original Code is VMware, Inc. -%% Copyright (c) 2007-2011 VMware, Inc. All rights reserved. -%% - --module(rabbit_consumer). - --export([info_all/1]). - --include("rabbit.hrl"). - -%%---------------------------------------------------------------------------- - --ifdef(use_specs). - --spec(info_all/1 :: (rabbit_types:vhost()) -> [rabbit_types:infos()]). - --endif. - -%%---------------------------------------------------------------------------- - -info_all(VHostPath) -> - [[{queue_name, QName#resource.name}, - {channel_pid, ChPid}, - {consumer_tag, ConsumerTag}, - {ack_required, AckRequired}] || - #amqqueue{pid=QPid, name=QName} <- rabbit_amqqueue:list(VHostPath), - {ChPid, ConsumerTag, AckRequired} <- - delegate:invoke(QPid, fun (P) -> - gen_server2:call(P, consumers, infinity) - end)]. |
