From f08d0b32d7931d44de09c7c1705d3887652a09aa Mon Sep 17 00:00:00 2001
From: ngjaying <huangjy@emqx.io>
Date: Sun, 28 Apr 2024 14:53:22 +0800
Subject: [PATCH] fix(neuron): remove max receive size (#2820)

Signed-off-by: Jiyong Huang <huangjy@emqx.io>
---
 internal/io/neuron/connection.go | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/internal/io/neuron/connection.go b/internal/io/neuron/connection.go
index 61cccbbf00..46610e9c34 100644
--- a/internal/io/neuron/connection.go
+++ b/internal/io/neuron/connection.go
@@ -121,6 +121,10 @@ func connect(ctx api.StreamContext, url string, info *conninfo) error {
 	if err != nil {
 		return err
 	}
+	err = info.sock.SetOption(mangos.OptionMaxRecvSize, 0)
+	if err != nil {
+		return err
+	}
 	info.sock.SetPipeEventHook(func(ev mangos.PipeEvent, p mangos.Pipe) {
 		switch ev {
 		case mangos.PipeEventAttached: