amqp

Documentation

Index

• func NewMessageFromDelivery(delivery amqp.Delivery) *message.Message
• func NewProvider(connStr string) mq.IProvider
• func NewPublishingFromMessage(msg *message.Message) amqp.Publishing
• type Provider
  • func (provider *Provider) Exit() error
  • func (provider *Provider) Init(ctx context.Context, svcName string, purge bool, topics []string) error
  • func (provider *Provider) NotifyConfirm(ack, nack chan uint64)
  • func (provider *Provider) Publish(message *message.Message) error
  • func (provider *Provider) Subscribe(ctx context.Context, consumerTag string, msgs chan *message.Message) error

Functions

func NewMessageFromDelivery

func NewMessageFromDelivery(delivery amqp.Delivery) *message.Message

func NewProvider

func NewProvider(connStr string) mq.IProvider

func NewPublishingFromMessage

func NewPublishingFromMessage(msg *message.Message) amqp.Publishing

Types

type Provider

type Provider struct {
	// contains filtered or unexported fields
}

func (*Provider) Exit

func (provider *Provider) Exit() error

func (*Provider) Init

func (provider *Provider) Init(ctx context.Context, svcName string, purge bool, topics []string) error

func (*Provider) NotifyConfirm

func (provider *Provider) NotifyConfirm(ack, nack chan uint64)

func (*Provider) Publish

func (provider *Provider) Publish(message *message.Message) error

func (*Provider) Subscribe

func (provider *Provider) Subscribe(ctx context.Context, consumerTag string, msgs chan *message.Message) error