diff --git a/ringbuffer.go b/ringbuffer.go index a2e0251..25508d8 100644 --- a/ringbuffer.go +++ b/ringbuffer.go @@ -326,7 +326,7 @@ func (r *ringBuffer) processBufferMessages(ctx context.Context, outCh chan samDB case <-v.SAM.done: case <-ticker.C: log.Printf("----------------------------------------------\n") - log.Printf("Error: ringBuffer message %v seems to be stuck, did not receive done signal from publishAMessage process, exited on ticker\n", v.SAM.Subject) + 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) log.Printf("----------------------------------------------\n") } // log.Printf("info: processBufferMessages: done with message, deleting key from bucket, %v\n", v.ID)