From 2207bc1b7ef0143e3cfeb11b9b76411d6572e841 Mon Sep 17 00:00:00 2001
From: David Justice <david@devigned.com>
Date: Fri, 19 Jul 2019 11:05:54 -0700
Subject: [PATCH] update to common 2.1

---
 go.mod           | 2 +-
 go.sum           | 6 ++----
 iterator_test.go | 3 ++-
 3 files changed, 5 insertions(+), 6 deletions(-)

diff --git a/go.mod b/go.mod
index 8e41a66..02283d4 100644
--- a/go.mod
+++ b/go.mod
@@ -3,7 +3,7 @@ module github.com/Azure/azure-service-bus-go
 go 1.12
 
 require (
-	github.com/Azure/azure-amqp-common-go/v2 v2.0.1-0.20190619212702-9727f6e7bc50
+	github.com/Azure/azure-amqp-common-go/v2 v2.1.0
 	github.com/Azure/azure-sdk-for-go v30.1.0+incompatible
 	github.com/Azure/go-autorest v12.0.0+incompatible
 	github.com/devigned/tab v0.1.1
diff --git a/go.sum b/go.sum
index 0f4a119..64bba5f 100644
--- a/go.sum
+++ b/go.sum
@@ -3,8 +3,8 @@ cloud.google.com/go v0.34.0/go.mod h1:aQUYkXzVsufM+DwF1aE+0xfcU+56JwCaLick0ClmMT
 cloud.google.com/go v0.38.0/go.mod h1:990N+gfupTy94rShfmMCWGDn0LpTmnzTp2qbd1dvSRU=
 contrib.go.opencensus.io/exporter/ocagent v0.5.0 h1:TKXjQSRS0/cCDrP7KvkgU6SmILtF/yV2TOs/02K/WZQ=
 contrib.go.opencensus.io/exporter/ocagent v0.5.0/go.mod h1:ImxhfLRpxoYiSq891pBrLVhN+qmP8BTVvdH2YLs7Gl0=
-github.com/Azure/azure-amqp-common-go/v2 v2.0.1-0.20190619212702-9727f6e7bc50 h1:KPO7ZDYTiAMfLuK1r9vS98LrfPCE0t83sKJjy27Csdc=
-github.com/Azure/azure-amqp-common-go/v2 v2.0.1-0.20190619212702-9727f6e7bc50/go.mod h1:dCWWW6Z0g9RTKMYUP03nMUHdqm71VFt323bTNYML0Mc=
+github.com/Azure/azure-amqp-common-go/v2 v2.1.0 h1:+QbFgmWCnPzdaRMfsI0Yb6GrRdBj5jVL8N3EXuEUcBQ=
+github.com/Azure/azure-amqp-common-go/v2 v2.1.0/go.mod h1:R8rea+gJRuJR6QxTir/XuEd+YuKoUiazDC/N96FiDEU=
 github.com/Azure/azure-sdk-for-go v29.0.0+incompatible h1:CYPU39ULbGjQBo3gXIqiWouK0C4F+Pt2Zx5CqGvqknE=
 github.com/Azure/azure-sdk-for-go v29.0.0+incompatible/go.mod h1:9XXNKU+eRnpl9moKnB4QOLf1HestfXbmab5FXxiDBjc=
 github.com/Azure/azure-sdk-for-go v30.1.0+incompatible h1:HyYPft8wXpxMd0kfLtXo6etWcO+XuPbLkcgx9g2cqxU=
@@ -150,7 +150,5 @@ gopkg.in/yaml.v2 v2.0.0-20170812160011-eb3733d160e7/go.mod h1:JAlM8MvJe8wmxCU4Bl
 honnef.co/go/tools v0.0.0-20190102054323-c2f93a96b099/go.mod h1:rf3lG4BRIbNafJWhAfAdb/ePZxsR/4RtNHQocxwk9r4=
 honnef.co/go/tools v0.0.0-20190106161140-3f1c8253044a/go.mod h1:rf3lG4BRIbNafJWhAfAdb/ePZxsR/4RtNHQocxwk9r4=
 honnef.co/go/tools v0.0.0-20190418001031-e561f6794a2a/go.mod h1:rf3lG4BRIbNafJWhAfAdb/ePZxsR/4RtNHQocxwk9r4=
-pack.ag/amqp v0.11.1 h1:Hbj15aWwso+sgqKY7nJTYEeaUV8gx3+u1RUSZxeW0vA=
-pack.ag/amqp v0.11.1/go.mod h1:4/cbmt4EJXSKlG6LCfWHoqmN0uFdy5i/+YFz+fTfhV4=
 pack.ag/amqp v0.11.2 h1:cuNDWLUTbKRtEZwhB0WQBXf9pGbm87pUBXQhvcFxBWg=
 pack.ag/amqp v0.11.2/go.mod h1:4/cbmt4EJXSKlG6LCfWHoqmN0uFdy5i/+YFz+fTfhV4=
diff --git a/iterator_test.go b/iterator_test.go
index 9b462b3..10cbe07 100644
--- a/iterator_test.go
+++ b/iterator_test.go
@@ -41,7 +41,7 @@ func (suite *serviceBusSuite) TestMessageIterator() {
 
 			q, err := ns.NewQueue(queueName)
 			defer func() {
-				q.Close(context.Background())
+				_ = q.Close(context.Background())
 			}()
 			suite.NoError(err)
 
@@ -197,6 +197,7 @@ func testMessageIteratorLargePageSize(ctx context.Context, t *testing.T, queue *
 	}
 
 	require.NoError(t, queue.Send(ctx, NewMessageFromString(newPayload(pageSize+1))))
+	time.Sleep(1 * time.Second)
 
 	got := uint32(0)
 	for {