summaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authorEmile Joubert <emile@rabbitmq.com>2011-05-27 09:33:14 +0100
committerEmile Joubert <emile@rabbitmq.com>2011-05-27 09:33:14 +0100
commitc5bb4d5055b01bf6bf6920d9ef7c01a3b9fc8cf5 (patch)
treec610e5d543a8606b29d83c6f650ccf8f1ed2e395 /src
parent0dde8d8491c22dc4bfe1bd09be9aab9f6c25bbcf (diff)
downloadrabbitmq-server-git-c5bb4d5055b01bf6bf6920d9ef7c01a3b9fc8cf5.tar.gz
Remove rabbit_consumer.erl
Diffstat (limited to 'src')
-rw-r--r--src/rabbit_consumer.erl42
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)].