rabbitx

Documentation

Index

• func SetupCloseHandler(consumer *Consumer)
• type Consumer
  • func NewConsumer(ctx context.Context, cfgs RabbitmqConConf, ...) *Consumer
  • func (c *Consumer) Shutdown() error
• type Producer
  • func NewProducer(ctx context.Context, cfgs RabbitmqProConf) *Producer
  • func (p *Producer) Publish(data []byte) error
  • func (p *Producer) Shutdown() error
• type RabbitmqConConf
• type RabbitmqProConf

Functions

func SetupCloseHandler

func SetupCloseHandler(consumer *Consumer)

Types

type Consumer

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

func NewConsumer

func NewConsumer(ctx context.Context, cfgs RabbitmqConConf, handle func(deliveries <-chan amqp.Delivery, done chan error)) *Consumer

func (*Consumer) Shutdown

func (c *Consumer) Shutdown() error

type Producer

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

func NewProducer

func NewProducer(ctx context.Context, cfgs RabbitmqProConf) *Producer

func (*Producer) Publish

func (p *Producer) Publish(data []byte) error

func (*Producer) Shutdown

func (p *Producer) Shutdown() error

type RabbitmqConConf

type RabbitmqConConf struct {
	Address      string `yaml:"Address"`
	Exchange     string `yaml:"Exchange"`
	ExchangeType string `yaml:"ExchangeType"`
	Queue        string `yaml:"Queue"`
	BindingKey   string `yaml:"BindingKey"`
	ConsumerTag  string `yaml:"ConsumerTag"`
	LifeTime     int    `yaml:"LifeTime"`
	VerBose      bool   `yaml:"VerBose"`
	AutoACK      bool   `yaml:"AutoACK"`
}

type RabbitmqProConf

type RabbitmqProConf struct {
	Address      string `yaml:"Address"`
	Exchange     string `yaml:"Exchange"`
	ExchangeType string `yaml:"ExchangeType"`
	Queue        string `yaml:"Queue"`
	BindingKey   string `yaml:"BindingKey"`
	ConsumerTag  string `yaml:"ConsumerTag"`
	RoutingKey   string `yaml:"RoutingKey"`
	LifeTime     int    `yaml:"LifeTime"`
	AutoACK      bool   `yaml:"AutoACK"`
}