Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

rabbitmq

package module

Go to main page

Versions in this module

v0

v0.3.1

May 7, 2022

v0.3.0

May 6, 2022

Changes in this version

+ func DefaultLogger() *zap.Logger

type Destination

+ Logger *zap.Logger

+ func (destination *Destination) StartConsumer(receiver OnReceive, ch *rabbitmq.Channel, consumerTag string)

+ func (r *Destination) SetDefaults()

type Settings

+ Logger *zap.Logger

+ func (r *Settings) SetDefaults()

v0.2.0

May 29, 2021

v0.1.1

Feb 8, 2021

Changes in this version

+ type Destination struct

+ AutoAck bool

+ DeclareAll bool

+ ExchangeType string

+ Exclusive bool

+ Prefetch int

+ Queue string

+ Topic string

+ func (mq *Destination) Consume(conn *rabbitmq.Connection, consumerTag string) (<-chan amqp.Delivery, *rabbitmq.Channel, error)

+ func (mq *Destination) DeclareDestination(cnn *rabbitmq.Connection, createTempQueue bool) error

+ func (mq *Destination) Produce(channel *rabbitmq.Channel, message amqp.Publishing) error

+ func (mq *Destination) RPC(ctx context.Context, conn *rabbitmq.Connection, message amqp.Publishing) (*amqp.Delivery, error)

v0.1.0

Feb 5, 2021

v0.0.9

Jan 7, 2021

Changes in this version

+ var SharedConnection = true

v0.0.8

Jan 7, 2021

Changes in this version

type Settings

+ Shared bool

v0.0.7

Jan 7, 2021

Changes in this version

type Settings

+ func (r Settings) Close(v interface{}) error

+ func (r Settings) Factory() (interface{}, error)

+ func (r Settings) Ping(v interface{}) error

v0.0.6

Jan 6, 2021

v0.0.5

Dec 7, 2020

v0.0.4

Dec 4, 2020

Changes in this version

type MqDestination

+ func (mq *MqDestination) RPC(ctx context.Context, conn *rabbitmq.Connection, message amqp.Publishing) (*amqp.Delivery, error)

v0.0.3

Nov 8, 2020

v0.0.2

Nov 3, 2020

Changes in this version

+ func FailOnError(err error, msg string)

+ func StartConsumer(msg *MqDestination, receiver OnReceive, connSetting *Settings)

+ func WrapRepo(msg amqp.Delivery, body []byte, headers amqp.Table) *amqp.Publishing

+ type OnReceive interface

+ OnReceiveMessage func(msg amqp.Delivery) (string, *amqp.Publishing, error)

v0.0.1

Oct 29, 2020

Changes in this version

+ type MqDestination struct

+ AutoAck bool

+ DeclareAll bool

+ ExchangeType string

+ Exclusive bool

+ Prefetch int

+ Queue string

+ Topic string

+ func (mq *MqDestination) Consume(conn *rabbitmq.Connection) (<-chan amqp.Delivery, *rabbitmq.Channel, error)

+ func (mq *MqDestination) DeclareDestination(cnn *rabbitmq.Connection, createTempQueue bool) error

+ func (mq *MqDestination) Produce(channel *rabbitmq.Channel, message amqp.Publishing) error

+ type Settings struct

+ Host string

+ Password string

+ Port uint

+ Prop amqp.Table

+ User string

+ Vhost string

+ func (r *Settings) ConnURL() string

+ func (r *Settings) Connect() (*rabbitmq.Connection, error)

+ func (r *Settings) String() string