Use extenral sasl and configure rabbitmq with it

Author: MarcialRosales

selenium/amqp10-roundtriptest/src/main/java/com/rabbitmq/amqp1_0/RoundTripTest.java

@@ -26,9 +26,10 @@ public static void main(String args[]) throws Exception {
     String hostname = getEnv("RABBITMQ_HOSTNAME", "localhost");
     String port = getEnv("RABBITMQ_AMQP_PORT", "5672");
     String scheme = getEnv("RABBITMQ_AMQP_SCHEME", "amqp");
+    String uri = scheme + "://" + hostname + ":" + port;
     String username = args.length > 0 ? args[0] : getEnv("RABBITMQ_AMQP_USERNAME", "guest");
     String password = args.length > 1 ? args[1] : getEnv("RABBITMQ_AMQP_PASSWORD", "guest");
-    String uri = scheme + "://" + hostname + ":" + port;
+    
     boolean usemtls = Boolean.parseBoolean(getEnv("AMQP_USE_MTLS", "false"));
     String certsLocation = getEnv("RABBITMQ_CERTS");
 
@@ -41,6 +42,7 @@ public static void main(String args[]) throws Exception {
       connectionParams.add("transport.trustAll=true");    
 
       if (usemtls) {
+        connectionParams.add("amqp.saslMechanisms=EXTERNAL");
         connectionParams.add("transport.keyStoreLocation=" + certsLocation + "/client_rabbitmq.jks");
         connectionParams.add("transport.keyStorePassword=foobar");
         connectionParams.add("transport.keyAlias=client-rabbitmq-tls");
@@ -64,7 +66,8 @@ public static void main(String args[]) throws Exception {
     ConnectionFactory factory = (ConnectionFactory) context.lookup("myFactoryLookup");
     Destination queue = (Destination) context.lookup("myQueueLookup");
 
-    try (Connection connection = factory.createConnection(username, password)) {
+    try (Connection connection = 
+                      createConnection(factory, usemtls, username, password)) {
       connection.start();
 
       Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
@@ -82,5 +85,12 @@ public static void main(String args[]) throws Exception {
 
       assertEquals(message.getText(), receivedMessage.getText());
     }
+  }  
+  private static Connection createConnection(ConnectionFactory factory, 
+      boolean usemtls, String username, String password) throws jakarta.jms.JMSException {
+    if (usemtls) {
+      return factory.createConnection();      
+    }
+    return factory.createConnection(username, password);
   }
 }

selenium/test/authnz-msg-protocols/rabbitmq.auth-mtls.conf

@@ -1,4 +1,6 @@
 
+auth_mechanisms.1 = EXTERNAL
+
 ssl_cert_login_from = subject_alternative_name
 ssl_cert_login_san_type = dns 
 ssl_cert_login_san_index = 1