@@ -16,23 +16,7 @@ public sealed class PulsarBuilder : ContainerBuilder<PulsarBuilder, PulsarContai
16
16
17
17
public const string Username = "test-user" ;
18
18
19
- private static readonly IReadOnlyDictionary < string , string > AuthenticationEnvVars ;
20
-
21
- static PulsarBuilder ( )
22
- {
23
- const string authenticationPlugin = "org.apache.pulsar.client.impl.auth.AuthenticationToken" ;
24
- var authenticationEnvVars = new Dictionary < string , string > ( ) ;
25
- authenticationEnvVars . Add ( "authenticateOriginalAuthData" , "false" ) ;
26
- authenticationEnvVars . Add ( "authenticationEnabled" , "true" ) ;
27
- authenticationEnvVars . Add ( "authorizationEnabled" , "true" ) ;
28
- authenticationEnvVars . Add ( "authenticationProviders" , "org.apache.pulsar.broker.authentication.AuthenticationProviderToken" ) ;
29
- authenticationEnvVars . Add ( "brokerClientAuthenticationPlugin" , authenticationPlugin ) ;
30
- authenticationEnvVars . Add ( "CLIENT_PREFIX_authPlugin" , authenticationPlugin ) ;
31
- authenticationEnvVars . Add ( "PULSAR_PREFIX_authenticationRefreshCheckSeconds" , "5" ) ;
32
- authenticationEnvVars . Add ( "PULSAR_PREFIX_tokenSecretKey" , "file://" + SecretKeyFilePath ) ;
33
- authenticationEnvVars . Add ( "superUserRoles" , Username ) ;
34
- AuthenticationEnvVars = new ReadOnlyDictionary < string , string > ( authenticationEnvVars ) ;
35
- }
19
+ private static readonly IReadOnlyDictionary < string , string > AuthenticationEnvVars = InitAuthenticationEnvVars ( ) ;
36
20
37
21
/// <summary>
38
22
/// Initializes a new instance of the <see cref="PulsarBuilder" /> class.
@@ -126,6 +110,22 @@ protected override PulsarBuilder Merge(PulsarConfiguration oldValue, PulsarConfi
126
110
return new PulsarBuilder ( new PulsarConfiguration ( oldValue , newValue ) ) ;
127
111
}
128
112
113
+ private static IReadOnlyDictionary < string , string > InitAuthenticationEnvVars ( )
114
+ {
115
+ const string authenticationPlugin = "org.apache.pulsar.client.impl.auth.AuthenticationToken" ;
116
+ var authenticationEnvVars = new Dictionary < string , string > ( ) ;
117
+ authenticationEnvVars . Add ( "authenticateOriginalAuthData" , "false" ) ;
118
+ authenticationEnvVars . Add ( "authenticationEnabled" , "true" ) ;
119
+ authenticationEnvVars . Add ( "authorizationEnabled" , "true" ) ;
120
+ authenticationEnvVars . Add ( "authenticationProviders" , "org.apache.pulsar.broker.authentication.AuthenticationProviderToken" ) ;
121
+ authenticationEnvVars . Add ( "brokerClientAuthenticationPlugin" , authenticationPlugin ) ;
122
+ authenticationEnvVars . Add ( "CLIENT_PREFIX_authPlugin" , authenticationPlugin ) ;
123
+ authenticationEnvVars . Add ( "PULSAR_PREFIX_authenticationRefreshCheckSeconds" , "5" ) ;
124
+ authenticationEnvVars . Add ( "PULSAR_PREFIX_tokenSecretKey" , "file://" + SecretKeyFilePath ) ;
125
+ authenticationEnvVars . Add ( "superUserRoles" , Username ) ;
126
+ return new ReadOnlyDictionary < string , string > ( authenticationEnvVars ) ;
127
+ }
128
+
129
129
/// <inheritdoc cref="IWaitUntil" />
130
130
private sealed class WaitUntil : IWaitUntil
131
131
{
0 commit comments