ppfun/pixelplanet
13
Fork 18
Code Issues 24 Pull Requests Releases 2 Activity

refactor shards subscription

Browse Source
This commit is contained in:
HF 2022-09-11 14:52:20 +02:00
parent 3946614b3a
commit 5e61aea368
1 changed files with 2 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/socket/MessageBroker.js
View File

@ -78,6 +78,7 @@ class MessageBroker extends SocketEvents {
} }
if (!this.shards[message]) { if (!this.shards[message]) {
console.log(`CLUSTER: Shard ${message} connected`); console.log(`CLUSTER: Shard ${message} connected`);
this.shards[message] = Date.now();
await this.subscriber.subscribe( await this.subscriber.subscribe(
message, message,
(buffer) => this.onShardBinaryMessage(buffer, message), (buffer) => this.onShardBinaryMessage(buffer, message),
@ -85,6 +86,7 @@ class MessageBroker extends SocketEvents {
); );
// immediately give new shards informations // immediately give new shards informations
this.publisher.publish('bc', this.thisShard); this.publisher.publish('bc', this.thisShard);
return;
} }
this.shards[message] = Date.now(); this.shards[message] = Date.now();
return; return;