consumer

type LuaScriptExec struct {
	Topic   string           // 订阅key
	Channel string           // 订阅渠道
	Workers LuaScriptWorkers // 消息处理执行
}

type LuaScriptMessageBody struct {
	ScriptPath   string                 // 脚本地址
	Args         map[string]interface{} // 脚本参数
	CallBackType string                 // 回调方式，api/topic
	CallBack     string                 // 回调地址/消息队列话题
}

type LuaScriptWorkers interface {
	// Before() error
	Processing(body []byte) error
}