queue

Documentation

Index

• func FailOnError(err error, msg string)
• func RabbitMQAdapter(ctx context.Context, queueName string, body []byte) (<-chan IDelivery, error)
• type IConsumer
  • func (c *IConsumer) Consumer(ctx context.Context, ch *amqp.Channel, queueName string) (<-chan IDelivery, error)
• type IDelivery
• type IPublisher
  • func (p *IPublisher) Publish(ctx context.Context, ch *amqp.Channel, queueName string, body []byte) error

Functions

func FailOnError

func FailOnError(err error, msg string)

func RabbitMQAdapter

func RabbitMQAdapter(ctx context.Context, queueName string, body []byte) (<-chan IDelivery, error)

Types

type IConsumer

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

func (*IConsumer) Consumer

func (c *IConsumer) Consumer(ctx context.Context, ch *amqp.Channel, queueName string) (<-chan IDelivery, error)

type IDelivery

type IDelivery struct {
	Delivery amqp.Delivery
	Ctx      context.Context
}

type IPublisher

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

func (*IPublisher) Publish

func (p *IPublisher) Publish(ctx context.Context, ch *amqp.Channel, queueName string, body []byte) error