common

Documentation

Index

• type MessageHandler
• type MessageQueue

Types

type MessageHandler

type MessageHandler func(queue MessageQueue, topic string, event *data_protocol.CloudEvent)

MessageHandler 消息处理函数 参数: - queue: 消息队列 - topic: 主题 - data: 消息数据 返回值: 无

type MessageQueue

type MessageQueue interface {
	Subscribe(group string, topic string, handler MessageHandler) error
	UnSubscribe(group string, topic string) error
	Publish(topic string, event *data_protocol.CloudEvent) error
}

MessageQueue 消息队列接口