diff --git a/system/service/event/queue.go b/system/service/event/queue.go index d09070b3a..0da308535 100644 --- a/system/service/event/queue.go +++ b/system/service/event/queue.go @@ -14,7 +14,7 @@ func (res queueBase) Match(c eventbus.ConstraintMatcher) bool { func queueMatch(r *types.QueueMessage, c eventbus.ConstraintMatcher) bool { switch c.Name() { - case "message.queue": + case "payload.queue": return c.Match(r.Queue) }