Skip to content

Commit 2167c26

Browse files
committed
ackhnowledge messages for now
1 parent ab40de9 commit 2167c26

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

src/taskmaster.ts

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -42,10 +42,11 @@ amqp.connect(`amqp://${config.AMQP.USER}:${config.AMQP.PASS}@${config.AMQP.HOST}
4242

4343
// TODO
4444
channel.sendToQueue(successQ, (new Buffer(JSON.stringify(jobResult))))
45-
channel.ack(msg)
45+
4646
} catch (err) {
4747
Raven.captureException(err);
4848
}
49+
channel.ack(msg)
4950
})
5051
})
5152
})

0 commit comments

Comments
 (0)