From 465e8ffe69a2c991195f97d181f8e213af91df93 Mon Sep 17 00:00:00 2001 From: Peter Grlica Date: Thu, 20 Jan 2022 15:41:00 +0100 Subject: [PATCH] Fix queue name matching on workflow onMessage event --- system/service/event/queue.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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) }