mq

package

v0.0.0-...-6dd7e16 Latest Latest Go to latest Published: Dec 30, 2019 License: MIT Imports: 4 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/solozyx/object-storage

Links

Open Source Insights

Documentation ¶

Index ¶

func Publish(exchange, routingKey string, msg []byte) bool
func StartConsume(queueName, consumerName string, callback func(msg []byte) bool)
func StopConsume()
type TransferData

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func Publish ¶

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

生产者发布消息生产者把消息投递到rabbitmq的交换机exchange

func StartConsume ¶

func StartConsume(queueName, consumerName string, callback func(msg []byte) bool)

接收消息 callback 外部调用者指定的回调函数

func StopConsume ¶

func StopConsume()

StopConsume : 停止监听队列

Types ¶

type TransferData ¶

type TransferData struct {
	FileHash      string
	CurLocation   string         // 上传文件本地存储路径
	DestLocation  string         // 文件迁移到OSS的目标地址
	DestStoreType comm.StoreType // 文件迁移到存储服务类型
}

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

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL