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()