File 0011-turtle-add-consume-3.patch of Package turtle

Overview Repositories Revisions Requests Users Attributes Meta

File 0011-turtle-add-consume-3.patch of Package turtle

From 0db6a93a00370c70e85ff55add959d12bbc1a175 Mon Sep 17 00:00:00 2001
From: Led <ledest@gmail.com>
Date: Wed, 1 Nov 2017 14:50:42 +0200
Subject: [PATCH 1/3] turtle: add consume/3

---
 src/turtle.erl | 10 ++++++++--
 1 file changed, 8 insertions(+), 2 deletions(-)

diff --git a/src/turtle.erl b/src/turtle.erl
index d204203..94cf0ff 100644
--- a/src/turtle.erl
+++ b/src/turtle.erl
@@ -35,7 +35,7 @@
 -export([
 	declare/2, declare/3,
 	open_channel/1, open_connection/1,
-	consume/2, cancel/2,
+	consume/2, consume/3, cancel/2,
 	qos/2
 ]).
 
@@ -288,7 +288,13 @@ await(publisher, Name, Timeout) ->
 %% @end
 %% @private
 consume(Channel, Queue) ->
-   Sub = #'basic.consume' { queue = Queue },
+    consume(Channel, Queue, false).
+
+%% @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}.
-- 
2.16.4

Places

File 0011-turtle-add-consume-3.patch of Package turtle

Places