From 6c125e979713259f41e99ef738a612318c69fbc5 Mon Sep 17 00:00:00 2001 From: zeripath Date: Fri, 3 Sep 2021 11:20:57 +0100 Subject: Use immediate queues in integration tests and ensure that immediate (#16927) queue type is also used for unique queues. Signed-off-by: Andrew Thornton --- modules/queue/setting.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) (limited to 'modules/queue') diff --git a/modules/queue/setting.go b/modules/queue/setting.go index 0e6ff3a0a8..caaf123d42 100644 --- a/modules/queue/setting.go +++ b/modules/queue/setting.go @@ -75,7 +75,7 @@ func CreateUniqueQueue(name string, handle HandlerFunc, exemplar interface{}) Un return nil } - if len(q.Type) > 0 && q.Type != "dummy" && !strings.HasPrefix(q.Type, "unique-") { + if len(q.Type) > 0 && q.Type != "dummy" && q.Type != "immediate" && !strings.HasPrefix(q.Type, "unique-") { q.Type = "unique-" + q.Type } -- cgit v1.2.3