rabbitmq

Documentation

Index

• func Consume(url, queueName string)
• func Init(rabbitMQ RabbitmqSection)
• func Shutdown()
• type MQRequest
• type RabbitmqSection

Functions

func Consume

func Consume(url, queueName string)

Consume 消费消息

func Init

func Init(rabbitMQ RabbitmqSection)

func Shutdown

func Shutdown()

Types

type MQRequest

type MQRequest struct {
	Method  string      `json:"method"`
	Payload interface{} `json:"payload"`
}

type RabbitmqSection

type RabbitmqSection struct {
	Enable bool   `yaml:"enable"`
	Addr   string `yaml:"addr"`
	Queue  string `yaml:"queue"`
}

var (
	RabbitMQ RabbitmqSection
)