Merge pull request #40 from Kevalin/master

fix / compatible with other amqp libraries
AlariCode · Aug 17, 2021 · fe771bb · fe771bb
2 parents d94fbce + 666f8d1
commit fe771bb
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/lib/rmq.service.ts b/lib/rmq.service.ts
@@ -104,7 +104,7 @@ export class RMQService implements OnModuleInit {
 			}, timeout);
 			this.sendResponseEmitter.once(correlationId, (msg: Message) => {
 				clearTimeout(timerId);
-				if (msg.properties.headers['-x-error']) {
+				if (msg.properties?.headers?.['-x-error']) {
 					reject(this.errorService.errorHandler(msg));
 				}
 				const { content } = msg;