From 3f0efa5908cedcc6c23ac37184b3d9f01d529a1a Mon Sep 17 00:00:00 2001
From: Adam Fowler <adamfowler71@gmail.com>
Date: Tue, 14 Dec 2021 21:04:22 +0000
Subject: [PATCH] Remember to pass active/inactive onto next channel

---
 Sources/MQTTNIO/ChannelHandlers/MQTTMessageHandler.swift | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/Sources/MQTTNIO/ChannelHandlers/MQTTMessageHandler.swift b/Sources/MQTTNIO/ChannelHandlers/MQTTMessageHandler.swift
index d06d9251..efb2c9a9 100644
--- a/Sources/MQTTNIO/ChannelHandlers/MQTTMessageHandler.swift
+++ b/Sources/MQTTNIO/ChannelHandlers/MQTTMessageHandler.swift
@@ -42,10 +42,12 @@ class MQTTMessageHandler: ChannelDuplexHandler {
 
     func channelActive(context: ChannelHandlerContext) {
         self.pingreqHandler?.start(context: context)
+        context.fireChannelActive()
     }
 
     func channelInactive(context: ChannelHandlerContext) {
         self.pingreqHandler?.stop()
+        context.fireChannelInactive()
     }
 
     func write(context: ChannelHandlerContext, data: NIOAny, promise: EventLoopPromise<Void>?) {