Added default queueID for AWS AMQP

This commit is contained in:
Trial97
2019-01-24 11:58:27 +02:00
committed by Dan Christian Bogos
parent 86570e199a
commit 3cb85f2fb6

View File

@@ -411,7 +411,7 @@ func (pstr *AWSPoster) parseURL(dialURL string) error {
}
qry := u.Query()
pstr.dialURL = strings.Split(dialURL, "?")[0]
pstr.queueID = defaultQueueID
pstr.queueID = "/" + defaultQueueID
if vals, has := qry[queueID]; has && len(vals) != 0 {
pstr.queueID = "/" + vals[0]
}