fix(bus): fallback on decoding uri (#91)

closes #90
NeuraLegion · Sep 11, 2020 · e9ab6e0 · e9ab6e0
1 parent 14acd7b
commit e9ab6e0
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 1 deletion.
diff --git a/src/Bus/Brokers/RabbitMQBus.ts b/src/Bus/Brokers/RabbitMQBus.ts
@@ -271,6 +271,9 @@ export class RabbitMQBus implements Bus {
   private async createConsumerChannel(): Promise<void> {
     if (!this.channel) {
       this.channel = await this.client.createConfirmChannel();
+      this.channel.on('error', (reason: Error) =>
+        logger.error('Unexpected error: %s', reason)
+      );
       await this.bindExchangesToQueue(this.channel);
       await this.startBasicConsume(this.channel);
     }

diff --git a/src/Utils/Helpers.ts b/src/Utils/Helpers.ts
@@ -52,7 +52,7 @@ export class Helpers {
     try {
       decodedStr = decodeURI(str);
     } catch {
-      throw new Error(`Malformed URI sequence: ${str}`);
+      decodedStr = str;
     }
 
     return encodeURI(decodedStr).replace(/%5B/g, '[').replace(/%5D/g, ']');