diff options
| author | Karl Nilsson <kjnilsson@gmail.com> | 2020-10-05 11:45:16 +0100 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2020-10-05 11:45:16 +0100 |
| commit | 1c128b5f94e15dff4785f5dcd710e419ddc890f0 (patch) | |
| tree | 2036488ba46feca1eabe5ed3738001fea2c24282 | |
| parent | 01ad6dae2f04f463c88bcd844149961b91ecf34d (diff) | |
| parent | 0aa0bf1cf7e2edb32ca17782973677f5ab59ee2b (diff) | |
| download | rabbitmq-server-git-1c128b5f94e15dff4785f5dcd710e419ddc890f0.tar.gz | |
Merge pull request #2459 from rabbitmq/restore-rabbit_amqqueue-deliver
Restore rabbit_amqqueue:deliver/2
| -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 78552ae440..002b21ecb2 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, @@ -1862,6 +1862,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} -> |