Use immediate queues in integration tests and ensure that immediate (#16927)

queue type is also used for unique queues.

Signed-off-by: Andrew Thornton <art27@cantab.net>
This commit is contained in:
zeripath authored and GitHub committed 2021-09-03 11:20:57 +01:00
1 parent 219dec030d
commit 6c125e9797
6 files changed
+16 -1

No files matched your search

+1 -1
View File
@@ -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
}