consumer

Documentation

Index

• type BaseConfig
  • func New(mq *gorabbitmq.RabbitMQ, data map[string]interface{}, f Fn) *BaseConfig
  • func (c *BaseConfig) Consumer() error
• type Fn

Types

type BaseConfig

type BaseConfig struct {
	Amqp     *gorabbitmq.RabbitMQ
	Data     map[string]interface{}
	CallBack Fn
}

func New

func New(mq *gorabbitmq.RabbitMQ, data map[string]interface{}, f Fn) *BaseConfig

New 实例化

func (*BaseConfig) Consumer

func (c *BaseConfig) Consumer() error

Consumer 消费者

type Fn

type Fn func(mq *gorabbitmq.RabbitMQ, Data map[string]interface{}) error