diff options
| author | Matthias Radestock <matthias@rabbitmq.com> | 2010-11-06 13:08:48 +0000 |
|---|---|---|
| committer | Matthias Radestock <matthias@rabbitmq.com> | 2010-11-06 13:08:48 +0000 |
| commit | 0d3669759559681b61bef7c2345fee02e6e50da1 (patch) | |
| tree | 4cf40aede0c7b39aad990adb595b0946f757d291 | |
| parent | 540f080c6a04725173c2d197d1d1092e9110f0cd (diff) | |
| parent | e72282afdbf921a0cf983821815cb3db03282309 (diff) | |
| download | rabbitmq-server-git-0d3669759559681b61bef7c2345fee02e6e50da1.tar.gz | |
merge heads
| -rw-r--r-- | src/rabbit_amqqueue.erl | 9 |
1 files changed, 9 insertions, 0 deletions
diff --git a/src/rabbit_amqqueue.erl b/src/rabbit_amqqueue.erl index 9d8d82e206..9d78bafa95 100644 --- a/src/rabbit_amqqueue.erl +++ b/src/rabbit_amqqueue.erl @@ -36,6 +36,7 @@ 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]). @@ -161,6 +162,7 @@ -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. @@ -495,6 +497,13 @@ 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) -> |