File 0034-turtle_publisher-add-clause-to-handle_rpc-2-for-exis.patch of Package turtle

From 1bc8c6cce6fe253bf1e0a1f7106189fd97591592 Mon Sep 17 00:00:00 2001
From: Led <ledest@gmail.com>
Date: Wed, 6 Nov 2019 17:09:36 +0200
Subject: [PATCH] turtle_publisher: add clause to handle_rpc/2 for existing
 queue

---
 src/turtle_publisher.erl | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/src/turtle_publisher.erl b/src/turtle_publisher.erl
index 4460b92..5d41df9 100644
--- a/src/turtle_publisher.erl
+++ b/src/turtle_publisher.erl
@@ -315,6 +315,9 @@ handle_confirms(_, _) -> ok.
 %% Different ways of enabling RPC on the connection. If given `enable' it just creates
 %% an anonymous queue. If given `{enable, Q}' It looks for that queue.
 %% @end
+handle_rpc(Channel, #{ rpc := {existing, Q}}) ->
+    {ok, Tag} = turtle:consume(Channel, Q),
+    {ok, Q, Tag};
 handle_rpc(Channel, #{ rpc := {enable, Q}}) ->
     #'queue.declare_ok' {} = amqp_channel:call(Channel,
         #'queue.declare' { exclusive = true, auto_delete = true, durable = false, queue = Q }),
-- 
2.16.4

openSUSE Build Service is sponsored by