producer

Documentation

Index

• Variables
• type Config
  • func (config Config) CreateProducer() (p Producer, err error)
  • func (config Config) ParseCli(ctx *cli.Context) Config
• type Producer
  • func (p *Producer) Close()
  • func (p *Producer) ConsumeQueue(queueName string) (resultChan <-chan amqp.Delivery, err error)
  • func (p *Producer) CreateQueue(queueName string) (err error)
  • func (p *Producer) Publish(message []byte, routingKey string) error

Variables

var CliOptions = libcli.CommonCliOptions(libcli.RabbitMQ)

CliOptions ...

Types

type Config

type Config struct {
	rabbitmq.Config
	QueueLength int64
}

Config ...

func (Config) CreateProducer

func (config Config) CreateProducer() (p Producer, err error)

CreateProducer ...

func (Config) ParseCli

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

ParseCli ...

type Producer

type Producer struct {
	Config Config
	Conn   *amqp.Connection
	ProdCh *amqp.Channel
	ConCh  *amqp.Channel
}

Producer ...

func (*Producer) Close

func (p *Producer) Close()

Close ...

func (*Producer) ConsumeQueue

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

ConsumeQueue ...

func (*Producer) CreateQueue

func (p *Producer) CreateQueue(queueName string) (err error)

CreateQueue ...

func (*Producer) Publish

func (p *Producer) Publish(message []byte, routingKey string) error

Publish ...