summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMatthias Radestock <matthias@rabbitmq.com>2010-11-06 11:30:08 +0000
committerMatthias Radestock <matthias@rabbitmq.com>2010-11-06 11:30:08 +0000
commitb59033e1fab1cbf632c8c72c4277b21a40b31745 (patch)
tree67d02fcb997a9056494f65e853ca67adaf315d71
parent6495b5278172e17ff3561007e2dc2ff7ef8d8d59 (diff)
downloadrabbitmq-server-git-b59033e1fab1cbf632c8c72c4277b21a40b31745.tar.gz
remove rabbit_amqqueue:pseudo_queue
it's not used by any of our code and plugins anymore
-rw-r--r--src/rabbit_amqqueue.erl9
1 files changed, 0 insertions, 9 deletions
diff --git a/src/rabbit_amqqueue.erl b/src/rabbit_amqqueue.erl
index 9d78bafa95..9d8d82e206 100644
--- a/src/rabbit_amqqueue.erl
+++ b/src/rabbit_amqqueue.erl
@@ -36,7 +36,6 @@
maybe_run_queue_via_backing_queue/2,
update_ram_duration/1, set_ram_duration_target/2,
set_maximum_since_use/2, maybe_expire/1, drop_expired/1]).
--export([pseudo_queue/2]).
-export([lookup/1, with/2, with_or_die/2, assert_equivalence/5,
check_exclusive_access/2, with_exclusive_access_or_die/3,
stat/1, deliver/2, requeue/3, ack/4, reject/4]).
@@ -162,7 +161,6 @@
-spec(set_maximum_since_use/2 :: (pid(), non_neg_integer()) -> 'ok').
-spec(maybe_expire/1 :: (pid()) -> 'ok').
-spec(on_node_down/1 :: (node()) -> 'ok').
--spec(pseudo_queue/2 :: (binary(), pid()) -> rabbit_types:amqqueue()).
-endif.
@@ -497,13 +495,6 @@ delete_queue(QueueName) ->
ok = mnesia:delete({rabbit_queue, QueueName}),
rabbit_binding:remove_transient_for_destination(QueueName).
-pseudo_queue(QueueName, Pid) ->
- #amqqueue{name = QueueName,
- durable = false,
- auto_delete = false,
- arguments = [],
- pid = Pid}.
-
safe_delegate_call_ok(F, Pids) ->
{_, Bad} = delegate:invoke(Pids,
fun (Pid) ->