From 6e92eac19aa19607d4734eeddb60fccdfd025535 Mon Sep 17 00:00:00 2001
From: schneefux <schneefux+commit@schneefux.xyz>
Date: Thu, 13 Apr 2017 13:10:30 +0200
Subject: heartbeat & attempt to fix transaction

---
 worker.js | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

(limited to 'worker.js')

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
-- 
cgit v1.3.1