Fix bond outbound

This commit is contained in:
Sergei Maklagin
2026-03-02 19:31:23 +03:00
parent 7fc33134fb
commit 57c5ca13eb

View File

@@ -92,6 +92,10 @@ func (h *Inbound) Close() error {
}
func (h *Inbound) connHandler(ctx context.Context, conn net.Conn, metadata adapter.InboundContext, onClose N.CloseHandlerFunc) error {
if metadata.Destination != Destination {
h.router.RouteConnectionEx(ctx, conn, metadata, onClose)
return nil
}
request, err := ReadRequest(conn)
if err != nil {
return err