Problem same name of queue

Anime-Manga · Oct 15, 2023 · a2d3922 · a2d3922
1 parent 9ab4abb
commit a2d3922
Showing 1 changed file with 8 additions and 8 deletions.
diff --git a/src/Cesxhin.AnimeManga.NotifyService/Program.cs b/src/Cesxhin.AnimeManga.NotifyService/Program.cs
@@ -67,32 +67,32 @@ public static IHostBuilder CreateHostBuilder(string[] args) =>
 
                             if (selectService == "discord" || selectService == "any")
                             {
-                                cfg.ReceiveEndpoint("notify-video", e => {
+                                cfg.ReceiveEndpoint("notify-video-discord", e => {
                                     e.Consumer<NotifyVideoConsumer>();
                                 });
-                                cfg.ReceiveEndpoint("notify-book", e => {
+                                cfg.ReceiveEndpoint("notify-book-discord", e => {
                                     e.Consumer<NotifyBookConsumer>();
                                 });
-                                cfg.ReceiveEndpoint("notify-request-video", e => {
+                                cfg.ReceiveEndpoint("notify-request-video-discord", e => {
                                     e.Consumer<NotifyRequestVideoConsumer>();
                                 });
-                                cfg.ReceiveEndpoint("notify-request-book", e => {
+                                cfg.ReceiveEndpoint("notify-request-book-discord", e => {
                                     e.Consumer<NotifyRequestBookConsumer>();
                                 });
                             }
 
                             if(selectService == "telegram" || selectService == "any")
                             {
-                                cfg.ReceiveEndpoint("notify-video", e => {
+                                cfg.ReceiveEndpoint("notify-video-telegram", e => {
                                     e.Consumer<NotifyVideoTelegramConsumer>();
                                 });
-                                cfg.ReceiveEndpoint("notify-book", e => {
+                                cfg.ReceiveEndpoint("notify-book-telegram", e => {
                                     e.Consumer<NotifyBookTelegramConsumer>();
                                 });
-                                cfg.ReceiveEndpoint("notify-request-video", e => {
+                                cfg.ReceiveEndpoint("notify-request-video-telegram", e => {
                                     e.Consumer<NotifyRequestVideoTelegramConsumer>();
                                 });
-                                cfg.ReceiveEndpoint("notify-request-book", e => {
+                                cfg.ReceiveEndpoint("notify-request-book-telegram", e => {
                                     e.Consumer<NotifyRequestBookTelegramConsumer>();
                                 });
                             }