rabbitmq

Documentation

Index

• 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 Consume

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

普通模式消费消息

func Publish

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

发布订阅模式发布消息

func Push

func Push(msg string, msgName string) error

普通模式发布消息

func SubScribe

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

发布订阅模式消费消息

func UpdateRabbitmq

func UpdateRabbitmq() error