diff --git a/src/index.ts b/src/index.ts
index 1ff8a44..773d13a 100644
--- a/src/index.ts
+++ b/src/index.ts
@@ -343,4 +343,12 @@ export class AmqpAdapter extends Adapter {
     serverSideEmit(packet: any[]): void {
         throw new Error('this adapter does not support the serverSideEmit() functionality');
     }
+
+    onPublishChannelErrorCallback = (callback: (err: Error) => void) => {
+        this.publishChannel.on('error', callback);
+    }
+
+    onConsumeChannelErrorCallback = (callback: (err: Error) => void) => {
+        this.consumeChannel.on('error', callback);
+    }
 }