Documentation
¶
Index ¶
- Constants
- Variables
- type AMQP
- func (a *AMQP) Close() error
- func (a *AMQP) ConsumeNotifications(ctx context.Context) (<-chan amqp.Delivery, error)
- func (a *AMQP) ConsumeTasks() (<-chan amqp.Delivery, error)
- func (a *AMQP) PublishDelayed(body []byte, delay time.Duration, messageType string) error
- func (a *AMQP) PublishNotification(body []byte) error
Constants ¶
View Source
const ( DelayedExchange = "delayed" DelayedExchangeKind = "x-delayed-message" DelayedQueue = "delayed-queue" NotificationsExchange = "notifications_fanout" )
Variables ¶
View Source
var Module = fx.Provide( NewAMQPMessageBackend, )
Functions ¶
This section is empty.
Types ¶
type AMQP ¶
type AMQP struct {
// contains filtered or unexported fields
}
func NewAMQPMessageBackend ¶
func NewAMQPMessageBackend(lc fx.Lifecycle, shutdowner fx.Shutdowner, conf config.AMQPConfig, log *zap.Logger) (*AMQP, error)
func (*AMQP) ConsumeNotifications ¶
func (*AMQP) PublishDelayed ¶
func (*AMQP) PublishNotification ¶
Source Files
Click to show internal directories.
Click to hide internal directories.