// Package service add by blacknc <blacknc@163.com> at 2023/04/06 15:12:05
package service

import (
	"dataservices/commons/eventbus"
	"time"
)

var event_handler_config []eventbus.HandlerConfig

func registerHandler(cfg eventbus.HandlerConfig) {
	if cfg.RetryTimes == 0 {
		cfg.RetryTimes = 3
	}
	if cfg.RetryInterval == 0 {
		cfg.RetryInterval = time.Second * 5
	}
	if cfg.NumOfGoroutines == 0 {
		cfg.NumOfGoroutines = 2
	}
	event_handler_config = append(event_handler_config, cfg)
}

func RegisterEventbusHandler(bus eventbus.Eventbus) {
	bus.RegisterEventHandler(event_handler_config...)
}