From b9a8a7e237774a33f0d6ab3d12795c39272ba42f Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E7=A7=8B=E3=81=AE=E3=81=8B=E3=81=88=E3=81=A7?= Date: Sat, 8 Oct 2022 09:04:05 +0800 Subject: [PATCH] Feat: add transport original name to listen unix (#2048) --- transport/internet/tcp_hub.go | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/transport/internet/tcp_hub.go b/transport/internet/tcp_hub.go index 177b56887..3cc25e5bf 100644 --- a/transport/internet/tcp_hub.go +++ b/transport/internet/tcp_hub.go @@ -36,6 +36,11 @@ func ListenUnix(ctx context.Context, address net.Address, settings *MemoryStream } protocol := settings.ProtocolName + + if originalProtocolName := getOriginalMessageName(settings); originalProtocolName != "" { + protocol = originalProtocolName + } + listenFunc := transportListenerCache[protocol] if listenFunc == nil { return nil, newError(protocol, " unix istener not registered.").AtError()