diff --git a/v1/amqp/amqp.go b/v1/amqp/amqp.go index bec55f7..8687364 100644 --- a/v1/amqp/amqp.go +++ b/v1/amqp/amqp.go @@ -31,7 +31,7 @@ import ( var ( instance *AMQP retryTimeout = 500 * time.Millisecond - cancelTimeout = 30 * time.Second + cancelTimeout = 300 * time.Second ) // AMQP exposes amqp api methods