diff options
author | Tomofumi Hayashi <tohayash@redhat.com> | 2019-04-27 20:38:39 +0900 |
---|---|---|
committer | Tomofumi Hayashi <tohayash@redhat.com> | 2019-04-27 20:40:37 +0900 |
commit | 4d11ca17d0f73f5bd783f45900118295fdfed46b (patch) | |
tree | cce8575b02ac850d2b30ec12a5c4083c48e85c6c /src/dma/vendor/github.com/streadway/amqp/channel.go | |
parent | 07e4a96e4996f3d39b92dd601b3ed0d23bfbaa0c (diff) |
barometer: update DMA's vendoring packages
Change-Id: I0578b094f1ecdaed20c906be2ba29d51b8089d7c
Signed-off-by: Tomofumi Hayashi <tohayash@redhat.com>
Diffstat (limited to 'src/dma/vendor/github.com/streadway/amqp/channel.go')
-rw-r--r-- | src/dma/vendor/github.com/streadway/amqp/channel.go | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/src/dma/vendor/github.com/streadway/amqp/channel.go b/src/dma/vendor/github.com/streadway/amqp/channel.go index dd2552ca..3898ed78 100644 --- a/src/dma/vendor/github.com/streadway/amqp/channel.go +++ b/src/dma/vendor/github.com/streadway/amqp/channel.go @@ -889,7 +889,7 @@ and exchanges will also be restored on server restart. If the binding could not complete, an error will be returned and the channel will be closed. -When noWait is true and the queue could not be bound, the channel will be +When noWait is false and the queue could not be bound, the channel will be closed with an error. */ @@ -1580,6 +1580,9 @@ multiple messages, reducing the amount of protocol messages to exchange. See also Delivery.Reject */ func (ch *Channel) Reject(tag uint64, requeue bool) error { + ch.m.Lock() + defer ch.m.Unlock() + return ch.send(&basicReject{ DeliveryTag: tag, Requeue: requeue, |