groupPowerLeave.go 857 Bytes
Newer Older
hujiebin's avatar
hujiebin committed
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29
package group_power_ev

import (
	"git.hilo.cn/hilo-common/domain"
	"git.hilo.cn/hilo-common/resource/mysql"
)

type GroupPowerLeaveEvent struct {
	UserId       mysql.ID
	GroupPowerId mysql.ID
}

//注册监听
var groupPowerLeaveListen = new(domain.EventBase)

//添加领域事件,在每个领域模型中init中添加,因为这是静态业务,非动态的。
func AddGroupPowerLeaveSync(callback func(model *domain.Model, event interface{}) error) {
	domain.AddEventSync(groupPowerLeaveListen, callback)
}

//加入到异步操作中
func AddGroupPowerLeaveAsync(callback func(model *domain.Model, event interface{}) error) {
	domain.AddEventAsync(groupPowerLeaveListen, callback)
}

//领域事件发布
func PublishGroupPowerLeave(model *domain.Model, event interface{}) error {
	return domain.PublishEvent(groupPowerLeaveListen, model, event)
}