diff --git a/node/node_handler.go b/node/node_handler.go index f37b65df4..f49cf4588 100644 --- a/node/node_handler.go +++ b/node/node_handler.go @@ -65,7 +65,7 @@ func (node *Node) ReceiveGroupMessage() { // utils.GetLogInstance().Info("[PUBSUB]", "received group msg", len(msg), "sender", sender) if err == nil { // skip the first 5 bytes, 1 byte is p2p type, 4 bytes are message size - node.messageHandler(msg[5:], string(sender)) + go node.messageHandler(msg[5:], string(sender)) } } } @@ -85,7 +85,7 @@ func (node *Node) ReceiveClientGroupMessage() { utils.GetLogInstance().Info("[CLIENT]", "received group msg", len(msg), "sender", sender) if err == nil { // skip the first 5 bytes, 1 byte is p2p type, 4 bytes are message size - node.messageHandler(msg[5:], string(sender)) + go node.messageHandler(msg[5:], string(sender)) } } }