@@ -48,17 +48,14 @@ abstract class DefaultConnectionSettings<T> implements ConnectionSettings<T> {
4848 SASL_MECHANISM_ANONYMOUS ,
4949 SASL_MECHANISM_EXTERNAL );
5050
51- static final String DEFAULT_USERNAME = "guest" ;
52- static final String DEFAULT_PASSWORD = DEFAULT_USERNAME ;
5351 static final String DEFAULT_HOST = "localhost" ;
5452 static final int DEFAULT_PORT = 5672 ;
5553 static final int DEFAULT_TLS_PORT = 5671 ;
5654 static final String DEFAULT_VIRTUAL_HOST = "/" ;
5755
5856 private String host = DEFAULT_HOST ;
5957 private int port = DEFAULT_PORT ;
60- private CredentialsProvider credentialsProvider =
61- new DefaultUsernamePasswordCredentialsProvider (DEFAULT_USERNAME , DEFAULT_PASSWORD );
58+ private CredentialsProvider credentialsProvider ;
6259 private String virtualHost = DEFAULT_VIRTUAL_HOST ;
6360 private List <URI > uris = Collections .emptyList ();
6461 private Duration idleTimeout = Duration .ofMillis (ConnectionOptions .DEFAULT_IDLE_TIMEOUT );
@@ -173,14 +170,7 @@ public T saslMechanism(String mechanism) {
173170 SASL_MECHANISMS .stream ().map (n -> "'" + n + "'" ).collect (Collectors .joining (", " ))));
174171 }
175172 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 ;
184174 return this .toReturn ();
185175 }
186176
0 commit comments