Fix queue name matching on workflow onMessage event

cortezaproject · Mar 1, 2022 · 465e8ff · 465e8ff
1 parent 96c335e
commit 465e8ff
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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)
 	}