diff --git a/inbound/default_tcp.go b/inbound/default_tcp.go index 0d32a1c0..be665c3c 100644 --- a/inbound/default_tcp.go +++ b/inbound/default_tcp.go @@ -40,9 +40,10 @@ func (a *myInboundAdapter) loopTCPIn() { for { conn, err := tcpListener.Accept() if err != nil { - return + a.logger.ErrorContext(a.ctx, err) + } else { + go a.injectTCP(conn, adapter.InboundContext{}) } - go a.injectTCP(conn, adapter.InboundContext{}) } }