From 3cb85f2fb6d9d623a82f20a48ce394f3482eca46 Mon Sep 17 00:00:00 2001
From: Trial97 <alexandru.tripon@itsyscom.com>
Date: Thu, 24 Jan 2019 11:58:27 +0200
Subject: [PATCH] Added default queueID for AWS AMQP

---
 engine/poster.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/engine/poster.go b/engine/poster.go
index 77224e0d6..4d751afed 100644
--- a/engine/poster.go
+++ b/engine/poster.go
@@ -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]
 	}