File tree 16 files changed +23
-21
lines changed
16 files changed +23
-21
lines changed Original file line number Diff line number Diff line change 5
5
6
6
amqp "github.com/rabbitmq/amqp091-go"
7
7
8
- "github.com/wagslane /go-rabbitmq/internal/connectionmanager"
8
+ "github.com/xBlaz3kx /go-rabbitmq/internal/connectionmanager"
9
9
)
10
10
11
11
// Conn manages the connection to a rabbit cluster
Original file line number Diff line number Diff line change 7
7
"sync"
8
8
9
9
amqp "github.com/rabbitmq/amqp091-go"
10
- "github.com/wagslane /go-rabbitmq/internal/channelmanager"
10
+ "github.com/xBlaz3kx /go-rabbitmq/internal/channelmanager"
11
11
)
12
12
13
13
// Action is an action that occurs after processed this delivery
Original file line number Diff line number Diff line change @@ -2,7 +2,7 @@ package rabbitmq
2
2
3
3
import (
4
4
amqp "github.com/rabbitmq/amqp091-go"
5
- "github.com/wagslane /go-rabbitmq/internal/logger"
5
+ "github.com/xBlaz3kx /go-rabbitmq/internal/logger"
6
6
)
7
7
8
8
// getDefaultConsumerOptions describes the options that will be used when a value isn't provided
Original file line number Diff line number Diff line change 1
1
package rabbitmq
2
2
3
3
import (
4
- "github.com/wagslane /go-rabbitmq/internal/channelmanager"
4
+ "github.com/xBlaz3kx /go-rabbitmq/internal/channelmanager"
5
5
)
6
6
7
7
func declareQueue (chanManager * channelmanager.ChannelManager , options QueueOptions ) error {
Original file line number Diff line number Diff line change @@ -3,7 +3,7 @@ package main
3
3
import (
4
4
"log"
5
5
6
- rabbitmq "github.com/wagslane /go-rabbitmq"
6
+ "github.com/xBlaz3kx /go-rabbitmq"
7
7
)
8
8
9
9
func main () {
Original file line number Diff line number Diff line change 7
7
"os/signal"
8
8
"syscall"
9
9
10
- rabbitmq "github.com/wagslane /go-rabbitmq"
10
+ rabbitmq "github.com/xBlaz3kx /go-rabbitmq"
11
11
)
12
12
13
13
func main () {
Original file line number Diff line number Diff line change 4
4
"context"
5
5
"log"
6
6
7
- rabbitmq "github.com/wagslane /go-rabbitmq"
7
+ rabbitmq "github.com/xBlaz3kx /go-rabbitmq"
8
8
)
9
9
10
10
// errorLogger is used in WithPublisherOptionsLogger to create a custom logger
Original file line number Diff line number Diff line change 8
8
"sync"
9
9
"syscall"
10
10
11
- rabbitmq "github.com/wagslane /go-rabbitmq"
11
+ rabbitmq "github.com/xBlaz3kx /go-rabbitmq"
12
12
)
13
13
14
14
func main () {
Original file line number Diff line number Diff line change 9
9
"syscall"
10
10
"time"
11
11
12
- rabbitmq "github.com/wagslane /go-rabbitmq"
12
+ rabbitmq "github.com/xBlaz3kx /go-rabbitmq"
13
13
)
14
14
15
15
func main () {
Original file line number Diff line number Diff line change 9
9
"syscall"
10
10
"time"
11
11
12
- rabbitmq "github.com/wagslane /go-rabbitmq"
12
+ rabbitmq "github.com/xBlaz3kx /go-rabbitmq"
13
13
)
14
14
15
15
func main () {
Original file line number Diff line number Diff line change 9
9
"syscall"
10
10
"time"
11
11
12
- rabbitmq "github.com/wagslane /go-rabbitmq"
12
+ rabbitmq "github.com/xBlaz3kx /go-rabbitmq"
13
13
)
14
14
15
15
func main () {
Original file line number Diff line number Diff line change 1
- module github.com/wagslane /go-rabbitmq
1
+ module github.com/xBlaz3kx /go-rabbitmq
2
2
3
3
go 1.22.6
4
4
5
- require github.com/rabbitmq/amqp091-go v1.10.0
5
+ require (
6
+ github.com/rabbitmq/amqp091-go v1.10.0
7
+ )
Original file line number Diff line number Diff line change 6
6
"time"
7
7
8
8
amqp "github.com/rabbitmq/amqp091-go"
9
- "github.com/wagslane /go-rabbitmq/internal/connectionmanager"
10
- "github.com/wagslane /go-rabbitmq/internal/dispatcher"
11
- "github.com/wagslane /go-rabbitmq/internal/logger"
9
+ "github.com/xBlaz3kx /go-rabbitmq/internal/connectionmanager"
10
+ "github.com/xBlaz3kx /go-rabbitmq/internal/dispatcher"
11
+ "github.com/xBlaz3kx /go-rabbitmq/internal/logger"
12
12
)
13
13
14
14
// ChannelManager -
Original file line number Diff line number Diff line change 8
8
"time"
9
9
10
10
amqp "github.com/rabbitmq/amqp091-go"
11
- "github.com/wagslane /go-rabbitmq/internal/dispatcher"
12
- "github.com/wagslane /go-rabbitmq/internal/logger"
11
+ "github.com/xBlaz3kx /go-rabbitmq/internal/dispatcher"
12
+ "github.com/xBlaz3kx /go-rabbitmq/internal/logger"
13
13
)
14
14
15
15
// ConnectionManager -
Original file line number Diff line number Diff line change 5
5
"log"
6
6
"os"
7
7
8
- "github.com/wagslane /go-rabbitmq/internal/logger"
8
+ "github.com/xBlaz3kx /go-rabbitmq/internal/logger"
9
9
)
10
10
11
11
// Logger is describes a logging structure. It can be set using
Original file line number Diff line number Diff line change 7
7
"sync"
8
8
9
9
amqp "github.com/rabbitmq/amqp091-go"
10
- "github.com/wagslane /go-rabbitmq/internal/channelmanager"
11
- "github.com/wagslane /go-rabbitmq/internal/connectionmanager"
10
+ "github.com/xBlaz3kx /go-rabbitmq/internal/channelmanager"
11
+ "github.com/xBlaz3kx /go-rabbitmq/internal/connectionmanager"
12
12
)
13
13
14
14
// DeliveryMode. Transient means higher throughput but messages will not be
You can’t perform that action at this time.
0 commit comments