From 9700004b0a10b33b917b39c7e6d516230caaa66d Mon Sep 17 00:00:00 2001 From: Trial97 Date: Tue, 5 Mar 2019 16:00:39 +0200 Subject: [PATCH] Updated SQSPoster to remove slash from the end of url endpoint --- config/multifiles_it_test.go | 1 - engine/poster.go | 1 + 2 files changed, 1 insertion(+), 1 deletion(-) diff --git a/config/multifiles_it_test.go b/config/multifiles_it_test.go index 37d2b8bb4..2ca995f0a 100644 --- a/config/multifiles_it_test.go +++ b/config/multifiles_it_test.go @@ -116,7 +116,6 @@ func TestMfEnvReaderITRead(t *testing.T) { Reconnects: -1, ConnectTimeout: time.Duration(1 * time.Second), ReplyTimeout: time.Duration(2 * time.Second), - ResponseCacheTTL: time.Duration(0), InternalTtl: time.Duration(2 * time.Minute), LockingTimeout: time.Duration(0), DigestSeparator: ",", diff --git a/engine/poster.go b/engine/poster.go index 6b6675a5f..bcb94efb4 100644 --- a/engine/poster.go +++ b/engine/poster.go @@ -581,6 +581,7 @@ func (pstr *SQSPoster) parseURL(dialURL string) (err error) { qry := u.Query() pstr.dialURL = strings.Split(dialURL, "?")[0] + pstr.dialURL = strings.TrimSuffix(pstr.dialURL, "/") // used to remove / to point to correct endpoint pstr.queueID = defaultQueueID if vals, has := qry[queueID]; has && len(vals) != 0 { pstr.queueID = vals[0]