rabbitmq

Documentation

Index

• func NewProducer(ctx context.Context, ...) (err error)
• func Test()
• type ConsumeMsg
• type Consumer
  • func NewConsumer(amqpURI, queueName, tag string, consumeMsg ConsumeMsg) (*Consumer, error)
  • func (c *Consumer) Shutdown()
• type TestConsumer
  • func (*TestConsumer) Do(d amqp.Delivery) error

Functions

func NewProducer

func NewProducer(ctx context.Context, msg, amqpURI, exchangeName, exchangeType, queueName, routeName, tag string) (err error)

func Test

func Test()

Types

type ConsumeMsg

type ConsumeMsg interface {
	// Do
	Do(d amqp.Delivery) error
}

ConsumeMsg

type Consumer

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

Consumer

func NewConsumer

func NewConsumer(amqpURI, queueName, tag string, consumeMsg ConsumeMsg) (*Consumer, error)

NewConsumer

func (*Consumer) Shutdown

func (c *Consumer) Shutdown()

type TestConsumer

type TestConsumer struct{}

func (*TestConsumer) Do

func (*TestConsumer) Do(d amqp.Delivery) error