rabbitmq

Documentation

Index

• type RabbitMQ
  • func NewQueue(opts queue.NewQueueOpts) (*RabbitMQ, error)
  • func (r *RabbitMQ) Ack(ctx context.Context, msg queue.Message) error
  • func (r *RabbitMQ) Close(ctx context.Context)
  • func (r *RabbitMQ) Nack(ctx context.Context, msg queue.Message, requeue bool) error
  • func (r *RabbitMQ) Notify(ctx context.Context, wg *sync.WaitGroup) error
  • func (r *RabbitMQ) Publish(ctx context.Context, queueName string, msg []byte, ...) error
  • func (r *RabbitMQ) Start(ctx context.Context, queueName string) error
  • func (r *RabbitMQ) Subscribe(ctx context.Context, msgChan chan<- queue.Message, wg *sync.WaitGroup) error

Types

type RabbitMQ

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

func NewQueue

func NewQueue(opts queue.NewQueueOpts) (*RabbitMQ, error)

func (*RabbitMQ) Ack

func (r *RabbitMQ) Ack(ctx context.Context, msg queue.Message) error

func (*RabbitMQ) Close

func (r *RabbitMQ) Close(ctx context.Context)

func (*RabbitMQ) Nack

func (r *RabbitMQ) Nack(ctx context.Context, msg queue.Message, requeue bool) error

func (*RabbitMQ) Notify

func (r *RabbitMQ) Notify(ctx context.Context, wg *sync.WaitGroup) error

Notify should be called by publishers who wish to be notified of subscription errors.

func (*RabbitMQ) Publish

func (r *RabbitMQ) Publish(
	ctx context.Context,
	queueName string,
	msg []byte,
	headers map[string]interface{},
	expiration *string,
) error

func (*RabbitMQ) Start

func (r *RabbitMQ) Start(ctx context.Context, queueName string) error

func (*RabbitMQ) Subscribe

func (r *RabbitMQ) Subscribe(ctx context.Context, msgChan chan<- queue.Message, wg *sync.WaitGroup) error

Subscribe should be called by consumers.