Skip to content

Commit 1dbae5b

Browse files
committed
amqp: Use noAck option
1 parent 71e4101 commit 1dbae5b

File tree

1 file changed

+1
-2
lines changed

1 file changed

+1
-2
lines changed

src/amqp.coffee

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -191,10 +191,9 @@ class MessageBroker extends Client
191191
catch e
192192
null
193193
sub.handler sub.binding, data
194-
@channel.ack message
195194

196195
subscribeOptions =
197-
noAck: false
196+
noAck: true
198197
@channel.consume name, onSubscribedQueueData, subscribeOptions, (err) ->
199198
debug 'broker created subscription queue', err
200199
return callback err

0 commit comments

Comments
 (0)