We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent ab5ad2f commit 69bff30Copy full SHA for 69bff30
src/taskmaster.ts
@@ -24,21 +24,21 @@ mkdir('-p', config.RUNBOX.DIR)
24
amqp.connect(`amqp://${config.AMQP.USER}:${config.AMQP.PASS}@${config.AMQP.HOST}:${config.AMQP.PORT}`, (err, connection: Connection) => {
25
if (err) {
26
Raven.captureException(err);
27
- return;
+ throw err
28
}
29
30
connection.createChannel((err2, channel) => {
31
if (err2) {
32
Raven.captureException(err2);
33
+ throw err2
34
35
36
channel.assertQueue(successQ);
37
channel.assertQueue(jobQ);
38
channel.assertQueue(errorQ);
39
40
channel.prefetch(1);
41
-
+
42
channel.consume(jobQ, async (msg) => {
43
try {
44
const payload = JSON.parse(msg.content.toString())
0 commit comments