diff options
| author | schneefux <schneefux+commit@schneefux.xyz> | 2017-07-26 20:34:27 +0200 |
|---|---|---|
| committer | schneefux <schneefux+commit@schneefux.xyz> | 2017-07-26 20:34:27 +0200 |
| commit | 78a114a0702207d8bfd5412bf59dea67df63c006 (patch) | |
| tree | 3211a8dc2f9a63361091cbc07279db6de7fadabc | |
| parent | 7c78c7dacd397a35456fc76195fef5d1aadb5f12 (diff) | |
| download | processor-78a114a0702207d8bfd5412bf59dea67df63c006.tar.gz processor-78a114a0702207d8bfd5412bf59dea67df63c006.zip | |
add hotfix for web not listening to match_dupe
| -rw-r--r-- | worker.js | 8 |
1 files changed, 6 insertions, 2 deletions
@@ -172,11 +172,15 @@ amqp.connect(RABBITMQ_URI).then(async (rabbit) => { if (msg.properties.headers.notify) { await ch.publish("amq.topic", msg.properties.headers.notify, - new Buffer("matches_dupe")) + new Buffer("matches_dupe")); // send match_dupe to web player.ign.api_id await ch.publish("amq.topic", msg.properties.headers.notify + "." + match.id, - new Buffer("match_dupe")) + new Buffer("match_dupe")); + // HOTFIX TODO remove me, web should listen to match_dupe + await ch.publish("amq.topic", + msg.properties.headers.notify, + new Buffer("match_update")); } await ch.nack(msg, false, false); } else if (match.rosters.length < 2 || match.rosters[0].id == "null") { |
