diff options
| author | schneefux <schneefux+commit@schneefux.xyz> | 2017-07-25 20:11:54 +0200 |
|---|---|---|
| committer | schneefux <schneefux+commit@schneefux.xyz> | 2017-07-25 20:11:54 +0200 |
| commit | be4f5c1b4e9641d57956fe5685ef867186c1fad2 (patch) | |
| tree | cf15ac44d4afb1cd6873c68f266ca3eab11121f1 | |
| parent | 8fd9305bb207db826701a28bf90ed858b5ad77d7 (diff) | |
| download | telesucker-be4f5c1b4e9641d57956fe5685ef867186c1fad2.tar.gz telesucker-be4f5c1b4e9641d57956fe5685ef867186c1fad2.zip | |
don't attempt to parse a string as json
| -rw-r--r-- | worker.js | 6 |
1 files changed, 3 insertions, 3 deletions
@@ -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 }); |
