diff --git a/mqtt/logger.go b/mqtt/logger.go index fd3a85e..209cbc2 100644 --- a/mqtt/logger.go +++ b/mqtt/logger.go @@ -122,8 +122,3 @@ func (ml *MessageLogger) logMessage(packet *Packet) { } } -// Close overrides the BaseSubscriber.Close method -func (ml *MessageLogger) Close() { - // Call the base close method which will handle unsubscribe and closeLogFiles - ml.BaseSubscriber.Close() -} \ No newline at end of file diff --git a/mqtt/stats.go b/mqtt/stats.go index 33c3576..5ce8116 100644 --- a/mqtt/stats.go +++ b/mqtt/stats.go @@ -103,8 +103,3 @@ func (s *MessageStats) PrintStats() { s.LastStatsPrinted = now } -// Close overrides the BaseSubscriber.Close method -func (s *MessageStats) Close() { - // Call the base close method which will handle unsubscribe and stop the ticker - s.BaseSubscriber.Close() -} \ No newline at end of file