concurrent consumption of messages

3 years ago · 2b142baf19
parent 78bfd1ff64
commit 2b142baf19
1 changed files with 1 additions and 1 deletions
--- a/internal/msg_transfer/logic/init.go
+++ b/internal/msg_transfer/logic/init.go
@ -15,7 +15,7 @@ const OnlineTopicVacancy = 0
 const Msg = 2
 const ConsumerMsgs = 3
 const UserMessages = 4
-const ChannelNum = 10
+const ChannelNum = 11

 var (
 	persistentCH          PersistentConsumerHandler