rabbitmqx

Nov 7, 2022

Changes in this version

+ type Config struct

+ ExType string

+ Exchange string

+ MqUrl string

+ Queue string

+ RoutingKey string

+ func NewConfigByMap(setting map[string]interface{}) *Config

+ type Consumer struct

+ func NewConsumer(mqUrl string) (*Consumer, error)

+ func NewConsumerByConfig(c *Config) (*Consumer, error)

+ func NewDelayedQueueConsumer(config *Config) (*Consumer, error)

+ func (c *Consumer) Close() error

+ func (c *Consumer) Consume(handler rabbitmq.Handler) error

+ func (c *Consumer) SetExchange(exchange string, exType string)

+ func (c *Consumer) SetOptions(options []func(*rabbitmq.ConsumeOptions))

+ func (c *Consumer) SetQueue(queue string)

+ func (c *Consumer) SetRoutingKey(routingKey []string)

+ type Publisher struct

+ func NewDelayedQueuePulisher(config *Config) (*Publisher, error)

+ func NewPublisher(mqUrl string) (*Publisher, error)

+ func NewPublisherByConfig(c *Config) (*Publisher, error)

+ func (p *Publisher) Close() error

+ func (p *Publisher) Publish(msg []byte) error

+ func (p *Publisher) PublishDelayed(msg []byte, ttl int64) error

+ func (p *Publisher) SetExchange(exchange string)

+ func (p *Publisher) SetOptions(options []func(*rabbitmq.PublishOptions))

+ func (p *Publisher) SetRoutingKey(routingKey []string)