in src/DotPulsar/Internal/ConnectionPool.cs [170:185]
private static CommandConnect WithProxyToBroker(CommandConnect commandConnect, Uri logicalUrl)
{
return new CommandConnect
{
AuthData = commandConnect.ShouldSerializeAuthData() ? commandConnect.AuthData : null,
AuthMethod = commandConnect.ShouldSerializeAuthMethod() ? commandConnect.AuthMethod : AuthMethod.AuthMethodNone,
AuthMethodName = commandConnect.ShouldSerializeAuthMethodName() ? commandConnect.AuthMethodName : null,
ClientVersion = commandConnect.ClientVersion,
OriginalPrincipal = commandConnect.ShouldSerializeOriginalPrincipal() ? commandConnect.OriginalPrincipal : null,
ProtocolVersion = commandConnect.ProtocolVersion,
OriginalAuthData = commandConnect.ShouldSerializeOriginalAuthData() ? commandConnect.OriginalAuthData : null,
OriginalAuthMethod = commandConnect.ShouldSerializeOriginalAuthMethod() ? commandConnect.OriginalAuthMethod : null,
ProxyToBrokerUrl = $"{logicalUrl.Host}:{logicalUrl.Port}",
FeatureFlags = commandConnect.FeatureFlags
};
}