consumer

Documentation

Index

• type Consumer
  • func NewConsumer(ch *amqp.Channel, handler middleware.HandlerFunc, opts ...Option) (*Consumer, error)
  • func (c *Consumer) Start(ctx context.Context) error
  • func (c *Consumer) Stop() error
• type Option
  • func WithAutoAck(autoAck bool) Option
  • func WithExchange(exchange string) Option
  • func WithMiddlewares(mws ...middleware.MiddlewareFunc) Option
  • func WithQueue(queue string) Option
  • func WithQueueDeclare(declare bool) Option
  • func WithQueueOptions(options amqp.Table) Option
  • func WithRoutingKey(key string) Option
• type Options

Types

type Consumer

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

func NewConsumer

func NewConsumer(ch *amqp.Channel, handler middleware.HandlerFunc, opts ...Option) (*Consumer, error)

func (*Consumer) Start

func (c *Consumer) Start(ctx context.Context) error

func (*Consumer) Stop

func (c *Consumer) Stop() error

type Option

type Option func(*Options)

func WithAutoAck

func WithAutoAck(autoAck bool) Option

func WithExchange

func WithExchange(exchange string) Option

func WithMiddlewares

func WithMiddlewares(mws ...middleware.MiddlewareFunc) Option

func WithQueue

func WithQueue(queue string) Option

func WithQueueDeclare

func WithQueueDeclare(declare bool) Option

func WithQueueOptions

func WithQueueOptions(options amqp.Table) Option

func WithRoutingKey

func WithRoutingKey(key string) Option

type Options

type Options struct {
	Exchange     string
	Queue        string
	RoutingKey   string
	AutoAck      bool
	Middlewares  []middleware.MiddlewareFunc
	QueueDeclare bool
	QueueOptions amqp.Table
}