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
