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