Just bail out, on rabbitmq error

Author: skadefro

OpenFlow/src/QueueClient.ts

@@ -108,8 +108,9 @@ export class QueueClient {
             } catch (error) {
                 if (NoderedUtil.IsNullUndefinded(this.queue)) {
                     Logger.instanse.warn("SendForProcessing queue is null, shutdown amqp connection");
-                    amqpwrapper.Instance().shutdown();
-                    amqpwrapper.Instance().connect(null);
+                    process.exit(406);
+                    // amqpwrapper.Instance().shutdown();
+                    // amqpwrapper.Instance().connect(null);
                 } else {
                     Logger.instanse.error(error);
                 }

OpenFlow/src/amqpwrapper.ts

@@ -256,17 +256,19 @@ export class amqpwrapper extends events.EventEmitter {
                 }
             })
             this.channel.on('close', async () => {
-                this.connected = false;
-                try {
-                    if (this.conn != null) await this.conn.close();
-                } catch (error) {
-                }
-                this.channel = null;
-                if (this.timeout != null) {
-                    clearTimeout(this.timeout);
-                    this.timeout = null;
-                }
-                this.timeout = setTimeout(this.connect.bind(this), 1000);
+                Logger.instanse.error("Exit, when we cannot create dead letter exchange and/or Openflow exchange");
+                process.exit(406);
+                // this.connected = false;
+                // try {
+                //     if (this.conn != null) await this.conn.close();
+                // } catch (error) {
+                // }
+                // this.channel = null;
+                // if (this.timeout != null) {
+                //     clearTimeout(this.timeout);
+                //     this.timeout = null;
+                // }
+                // this.timeout = setTimeout(this.connect.bind(this), 1000);
             });
         } catch (error) {
             span?.recordException(error);