hedwig

Mar 27, 2025

Changes in this version

+ const QosPrefetchCount

Dec 11, 2024

Changes in this version

+ const MinDeliveryLimit

type QueueSetting

+ DeliveryLimit uint

+ QueueType QueueType

+ type QueueType uint

+ const QueueType_Classic

+ const QueueType_Quorum

Sep 28, 2023

Changes in this version

+ const DelayHeader

+ const DelayedExchangeArgKey

+ const ExchangeTypeDelayed

+ const PublishChannel

+ const SubscribeChannel

+ var ErrAlreadyInitialized = errors.New("already initialized, disconnect before attempting again")

+ var ErrNilHedwig = errors.New("hedwig is nil, use `New` to create an instance")

+ var ErrNoBindings = errors.New("no bindings provided, need at least one")

+ var ErrNoConsumerSetting = errors.New("consumer setting is nil")

+ type Callback func(<-chan amqp.Delivery, *sync.WaitGroup)

+ type ConsumerSetting struct

+ Queues map[string]*QueueSetting

+ type Hedwig struct

+ Error error

+ Settings *Settings

+ func New(settings *Settings) *Hedwig

+ func (h *Hedwig) AddQueue(qSetting *QueueSetting, qName string) error

+ func (h *Hedwig) Consume() error

+ func (h *Hedwig) Disconnect() error

+ func (h *Hedwig) Publish(key string, body []byte) (err error)

+ func (h *Hedwig) PublishWithDelay(key string, body []byte, delay time.Duration) (err error)

+ func (h *Hedwig) PublishWithHeaders(key string, body []byte, headers map[string]interface{}) (err error)

+ type QueueSetting struct

+ AutoDelete bool

+ Bindings []string

+ Callback Callback

+ Durable bool

+ Exclusive bool

+ NoAck bool

+ func DefaultQueueSetting(callback Callback, bindings ...string) *QueueSetting

+ type Settings struct

+ Consumer *ConsumerSetting

+ Exchange string

+ ExchangeArgs amqp.Table

+ ExchangeType string

+ HeartBeatInterval time.Duration

+ Host string

+ Password string

+ Port int

+ SocketTimeout time.Duration

+ Username string

+ Vhost string

+ func DefaultSettings() *Settings