diff options
| author | schneefux <schneefux+commit@schneefux.xyz> | 2017-08-21 19:51:08 +0200 |
|---|---|---|
| committer | schneefux <schneefux+commit@schneefux.xyz> | 2017-08-21 19:51:08 +0200 |
| commit | 1b37486ea7f7b8536450f4171d6389a064dc7750 (patch) | |
| tree | 5ba6e5fde608c4f9c7426cb054f5b1e5c9366f80 | |
| parent | 670d4df1194412e2e5c85aa4d955aa5dd6b975cf (diff) | |
| download | processor-1b37486ea7f7b8536450f4171d6389a064dc7750.tar.gz processor-1b37486ea7f7b8536450f4171d6389a064dc7750.zip | |
remove unused player.$name.$m_id notification
| -rw-r--r-- | worker.js | 6 |
1 files changed, 0 insertions, 6 deletions
@@ -264,12 +264,6 @@ amqp.connect(RABBITMQ_URI).then(async (rabbit) => { switch (m.properties.type) { // new match case "match": - // notify player.name.api_id about match_update - await Promise.map(match_objects, async (mat) => - await ch.publish("amq.topic", - m.properties.headers.notify + "." + mat.id, - new Buffer("match_update")) - ); await ch.publish("amq.topic", m.properties.headers.notify, new Buffer("match_update")); break; |
