реконнект каждые 5 секунд

README.md

@@ -24,7 +24,7 @@ The goal with `go-rabbitmq` is to still provide most all of the nitty-gritty fun
 Inside a Go module:
 
 ```bash
-go get github.com/wagslane/go-rabbitmq
+go get github.com/fortyanov/go-rabbitmq
 ```
 
 ## 🚀 Quick Start Consumer

channel.go

@@ -76,11 +76,9 @@ func (chManager *channelManager) startNotifyCancelOrClosed() {
 // reconnectWithBackoff continuously attempts to reconnect with an
 // exponential backoff strategy
 func (chManager *channelManager) reconnectWithBackoff() {
-	backoffTime := time.Second
 	for {
-		chManager.logger.Printf("waiting %s seconds to attempt to reconnect to amqp server", backoffTime)
-		time.Sleep(backoffTime)
-		backoffTime *= 2
+		chManager.logger.Printf("waiting 5 seconds to attempt to reconnect to amqp server")
+		time.Sleep(5 * time.Second)
 		err := chManager.reconnect()
 		if err != nil {
 			chManager.logger.Printf("error reconnecting to amqp server: %v", err)

consume.go

@@ -153,11 +153,9 @@ func (consumer Consumer) startGoroutinesWithRetries(
 	routingKeys []string,
 	consumeOptions ConsumeOptions,
 ) {
-	backoffTime := time.Second
 	for {
-		consumer.logger.Printf("waiting %s seconds to attempt to start consumer goroutines", backoffTime)
-		time.Sleep(backoffTime)
-		backoffTime *= 2
+		consumer.logger.Printf("waiting 5 seconds to attempt to start consumer goroutines")
+		time.Sleep(5 * time.Second)
 		err := consumer.startGoroutines(
 			handler,
 			queue,

examples/consumer/main.go

@@ -7,8 +7,8 @@ import (
 	"os/signal"
 	"syscall"
 
+	rabbitmq "github.com/fortyanov/go-rabbitmq"
 	amqp "github.com/rabbitmq/amqp091-go"
-	rabbitmq "github.com/wagslane/go-rabbitmq"
 )
 
 var consumerName = "example"

examples/logger/main.go

@@ -3,8 +3,8 @@ package main
 import (
 	"log"
 
+	rabbitmq "github.com/fortyanov/go-rabbitmq"
 	amqp "github.com/rabbitmq/amqp091-go"
-	rabbitmq "github.com/wagslane/go-rabbitmq"
 )
 
 // customLogger is used in WithPublisherOptionsLogger to create a custom logger.

examples/publisher/main.go

@@ -8,8 +8,8 @@ import (
 	"syscall"
 	"time"
 
+	rabbitmq "github.com/fortyanov/go-rabbitmq"
 	amqp "github.com/rabbitmq/amqp091-go"
-	rabbitmq "github.com/wagslane/go-rabbitmq"
 )
 
 func main() {