mirrors/ctrl
mirrors/ctrl
1
0
Fork 0
mirror of https://github.com/postmannen/ctrl.git synced 2024-12-14 12:37:31 +00:00
Code Activity

printing ID working ringbuffer

Browse source
This commit is contained in:
postmannen 2023-01-01 20:31:54 +01:00
parent 6f525162ea
commit d58095764b
1 changed files with 1 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
ringbuffer.go
View file

@ -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)