:bug: fix rabbit mq -> fanout instead of work queue

1 files changed, 2 insertions, 2 deletions

diff --git a/src/util/Event.ts b/src/util/Event.ts

index e0bcadd4..4dd56417 100644
--- a/src/util/Event.ts
+++ b/src/util/Event.ts
@@ -5,10 +5,10 @@ export async function emitEvent(payload: Omit<Event, "created_at">) {
 		const id = (payload.channel_id || payload.user_id || payload.guild_id) as string;
 		if (!id) console.error("event doesn't contain any id", payload);
 		const data = typeof payload.data === "object" ? JSON.stringify(payload.data) : payload.data; // use rabbitmq for event transmission
-		await RabbitMQ.channel?.assertQueue(id);
+		await RabbitMQ.channel?.assertExchange(id, "fanout", { durable: false });
 
 		// assertQueue isn't needed, because a queue will automatically created if it doesn't exist
-		const successful = RabbitMQ.channel?.sendToQueue(id, Buffer.from(`${data}`), { type: payload.event });
+		const successful = RabbitMQ.channel?.publish(id, "", Buffer.from(`${data}`), { type: payload.event });
 		if (!successful) throw new Error("failed to send event");
 	} else {
 		// use mongodb for event transmission