From 7c311b3386fbf218d4ea7560d884855c9dcbbb6a Mon Sep 17 00:00:00 2001 From: Daniel Pupius Date: Mon, 21 Apr 2025 09:18:16 -0700 Subject: [PATCH] Remove unnecessary Close() overrides from subscribers --- mqtt/logger.go | 5 ----- mqtt/stats.go | 5 ----- 2 files changed, 10 deletions(-) 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