gormq

Aug 10, 2025

Changes in this version

type ConnectionOptions

+ ClientName string

Nov 6, 2024

Changes in this version

+ func Init(opt ConnectionOptions)

+ type Client interface

+ AddConsumer func(ConsumerOption) error

+ Conn func() *rabbitmq.Conn

+ Publish func(Message)

+ Start func()

+ Stop func()

+ var DefaultClient Client

+ func GetClient() Client

+ type ConnectionOptions struct

+ FailedMessageRetryInterval time.Duration

+ ReconnectInterval time.Duration

+ URL string

+ type Consumer func([]byte) error

+ type ConsumerOption struct

+ Consumer Consumer

+ Dlq bool

+ DlqName string

+ DlqRoutingKey string

+ Exchange string

+ PrefetchCount int

+ Queue string

+ RoutingKey string

+ type Logger struct

+ func (l *Logger) Debugf(msg string, args ...interface{})

+ func (l *Logger) Errorf(msg string, args ...interface{})

+ func (l *Logger) Fatalf(msg string, args ...interface{})

+ func (l *Logger) Infof(msg string, args ...interface{})

+ func (l *Logger) Warnf(msg string, args ...interface{})

+ type Message struct

+ Exchange string

+ Message []byte

+ RoutingKey string

+ func NewMessage(exchange, routingKey string, data interface{}) Message