summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorkjnilsson <knilsson@pivotal.io>2020-11-03 11:22:28 +0000
committerkjnilsson <knilsson@pivotal.io>2020-11-03 12:12:51 +0000
commitedd4d75a9b832f6148f1f3fe1a239afe59450a18 (patch)
treec717e27000ab5a5bfba0ef4cc57dea4937a29a49
parent18f94c832b063d429ee1f99b8f7f1b5178e6fc02 (diff)
downloadrabbitmq-server-git-ack-after-queue-delete.tar.gz
remove unused functionack-after-queue-delete
-rw-r--r--src/rabbit_queue_type.erl10
1 files changed, 0 insertions, 10 deletions
diff --git a/src/rabbit_queue_type.erl b/src/rabbit_queue_type.erl
index 9d794e13ee..569daa7bb2 100644
--- a/src/rabbit_queue_type.erl
+++ b/src/rabbit_queue_type.erl
@@ -36,9 +36,6 @@
is_server_named_allowed/1
]).
-%% temporary
--export([with/3]).
-
%% gah what is a good identity of a classic queue including all replicas
-type queue_name() :: rabbit_types:r(queue).
-type queue_ref() :: queue_name() | atom().
@@ -499,13 +496,6 @@ dequeue(Q, NoAck, LimiterPid, CTag, Ctxs) ->
Err
end.
-%% temporary
-with(QRef, Fun, Ctxs) ->
- #ctx{state = State0} = Ctx = get_ctx(QRef, Ctxs),
- {Res, State} = Fun(State0),
- {Res, set_ctx(QRef, Ctx#ctx{state = State}, Ctxs)}.
-
-
get_ctx(Q, #?STATE{ctxs = Contexts}) when ?is_amqqueue(Q) ->
Ref = qref(Q),
case Contexts of