Versions in this module Expand all Collapse all v1 v1.1.0 Sep 19, 2024 Changes in this version + type AmqpBroker struct + func NewAmqpBroker(option *AmqpBrokerOptions) *AmqpBroker + func (a *AmqpBroker) Consume(queue *Queue) error + func (a *AmqpBroker) Health() bool + func (a *AmqpBroker) Publish(key string, body []byte) error + func (a *AmqpBroker) PublishDelay(queue string, body []byte, delay int64) error + type AmqpBrokerOptions struct + Exchange string + ExchangeType string + Url string + type Broker interface + Consume func(queue *Queue) error + Health func() bool + Publish func(key string, body []byte) error + PublishDelay func(queue string, body []byte, delay int64) error + type Queue struct + Handle func([]byte) Status + Name string + RetryQueue []int64 + RouteKey string + type Status int + const Retry + const Success v1.0.0 Sep 10, 2024
Go to main page