eee

Author: skadefro

OpenFlow/src/amqpwrapper.ts

@@ -138,18 +138,18 @@ export class amqpwrapper extends events.EventEmitter {
             try {
                 span?.addEvent("AddReplyQueue");
                 await this.AddReplyQueue(span);
+                this.channel.on('error', (error) => {
+                    if (error.code != 404) {
+                        Logger.instanse.error(error);
+                    }
+                });
             } catch (error) {
                 Logger.instanse.error(error);
                 if (Config.NODE_ENV == "production") {
                     Logger.instanse.error("Exit, when we cannot create reply queue");
                     process.exit(405);
                 }
             }
-            this.channel.on('error', (error) => {
-                if (error.code != 404) {
-                    Logger.instanse.error(error);
-                }
-            });
             try {
                 await this.Adddlx(span);
                 await this.AddOFExchange(span);