OrgGo/eventials.goevents
1
0
Fork 0
mirror of https://github.com/eventials/goevents.git synced 2025-04-24 13:48:53 +08:00
Code Issues Projects Releases Wiki Activity

(debug): Add debug information for priority check

Browse Source 
- Added a debug log statement in the checkPriorityMessages function
- The debug log outputs when a higher priority consumer has messages in queue, skipping the current consumer
This commit is contained in:
Eddy Santos 2023-06-05 13:59:55 -03:00
parent f1b607259f
commit 3ea7599c2c
1 changed files with 1 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
sns/consumer.go
View File

@ -454,6 +454,7 @@ func checkPriorityMessages(consumers []*consumer, currentConsumer *consumer) boo
// If any higher priority consumer has messages to consume, then the currentConsumer should not consume.
if len(consumer.qos) > 0 {
logrus.Debugf("Higher priority consumer %s has messages to consume, skipping current consumer %s", consumer.config.QueueUrl, currentConsumer.config.QueueUrl)
return false
}
}