File 0012-turtle-update-consume-2-consume-3.patch of Package turtle

Overview Repositories Revisions Requests Users Attributes Meta

File 0012-turtle-update-consume-2-consume-3.patch of Package turtle

From fbf9206241e6018500ace5ec5b9c4d07f4a88f3c Mon Sep 17 00:00:00 2001
From: Led <ledest@gmail.com>
Date: Mon, 10 Sep 2018 13:25:43 +0300
Subject: [PATCH 2/3] turtle: update consume/2, consume/3

---
 src/turtle.erl | 12 ++++++------
 1 file changed, 6 insertions(+), 6 deletions(-)

diff --git a/src/turtle.erl b/src/turtle.erl
index 94cf0ff..79b5de5 100644
--- a/src/turtle.erl
+++ b/src/turtle.erl
@@ -287,17 +287,17 @@ await(publisher, Name, Timeout) ->
 %% @doc consume/2 starts consumption on a channel with default parameters
 %% @end
 %% @private
+consume(Channel, #'basic.consume' {} = Consume) ->
+    #'basic.consume_ok' { consumer_tag = Tag } = amqp_channel:call(Channel, Consume),
+    {ok, Tag};
 consume(Channel, Queue) ->
-    consume(Channel, Queue, false).
+    consume(Channel, #'basic.consume' { queue = Queue }).
 
 %% @doc consume/3 starts consumption on a channel with default parameters
 %% @end
 %% @private
-consume(Channel, Queue, NoAck) ->
-   Sub = #'basic.consume' { queue = Queue, no_ack = NoAck },
-   #'basic.consume_ok' { consumer_tag = Tag } =
-       amqp_channel:call(Channel, Sub),
-   {ok, Tag}.
+consume(Channel, Queue, NoAck) when is_boolean(NoAck) ->
+    consume(Channel, #'basic.consume' { queue = Queue, no_ack = NoAck }).
 
 
 %% @doc cancel/2 stop consumption on a channel again.
-- 
2.16.4

Places

File 0012-turtle-update-consume-2-consume-3.patch of Package turtle

Places