From be4f5c1b4e9641d57956fe5685ef867186c1fad2 Mon Sep 17 00:00:00 2001 From: schneefux Date: Tue, 25 Jul 2017 20:11:54 +0200 Subject: don't attempt to parse a string as json --- worker.js | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) (limited to 'worker.js') diff --git a/worker.js b/worker.js index 2c9d0c0..18de020 100644 --- a/worker.js +++ b/worker.js @@ -45,17 +45,17 @@ amqp.connect(RABBITMQ_URI).then(async (rabbit) => { await ch.prefetch(1); ch.consume(QUEUE, async (msg) => { - const payload = JSON.parse(msg.content.toString()); + const url = msg.content.toString(); try { - await getTelemetry(payload, msg.properties.headers.match_api_id); + await getTelemetry(url, msg.properties.headers.match_api_id); } catch (err) { logger.error("Telemetry download error", err); ch.nack(msg, false, false); return; } - logger.info("done", payload); + logger.info("done", url); ch.ack(msg); }, { noAck: false }); -- cgit v1.3.1