zhangdeman/gopkg
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

增加redis数据处理的接口定义

Browse Source
This commit is contained in:
白茶清欢 2021-09-24 11:08:02 +08:00
parent 339e78bd12
commit 04d19d9088
1 changed files with 19 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
queue/message/abstract.go
View File

@ -7,7 +7,9 @@
// Date : 2021-09-23 10:58 下午 // Date : 2021-09-23 10:58 下午
package message package message
import "git.zhangdeman.cn/zhangdeman/gopkg/middleware/kafka" import (
"git.zhangdeman.cn/zhangdeman/gopkg/middleware/kafka"
)
// IMessageQueue 消息队列的接口约束 // IMessageQueue 消息队列的接口约束
// //
@ -19,11 +21,23 @@ type IMessageQueue interface {
Publish(data interface{}) error Publish(data interface{}) error
// Subscribe 订阅消息 // Subscribe 订阅消息
Subscribe() Subscribe()
// Success 成功回调
Success(data []byte)
// Fail 失败回调
Fail(data []byte, err error)
} }
// IKafkaMessageHandler 卡夫卡消息处理 // IKafkaMessageHandler 卡夫卡消息处理
type IKafkaMessageHandler kafka.IConsumeDataHandler type IKafkaMessageHandler kafka.IConsumeDataHandler
// IRedisMessageHandler redis消息的处理
//
// Author : go_developer@163.com<白茶清欢>
//
// Date : 11:04 上午 2021/9/24
type IRedisMessageHandler interface {
// Execute 处理数据
Execute(data []byte) error
// Success 成功回调
Success(data []byte)
// Fail 处理失败回调
Fail(data []byte, err error)
// Exception 消费出现异常回调
Exception(err error)
}