fix(startup): Respect large bot sharding

SideProjectGuys · Mar 30, 2020 · 07d3418 · 07d3418
1 parent 5475e2b
commit 07d3418
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/src/framework/services/RabbitMq.ts b/src/framework/services/RabbitMq.ts
@@ -9,6 +9,8 @@ import { FakeChannel } from '../../util';
 
 import { IMService } from './Service';
 
+const BOT_SHARDING = 16;
+
 interface ShardMessage {
 	id: string;
 	cmd: ShardCommand;
@@ -133,7 +135,8 @@ export class RabbitMqService extends IMService {
 			return;
 		}
 
-		this.qNameStartup = `shard-${this.client.instance}-start`;
+		const startupSuffix = this.client.shardCount > BOT_SHARDING ? `-${this.client.shardId % BOT_SHARDING}` : '';
+		this.qNameStartup = `shard-${this.client.instance}-start${startupSuffix}`;
 
 		this.channelStartup = await this.conn.createChannel();
 		this.channelStartup.on('close', async (err) => {