diff options
| author | Philip Kuryloski <kuryloskip@vmware.com> | 2020-10-05 10:19:11 +0200 |
|---|---|---|
| committer | Philip Kuryloski <kuryloskip@vmware.com> | 2020-10-05 10:19:11 +0200 |
| commit | 0aa0bf1cf7e2edb32ca17782973677f5ab59ee2b (patch) | |
| tree | 892eef50b59ef9493cb7c4d58003652df5033b99 | |
| parent | 31ec214e1a44d348bde09e78b73269b469a32359 (diff) | |
| download | rabbitmq-server-git-restore-rabbit_amqqueue-deliver.tar.gz | |
Restore rabbit_amqqueue:deliver/2restore-rabbit_amqqueue-deliver
For rabbit_exchange_type_recent_history and any other plugins that use it
| -rw-r--r-- | src/rabbit_amqqueue.erl | 7 |
1 files changed, 6 insertions, 1 deletions
diff --git a/src/rabbit_amqqueue.erl b/src/rabbit_amqqueue.erl index b4bee8068f..7c0b46a44a 100644 --- a/src/rabbit_amqqueue.erl +++ b/src/rabbit_amqqueue.erl @@ -16,7 +16,7 @@ with/2, with/3, with_or_die/2, assert_equivalence/5, check_exclusive_access/2, with_exclusive_access_or_die/3, - stat/1, + stat/1, deliver/2, requeue/3, ack/3, reject/4]). -export([not_found/1, absent/2]). -export([list/0, list/1, info_keys/0, info/1, info/2, info_all/1, info_all/2, @@ -1848,6 +1848,11 @@ pseudo_queue(#resource{kind = queue} = QueueName, Pid, Durable) immutable(Q) -> amqqueue:set_immutable(Q). +-spec deliver([amqqueue:amqqueue()], rabbit_types:delivery()) -> 'ok'. + +deliver(Qs, Delivery) -> + rabbit_queue_type:deliver(Qs, Delivery, stateless). + get_quorum_nodes(Q) -> case amqqueue:get_type_state(Q) of #{nodes := Nodes} -> |