mq

Documentation

Index

• func Init()
• func Publish(exchange, routingKey string, msg []byte) bool
• func StartConsume(qName, cName string, callback func(msg []byte) bool)
• func StopConsume()
• func UpdateRabbitHost(host string)
• type TransferData

Functions

func Init

func Init()

Init : 初始化MQ连接信息

func Publish

func Publish(exchange, routingKey string, msg []byte) bool

Publish : 发布消息

func StartConsume

func StartConsume(qName, cName string, callback func(msg []byte) bool)

StartConsume : 接收消息

func StopConsume

func StopConsume()

StopConsume : 停止监听队列

func UpdateRabbitHost

func UpdateRabbitHost(host string)

UpdateRabbitHost : 更新mq host

Types

type TransferData

type TransferData struct {
	FileHash      string
	CurLocation   string
	DestLocation  string
	DestStoreType cmn.StoreType
}

TransferData : 将要写到rabbitmq的数据的结构体