Browse Source

chnaged repo name

pull/187/head^2
Фиалковский Максим Сергеевич 1 year ago
parent
commit
2efa0b3293
17 changed files with 22 additions and 22 deletions
  1. +2
    -2
      README.md
  2. +1
    -1
      connection.go
  3. +1
    -1
      consume.go
  4. +1
    -1
      consumer_options.go
  5. +1
    -1
      declare.go
  6. +1
    -1
      examples/cluster/main.go
  7. +1
    -1
      examples/consumer/main.go
  8. +1
    -1
      examples/logger/main.go
  9. +1
    -1
      examples/multiconsumer/main.go
  10. +1
    -1
      examples/multipublisher/main.go
  11. +1
    -1
      examples/publisher/main.go
  12. +1
    -1
      examples/publisher_confirm/main.go
  13. +1
    -1
      go.mod
  14. +3
    -3
      internal/channelmanager/channel_manager.go
  15. +2
    -2
      internal/connectionmanager/connection_manager.go
  16. +1
    -1
      logger.go
  17. +2
    -2
      publish.go

+ 2
- 2
README.md View File

@ -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


+ 1
- 1
connection.go View File

@ -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


+ 1
- 1
consume.go View File

@ -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


+ 1
- 1
consumer_options.go View File

@ -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


+ 1
- 1
declare.go View File

@ -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 {


+ 1
- 1
examples/cluster/main.go View File

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


+ 1
- 1
examples/consumer/main.go View File

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


+ 1
- 1
examples/logger/main.go View File

@ -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


+ 1
- 1
examples/multiconsumer/main.go View File

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


+ 1
- 1
examples/multipublisher/main.go View File

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


+ 1
- 1
examples/publisher/main.go View File

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


+ 1
- 1
examples/publisher_confirm/main.go View File

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


+ 1
- 1
go.mod View File

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


+ 3
- 3
internal/channelmanager/channel_manager.go View File

@ -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 -


+ 2
- 2
internal/connectionmanager/connection_manager.go View File

@ -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 -


+ 1
- 1
logger.go View File

@ -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


+ 2
- 2
publish.go View File

@ -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


Loading…
Cancel
Save