consumer

Documentation

Index

• Variables
• type Config
  • func (config Config) CreateConsumer() (c Consumer, err error)
  • func (config Config) ParseCli(ctx *cli.Context) Config
• type Consumer
  • func WithConnection(conn *amqp.Connection) (c Consumer, err error)
  • func (c *Consumer) Close()
  • func (c *Consumer) ConsumeQueue(queueName string) (resultChan <-chan amqp.Delivery, err error)

Variables

var CliOptions = libcli.CommonCliOptions(libcli.RabbitMQ)

CliOptions ...

Types

type Config

type Config struct {
	rabbitmq.Config
}

Config ...

func (Config) CreateConsumer

func (config Config) CreateConsumer() (c Consumer, err error)

CreateConsumer ...

func (Config) ParseCli

func (config Config) ParseCli(ctx *cli.Context) Config

ParseCli ...

type Consumer

type Consumer struct {
	Config Config
	Conn   *amqp.Connection
	Ch     *amqp.Channel
}

Consumer ...

func WithConnection

func WithConnection(conn *amqp.Connection) (c Consumer, err error)

WithConnection ...

func (*Consumer) Close

func (c *Consumer) Close()

Close ...

func (*Consumer) ConsumeQueue

func (c *Consumer) ConsumeQueue(queueName string) (resultChan <-chan amqp.Delivery, err error)

ConsumeQueue ...