rabbit

Documentation

Index

• func Add(name string, option Option)
• func AddMap(name string, setting map[string]interface{})
• func AddMapBatch(batch map[string]interface{})
• func GetConsumer(name string, queue string, optionFuncs ...func(*rabbitmq.ConsumerOptions)) *rabbitmq.Consumer
• func GetPublisher(name string, optionFuncs ...func(*rabbitmq.PublisherOptions)) *rabbitmq.Publisher
• func Use(name string) *rabbitmq.Conn
• type Option

Functions

func Add

func Add(name string, option Option)

func AddMap

func AddMap(name string, setting map[string]interface{})

func AddMapBatch

func AddMapBatch(batch map[string]interface{})

func GetConsumer

func GetConsumer(name string, queue string, optionFuncs ...func(*rabbitmq.ConsumerOptions)) *rabbitmq.Consumer

func GetPublisher

func GetPublisher(name string, optionFuncs ...func(*rabbitmq.PublisherOptions)) *rabbitmq.Publisher

func Use

func Use(name string) *rabbitmq.Conn

Types

type Option

type Option struct {
	DSN string `json:"dsn"` //数据源
}