@@ -48,17 +48,14 @@ abstract class DefaultConnectionSettings<T> implements ConnectionSettings<T> {
48
48
SASL_MECHANISM_ANONYMOUS ,
49
49
SASL_MECHANISM_EXTERNAL );
50
50
51
- static final String DEFAULT_USERNAME = "guest" ;
52
- static final String DEFAULT_PASSWORD = DEFAULT_USERNAME ;
53
51
static final String DEFAULT_HOST = "localhost" ;
54
52
static final int DEFAULT_PORT = 5672 ;
55
53
static final int DEFAULT_TLS_PORT = 5671 ;
56
54
static final String DEFAULT_VIRTUAL_HOST = "/" ;
57
55
58
56
private String host = DEFAULT_HOST ;
59
57
private int port = DEFAULT_PORT ;
60
- private CredentialsProvider credentialsProvider =
61
- new DefaultUsernamePasswordCredentialsProvider (DEFAULT_USERNAME , DEFAULT_PASSWORD );
58
+ private CredentialsProvider credentialsProvider ;
62
59
private String virtualHost = DEFAULT_VIRTUAL_HOST ;
63
60
private List <URI > uris = Collections .emptyList ();
64
61
private Duration idleTimeout = Duration .ofMillis (ConnectionOptions .DEFAULT_IDLE_TIMEOUT );
@@ -173,14 +170,7 @@ public T saslMechanism(String mechanism) {
173
170
SASL_MECHANISMS .stream ().map (n -> "'" + n + "'" ).collect (Collectors .joining (", " ))));
174
171
}
175
172
this .saslMechanism = mechanism ;
176
- if (SASL_MECHANISM_ANONYMOUS .equals (mechanism )) {
177
- this .credentialsProvider = null ;
178
- } else if (SASL_MECHANISM_PLAIN .equals (mechanism )) {
179
- this .credentialsProvider =
180
- new DefaultUsernamePasswordCredentialsProvider (DEFAULT_USERNAME , DEFAULT_PASSWORD );
181
- } else if (SASL_MECHANISM_EXTERNAL .equals (mechanism )) {
182
- this .credentialsProvider = null ;
183
- }
173
+ this .credentialsProvider = null ;
184
174
return this .toReturn ();
185
175
}
186
176
0 commit comments