diff --git a/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/JMSClientSimpleAuthTest.java b/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/JMSClientSimpleAuthTest.java index 064e132a8f..2f559e6b7c 100644 --- a/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/JMSClientSimpleAuthTest.java +++ b/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/JMSClientSimpleAuthTest.java @@ -25,6 +25,7 @@ import java.net.URI; import javax.jms.Connection; import javax.jms.JMSException; +import javax.jms.JMSSecurityException; import javax.jms.Message; import javax.jms.MessageConsumer; import javax.jms.MessageProducer; @@ -71,6 +72,8 @@ public class JMSClientSimpleAuthTest { Thread.sleep(500); connection.createSession(false, Session.AUTO_ACKNOWLEDGE); fail("Expected JMSException"); + } catch (JMSSecurityException ex) { + LOG.debug("Failed to authenticate connection with no user / password."); } catch (JMSException e) { Exception linkedException = e.getLinkedException(); if (linkedException != null && linkedException instanceof ConnectionClosedException) { @@ -91,6 +94,8 @@ public class JMSClientSimpleAuthTest { Thread.sleep(500); connection.createSession(false, Session.AUTO_ACKNOWLEDGE); fail("Expected JMSException"); + } catch (JMSSecurityException ex) { + LOG.debug("Failed to authenticate connection with no user / password."); } catch (JMSException e) { Exception linkedException = e.getLinkedException(); if (linkedException != null && linkedException instanceof ConnectionClosedException) { @@ -111,6 +116,8 @@ public class JMSClientSimpleAuthTest { Thread.sleep(500); connection.createSession(false, Session.AUTO_ACKNOWLEDGE); fail("Expected JMSException"); + } catch (JMSSecurityException ex) { + LOG.debug("Failed to authenticate connection with no user / password."); } catch (JMSException e) { Exception linkedException = e.getLinkedException(); if (linkedException != null && linkedException instanceof ConnectionClosedException) {