diff --git a/node/node.go b/node/node.go index c19c11ab7..85cd9d677 100644 --- a/node/node.go +++ b/node/node.go @@ -370,7 +370,7 @@ func (node *Node) Start() error { return errors.New("have no topics to listen to") } weighted := make([]*semaphore.Weighted, len(allTopics)) - const maxMessageHandlers = 2000 + const maxMessageHandlers = 4096 ctx := context.Background() ownID := node.host.GetID() errChan := make(chan error)