diff --git a/src/MessageBroker.ts b/src/MessageBroker.ts
index 2f443d4..b8cbb2a 100644
--- a/src/MessageBroker.ts
+++ b/src/MessageBroker.ts
@@ -52,9 +52,9 @@ type InternalQueueMsg = {
 } & InternalMessage
 
 // eslint-disable-next-line @typescript-eslint/no-explicit-any
-type Consumer<T = any> = (content: T, msg: ConsumeMessage) => Promise<void>
+type Consumer<T = any> = (content: T, msg: ConsumeMessage) => Promise<void> | void
 // eslint-disable-next-line @typescript-eslint/no-explicit-any
-type Subscriber<T = any> = (content: T, msg: ConsumeMessage) => Promise<void>
+type Subscriber<T = any> = (content: T, msg: ConsumeMessage) => Promise<void> | void
 
 class MessageBroker 
 {