summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorschneefux <schneefux+commit@schneefux.xyz>2017-07-25 20:11:54 +0200
committerschneefux <schneefux+commit@schneefux.xyz>2017-07-25 20:11:54 +0200
commitbe4f5c1b4e9641d57956fe5685ef867186c1fad2 (patch)
treecf15ac44d4afb1cd6873c68f266ca3eab11121f1
parent8fd9305bb207db826701a28bf90ed858b5ad77d7 (diff)
downloadtelesucker-be4f5c1b4e9641d57956fe5685ef867186c1fad2.tar.gz
telesucker-be4f5c1b4e9641d57956fe5685ef867186c1fad2.zip
don't attempt to parse a string as json
-rw-r--r--worker.js6
1 files changed, 3 insertions, 3 deletions
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 });