diff --git a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/remoting/impl/netty/NettyConnection.java b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/remoting/impl/netty/NettyConnection.java index 601bbfc884..a73983d7ac 100644 --- a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/remoting/impl/netty/NettyConnection.java +++ b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/remoting/impl/netty/NettyConnection.java @@ -497,17 +497,6 @@ public class NettyConnection implements Connection { //never allow this @Override public final ActiveMQPrincipal getDefaultActiveMQPrincipal() { - ChannelHandler channelHandler = channel.pipeline().get("ssl"); - if (channelHandler != null && channelHandler instanceof SslHandler) { - SslHandler sslHandler = (SslHandler) channelHandler; - try { - return new ActiveMQPrincipal(sslHandler.engine().getSession().getPeerPrincipal().getName(), ""); - } catch (SSLPeerUnverifiedException ignored) { - if (logger.isTraceEnabled()) { - logger.trace(ignored.getMessage(), ignored); - } - } - } return null; }