fix(backend-http): topic name

This commit is contained in:
ShiKhu 2021-11-10 18:17:40 +01:00
parent 9c6d895cee
commit 4551b7448e

View file

@ -31,7 +31,7 @@ func main() {
consumer := queue.NewMessageConsumer(
env.String("GROUP_DB"),
[]string{
env.String("TOPIC_IOS_RAW"),
env.String("TOPIC_RAW_IOS"),
env.String("TOPIC_TRIGGER"),
},
func(sessionID uint64, msg messages.Message, _ *types.Meta) {