Sign Up
Log In
Log In
or
Sign Up
Places
All Projects
Status Monitor
Collapse sidebar
home:Ledest:erlang:19
turtle
0011-turtle-add-consume-3.patch
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
Locations
Projects
Search
Status Monitor
Help
OpenBuildService.org
Documentation
API Documentation
Code of Conduct
Contact
Support
@OBShq
Terms
openSUSE Build Service is sponsored by
The Open Build Service is an
openSUSE project
.
Sign Up
Log In
Places
Places
All Projects
Status Monitor