fix set channel in Confirm mode not immediately after creating

README.md

@@ -4,7 +4,7 @@ A wrapper of [rabbitmq/amqp091-go](https://github.com/rabbitmq/amqp091-go) that
 
 Supported by [Boot.dev](https://boot.dev). If you'd like to learn about RabbitMQ and Go, you can check out [my course here](https://www.boot.dev/learn/learn-pub-sub).
 
-[![](https://godoc.org/github.com/wagslane/go-rabbitmq?status.svg)](https://godoc.org/github.com/wagslane/go-rabbitmq)![Deploy](https://github.com/wagslane/go-rabbitmq/workflows/Tests/badge.svg)
+[![](https://godoc.org/github.com/makometr/go-rabbitmq?status.svg)](https://godoc.org/github.com/makometr/go-rabbitmq)![Deploy](https://github.com/makometr/go-rabbitmq/workflows/Tests/badge.svg)
 
 ## Motivation
 
@@ -25,7 +25,7 @@ The goal with `go-rabbitmq` is to provide *most* (but not all) of the nitty-grit
 Inside a Go module:
 
 ```bash
-go get github.com/wagslane/go-rabbitmq
+go get github.com/makometr/go-rabbitmq
 ```
 
 ## 🚀 Quick Start Consumer

connection.go

@@ -5,7 +5,7 @@ import (
 
 	amqp "github.com/rabbitmq/amqp091-go"
 
-	"github.com/wagslane/go-rabbitmq/internal/connectionmanager"
+	"github.com/makometr/go-rabbitmq/internal/connectionmanager"
 )
 
 // Conn manages the connection to a rabbit cluster

consume.go

@@ -6,8 +6,8 @@ import (
 	"fmt"
 	"sync"
 
+	"github.com/makometr/go-rabbitmq/internal/channelmanager"
 	amqp "github.com/rabbitmq/amqp091-go"
-	"github.com/wagslane/go-rabbitmq/internal/channelmanager"
 )
 
 // Action is an action that occurs after processed this delivery
@@ -62,7 +62,7 @@ func NewConsumer(
 		return nil, errors.New("connection manager can't be nil")
 	}
 
-	chanManager, err := channelmanager.NewChannelManager(conn.connectionManager, options.Logger, conn.connectionManager.ReconnectInterval)
+	chanManager, err := channelmanager.NewChannelManager(conn.connectionManager, false, options.Logger, conn.connectionManager.ReconnectInterval)
 	if err != nil {
 		return nil, err
 	}

consumer_options.go

@@ -1,8 +1,8 @@
 package rabbitmq
 
 import (
+	"github.com/makometr/go-rabbitmq/internal/logger"
 	amqp "github.com/rabbitmq/amqp091-go"
-	"github.com/wagslane/go-rabbitmq/internal/logger"
 )
 
 // getDefaultConsumerOptions describes the options that will be used when a value isn't provided

declare.go

@@ -1,7 +1,7 @@
 package rabbitmq
 
 import (
-	"github.com/wagslane/go-rabbitmq/internal/channelmanager"
+	"github.com/makometr/go-rabbitmq/internal/channelmanager"
 )
 
 func declareQueue(chanManager *channelmanager.ChannelManager, options QueueOptions) error {

examples/cluster/main.go

@@ -3,7 +3,7 @@ package main
 import (
 	"log"
 
-	rabbitmq "github.com/wagslane/go-rabbitmq"
+	rabbitmq "github.com/makometr/go-rabbitmq"
 )
 
 func main() {

examples/consumer/main.go

@@ -7,7 +7,7 @@ import (
 	"os/signal"
 	"syscall"
 
-	rabbitmq "github.com/wagslane/go-rabbitmq"
+	rabbitmq "github.com/makometr/go-rabbitmq"
 )
 
 func main() {

examples/logger/main.go

@@ -4,7 +4,7 @@ import (
 	"context"
 	"log"
 
-	rabbitmq "github.com/wagslane/go-rabbitmq"
+	rabbitmq "github.com/makometr/go-rabbitmq"
 )
 
 // errorLogger is used in WithPublisherOptionsLogger to create a custom logger

examples/multiconsumer/main.go

@@ -8,7 +8,7 @@ import (
 	"sync"
 	"syscall"
 
-	rabbitmq "github.com/wagslane/go-rabbitmq"
+	rabbitmq "github.com/makometr/go-rabbitmq"
 )
 
 func main() {

examples/multipublisher/main.go

@@ -9,7 +9,7 @@ import (
 	"syscall"
 	"time"
 
-	rabbitmq "github.com/wagslane/go-rabbitmq"
+	rabbitmq "github.com/makometr/go-rabbitmq"
 )
 
 func main() {

examples/publisher/main.go

@@ -9,7 +9,7 @@ import (
 	"syscall"
 	"time"
 
-	rabbitmq "github.com/wagslane/go-rabbitmq"
+	rabbitmq "github.com/makometr/go-rabbitmq"
 )
 
 func main() {

examples/publisher_confirm/main.go

@@ -9,7 +9,7 @@ import (
 	"syscall"
 	"time"
 
-	rabbitmq "github.com/wagslane/go-rabbitmq"
+	rabbitmq "github.com/makometr/go-rabbitmq"
 )
 
 func main() {

go.mod

@@ -1,4 +1,4 @@
-module github.com/wagslane/go-rabbitmq
+module github.com/makometr/go-rabbitmq
 
 go 1.22.6
 

internal/channelmanager/channel_manager.go

@@ -5,10 +5,10 @@ import (
 	"sync"
 	"time"
 
+	"github.com/makometr/go-rabbitmq/internal/connectionmanager"
+	"github.com/makometr/go-rabbitmq/internal/dispatcher"
+	"github.com/makometr/go-rabbitmq/internal/logger"
 	amqp "github.com/rabbitmq/amqp091-go"
-	"github.com/wagslane/go-rabbitmq/internal/connectionmanager"
-	"github.com/wagslane/go-rabbitmq/internal/dispatcher"
-	"github.com/wagslane/go-rabbitmq/internal/logger"
 )
 
 // ChannelManager -
@@ -21,10 +21,11 @@ type ChannelManager struct {
 	reconnectionCount   uint
 	reconnectionCountMu *sync.Mutex
 	dispatcher          *dispatcher.Dispatcher
+	inConfirmMode       bool
 }
 
 // NewChannelManager creates a new connection manager
-func NewChannelManager(connManager *connectionmanager.ConnectionManager, log logger.Logger, reconnectInterval time.Duration) (*ChannelManager, error) {
+func NewChannelManager(connManager *connectionmanager.ConnectionManager, confirmMode bool, log logger.Logger, reconnectInterval time.Duration) (*ChannelManager, error) {
 	ch, err := getNewChannel(connManager)
 	if err != nil {
 		return nil, err
@@ -39,6 +40,7 @@ func NewChannelManager(connManager *connectionmanager.ConnectionManager, log log
 		reconnectionCount:   0,
 		reconnectionCountMu: &sync.Mutex{},
 		dispatcher:          dispatcher.NewDispatcher(),
+		inConfirmMode:       confirmMode,
 	}
 	go chanManager.startNotifyCancelOrClosed()
 	return &chanManager, nil
@@ -119,6 +121,12 @@ func (chanManager *ChannelManager) reconnect() error {
 	if err != nil {
 		return err
 	}
+	// chaneel creating and setting confirm mode should be in the same mutex Lock interval
+	if chanManager.inConfirmMode {
+		if err = newChannel.Confirm(false); err != nil {
+			return err
+		}
+	}
 
 	if err = chanManager.channel.Close(); err != nil {
 		chanManager.logger.Warnf("error closing channel while reconnecting: %v", err)

internal/connectionmanager/connection_manager.go

@@ -6,9 +6,9 @@ import (
 	"sync"
 	"time"
 
+	"github.com/makometr/go-rabbitmq/internal/dispatcher"
+	"github.com/makometr/go-rabbitmq/internal/logger"
 	amqp "github.com/rabbitmq/amqp091-go"
-	"github.com/wagslane/go-rabbitmq/internal/dispatcher"
-	"github.com/wagslane/go-rabbitmq/internal/logger"
 )
 
 // ConnectionManager -

logger.go

@@ -5,7 +5,7 @@ import (
 	"log"
 	"os"
 
-	"github.com/wagslane/go-rabbitmq/internal/logger"
+	"github.com/makometr/go-rabbitmq/internal/logger"
 )
 
 // Logger is describes a logging structure. It can be set using

publish.go

@@ -6,9 +6,9 @@ import (
 	"fmt"
 	"sync"
 
+	"github.com/makometr/go-rabbitmq/internal/channelmanager"
+	"github.com/makometr/go-rabbitmq/internal/connectionmanager"
 	amqp "github.com/rabbitmq/amqp091-go"
-	"github.com/wagslane/go-rabbitmq/internal/channelmanager"
-	"github.com/wagslane/go-rabbitmq/internal/connectionmanager"
 )
 
 // DeliveryMode. Transient means higher throughput but messages will not be
@@ -78,7 +78,7 @@ func NewPublisher(conn *Conn, optionFuncs ...func(*PublisherOptions)) (*Publishe
 		return nil, errors.New("connection manager can't be nil")
 	}
 
-	chanManager, err := channelmanager.NewChannelManager(conn.connectionManager, options.Logger, conn.connectionManager.ReconnectInterval)
+	chanManager, err := channelmanager.NewChannelManager(conn.connectionManager, options.ConfirmMode, options.Logger, conn.connectionManager.ReconnectInterval)
 	if err != nil {
 		return nil, err
 	}
@@ -272,6 +272,7 @@ func (publisher *Publisher) PublishWithDeferredConfirmWithContext(
 		}
 		deferredConfirmations = append(deferredConfirmations, conf)
 	}
+
 	return deferredConfirmations, nil
 }