heartbeat & attempt to fix transaction

1 files changed, 4 insertions, 4 deletions

diff --git a/worker.js b/worker.js
index eef402b..2fa5fd2 100644
--- a/worker.js
+++ b/worker.js
@@ -18,7 +18,7 @@ var RABBITMQ_URI = process.env.RABBITMQ_URI,
     while (true) {
         try {
             seq = new Seq(DATABASE_URI, { logging: false }),
-            rabbit = await amqp.connect(RABBITMQ_URI),
+            rabbit = await amqp.connect(RABBITMQ_URI, { heartbeat: 30 }),
             ch = await rabbit.createChannel();
             await ch.assertQueue("crunch", {durable: true});
             break;
@@ -160,9 +160,9 @@ var RABBITMQ_URI = process.env.RABBITMQ_URI,
         }));
 
         try {
-            await seq.transaction({ autocommit: false }, async (transaction) => {
-                console.log("inserting batch into db");
-                await Promise.all([
+            console.log("inserting batch into db");
+            await seq.transaction({ autocommit: false }, (transaction) => {
+                return Promise.all([
                     model.PlayerPoint.bulkCreate(player_records, {
                         updateOnDuplicate: [],  // all
                         transaction: transaction