xconfig_rabbitmq

Documentation

Index

• func Consume(names []string, fn func(amqp.Delivery))
• func ConsumeRPC(names []string, fn func(amqp.Delivery) []byte)
• func GetOneChan(name ...string) *amqp.Channel
• func GetRabbitMq(name ...string) (c map[string]*amqp.Channel)
• func InitRabbitMq() (err error)
• func Publish(exchange, key string, tsk *kts.Task) (err error)
• func PublishRPC(exchange, key string, tsk *kts.Task) (err error)

Functions

func Consume

func Consume(names []string, fn func(amqp.Delivery))

func ConsumeRPC

func ConsumeRPC(names []string, fn func(amqp.Delivery) []byte)

func GetOneChan

func GetOneChan(name ...string) *amqp.Channel

func GetRabbitMq

func GetRabbitMq(name ...string) (c map[string]*amqp.Channel)

GetRedis get redis instance with name

func InitRabbitMq

func InitRabbitMq() (err error)

InitRabbitMq init rabbitMQ

func Publish

func Publish(exchange, key string, tsk *kts.Task) (err error)

Publish mq publish

func PublishRPC

func PublishRPC(exchange, key string, tsk *kts.Task) (err error)

Publish mq publish