rmqmanager

Documentation

Index

• type ConsumeFn
• type RabbitMqManager
  • func New(ch *amqp091.Channel) *RabbitMqManager
  • func (r *RabbitMqManager) Consume(ctx context.Context, rk string) (<-chan *TracedDelivery, error)
  • func (r *RabbitMqManager) Publish(ctx context.Context, exchange, rk string, msg []byte) error
• type TracedDelivery
  • func (d *TracedDelivery) Ack(multiple bool) error
  • func (d *TracedDelivery) Context() context.Context
  • func (d *TracedDelivery) Nack(multiple, requeue bool) error
  • func (d *TracedDelivery) Reject(requeue bool) error

Types

type ConsumeFn

type ConsumeFn func(ctx context.Context, msg amqp091.Delivery) error

type RabbitMqManager

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

func New

func New(ch *amqp091.Channel) *RabbitMqManager

func (*RabbitMqManager) Consume

func (r *RabbitMqManager) Consume(ctx context.Context, rk string) (<-chan *TracedDelivery, error)

func (*RabbitMqManager) Publish

func (r *RabbitMqManager) Publish(ctx context.Context, exchange, rk string, msg []byte) error

type TracedDelivery

type TracedDelivery struct {
	amqp091.Delivery
	// contains filtered or unexported fields
}

func (*TracedDelivery) Ack

func (d *TracedDelivery) Ack(multiple bool) error

func (*TracedDelivery) Context

func (d *TracedDelivery) Context() context.Context

func (*TracedDelivery) Nack

func (d *TracedDelivery) Nack(multiple, requeue bool) error

func (*TracedDelivery) Reject

func (d *TracedDelivery) Reject(requeue bool) error