Function subscribe

IceFireDB-Redis-Proxy/pkg/router/pubsub.go:51–70

(router IRoutes, pubSub *p2p.PubSub)

}

func subscribe(router IRoutes, pubSub *p2p.PubSub) {
	utils.GoWithRecover(func() {
		for args := range pubSub.Inbound {
			// logrus.Info("inbound: ", args.Message)
			var data []interface{}
			err := json.Unmarshal([]byte(args.Message), &data)
			if err != nil {
				logrus.Errorf("subscribe error: %v", err)
				continue
			}
			err = router.Sync(data)
			if err != nil {
				logrus.Errorf("subscribe sync error: %v", err)
			}
		}
	}, func(r interface{}) {
		time.Sleep(time.Second)
		subscribe(router, pubSub)
	})
}