From 1f95151da09602ee1737506bc0b5d012e6534a1e Mon Sep 17 00:00:00 2001 From: postmannen Date: Wed, 21 Jun 2023 12:08:17 +0200 Subject: [PATCH] removed debug printing from ringbuffer --- ringbuffer.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/ringbuffer.go b/ringbuffer.go index a9a6a77..e5c59ee 100644 --- a/ringbuffer.go +++ b/ringbuffer.go @@ -321,7 +321,7 @@ func (r *ringBuffer) processBufferMessages(ctx context.Context, ringBufferOutCh if r.configuration.RingBufferPersistStore { select { case <-v.SAM.done: - fmt.Printf("---\n DONE with\n---\n") + // fmt.Printf("---\n DONE with\n---\n") case <-ticker.C: log.Printf("----------------------------------------------\n") log.Printf("Error: ringBuffer message id: %v, subject: %v seems to be stuck, did not receive done signal from publishAMessage process, exited on ticker\n", v.SAM.ID, v.SAM.Subject)