lsm/seaweedfs
1
0
Fork 0
mirror of https://github.com/seaweedfs/seaweedfs.git synced 2025-09-22 20:23:39 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

fix: dead letter message log message (#7072)

Browse Source
This commit is contained in:
Ibrahim Konsowa
2025-08-02 19:21:57 +04:00
committed by GitHub
parent 9d013ea9b8
commit 315fcc70b2
1 changed files with 11 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
weed/notification/webhook/webhook_queue.go
View File

@@ -195,7 +195,11 @@ func (w *Queue) logDeadLetterMessages() error {
go func() { go func() {
for { for {
select { select {
case msg := <-ch: case msg, ok := <-ch:
if !ok {
glog.Info("dead letter channel closed")
return
}
if msg == nil { if msg == nil {
glog.Errorf("received nil message from dead letter channel") glog.Errorf("received nil message from dead letter channel")
continue continue
@@ -208,7 +212,12 @@ func (w *Queue) logDeadLetterMessages() error {
} }
payload := "" payload := ""
if msg.Payload != nil { if msg.Payload != nil {
payload = string(msg.Payload) var n filer_pb.EventNotification
if err := proto.Unmarshal(msg.Payload, &n); err != nil {
payload = fmt.Sprintf("failed to unmarshal payload: %v", err)
} else {
payload = n.String()
}
} }
glog.Errorf("received dead letter message: %s, key: %s", payload, key) glog.Errorf("received dead letter message: %s, key: %s", payload, key)
case <-w.ctx.Done(): case <-w.ctx.Done():