Skip to content

Commit 71e4101

Browse files
committed
amqp: Add missing ACK for data subscription
Was only delivering options.prefetch packets, then nothing
1 parent e6fc937 commit 71e4101

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

src/amqp.coffee

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -191,8 +191,11 @@ class MessageBroker extends Client
191191
catch e
192192
null
193193
sub.handler sub.binding, data
194+
@channel.ack message
194195

195-
@channel.consume name, onSubscribedQueueData, {}, (err) ->
196+
subscribeOptions =
197+
noAck: false
198+
@channel.consume name, onSubscribedQueueData, subscribeOptions, (err) ->
196199
debug 'broker created subscription queue', err
197200
return callback err
198201

0 commit comments

Comments
 (0)