rabbitmq

Documentation

Index

• func Connect()
• func Consume(queue string) (<-chan amqp.Delivery, error)
• func Publish(exchange, msg string, durable bool) error
• func Push(msg string, msgName string) error
• func SubScribe(exchange string, durable bool) (<-chan amqp.Delivery, error)
• func UpdateRabbitmq() error

Functions

func Connect

func Connect()

Connect 初始化连接rabbitmq

func Consume

func Consume(queue string) (<-chan amqp.Delivery, error)

Consume 普通模式消费消息

func Publish

func Publish(exchange, msg string, durable bool) error

Publish 发布订阅模式发布消息

func Push

func Push(msg string, msgName string) error

Push 普通模式发布消息

func SubScribe

func SubScribe(exchange string, durable bool) (<-chan amqp.Delivery, error)

SubScribe 发布订阅模式消费消息

func UpdateRabbitmq

func UpdateRabbitmq() error

UpdateRabbitmq 配置发生变动后调用更新实例