Browse Source

fix: change package name

pull/104/head
Vishal Dubey 3 years ago
parent
commit
43242b0592
14 changed files with 19 additions and 19 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/consumer/main.go
  7. +1
    -1
      examples/logger/main.go
  8. +1
    -1
      examples/multiconsumer/main.go
  9. +1
    -1
      examples/multipublisher/main.go
  10. +1
    -1
      examples/publisher/main.go
  11. +3
    -3
      internal/channelmanager/channel_manager.go
  12. +2
    -2
      internal/connectionmanager/connection_manager.go
  13. +1
    -1
      logger.go
  14. +2
    -2
      publish.go

+ 2
- 2
README.md View File

@ -4,7 +4,7 @@ Wrapper of [rabbitmq/amqp091-go](https://github.com/rabbitmq/amqp091-go) that pr
Supported by [Boot.dev](https://boot.dev)
[![](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/rudrasecure/go-rabbitmq?status.svg)](https://godoc.org/github.com/rudrasecure/go-rabbitmq)![Deploy](https://github.com/rudrasecure/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/rudrasecure/go-rabbitmq
```
## 🚀 Quick Start Consumer


+ 1
- 1
connection.go View File

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


+ 1
- 1
consume.go View File

@ -6,7 +6,7 @@ import (
"sync"
amqp "github.com/rabbitmq/amqp091-go"
"github.com/wagslane/go-rabbitmq/internal/channelmanager"
"github.com/rudrasecure/go-rabbitmq/internal/channelmanager"
)
// Action is an action that occurs after processed this delivery


+ 1
- 1
consumer_options.go View File

@ -2,7 +2,7 @@ package rabbitmq
import (
amqp "github.com/rabbitmq/amqp091-go"
"github.com/wagslane/go-rabbitmq/internal/logger"
"github.com/rudrasecure/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/rudrasecure/go-rabbitmq/internal/channelmanager"
)
func declareQueue(chanManager *channelmanager.ChannelManager, options QueueOptions) error {


+ 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/rudrasecure/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/rudrasecure/go-rabbitmq"
)
// errorLogger is used in WithPublisherOptionsLogger to create a custom logger


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

@ -7,7 +7,7 @@ import (
"os/signal"
"syscall"
rabbitmq "github.com/wagslane/go-rabbitmq"
rabbitmq "github.com/rudrasecure/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/rudrasecure/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/rudrasecure/go-rabbitmq"
)
func main() {


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

@ -6,9 +6,9 @@ import (
"time"
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"
"github.com/rudrasecure/go-rabbitmq/internal/connectionmanager"
"github.com/rudrasecure/go-rabbitmq/internal/dispatcher"
"github.com/rudrasecure/go-rabbitmq/internal/logger"
)
// ChannelManager -


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

@ -5,8 +5,8 @@ import (
"time"
amqp "github.com/rabbitmq/amqp091-go"
"github.com/wagslane/go-rabbitmq/internal/dispatcher"
"github.com/wagslane/go-rabbitmq/internal/logger"
"github.com/rudrasecure/go-rabbitmq/internal/dispatcher"
"github.com/rudrasecure/go-rabbitmq/internal/logger"
)
// ConnectionManager -


+ 1
- 1
logger.go View File

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


+ 2
- 2
publish.go View File

@ -7,8 +7,8 @@ import (
"sync"
amqp "github.com/rabbitmq/amqp091-go"
"github.com/wagslane/go-rabbitmq/internal/channelmanager"
"github.com/wagslane/go-rabbitmq/internal/connectionmanager"
"github.com/rudrasecure/go-rabbitmq/internal/channelmanager"
"github.com/rudrasecure/go-rabbitmq/internal/connectionmanager"
)
// DeliveryMode. Transient means higher throughput but messages will not be


Loading…
Cancel
Save