This commit is contained in:
Martyn Taylor 2017-12-15 14:31:16 +00:00
commit dec9453f6d
1 changed files with 0 additions and 11 deletions

View File

@ -497,17 +497,6 @@ public class NettyConnection implements Connection {
//never allow this //never allow this
@Override @Override
public final ActiveMQPrincipal getDefaultActiveMQPrincipal() { 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; return null;
} }