12345678910111213141516171819202122232425262728293031323334353637383940 |
- package bus
- import (
- "launcher/conf"
- "launcher/service"
- "infish.cn/comm"
- )
- var NatsCenter *comm.NatsBus
- func NewNatsBus(app *conf.AppConf) (*comm.NatsBus, map[string]*comm.NatsBus) {
- // 适配器总线连接
- replyers := []*comm.NatsMsgReplyer{}
- replyers = append(replyers, service.NewConfigReplyer(app), service.NetDevConfigReplyer(app), service.NewConfigSetReplyer(app), service.NewLancherQuitReplyer(app))
- localBus, _ := comm.NewNatsBus4("queen3d", app.Nats.Url, app.Nats.MaxReconnect, app.Nats.ReconnDelaySecond,
- []*comm.NatsStreamWather{
- // NewTestStream(),
- },
- replyers...,
- )
- proxies := service.RegisterProxyBus(app)
- proxyReplyers, err := comm.CreateBusProxyReplyers(proxies, localBus)
- if err != nil {
- panic(err)
- }
- localBus.AddReplyers(proxyReplyers...)
- NatsCenter = localBus
- if localBus == nil {
- panic("create bus error")
- }
- return NatsCenter, proxies
- }
|