diff --git a/activemq-stomp/src/main/java/org/apache/activemq/transport/stomp/StompNIOSSLTransport.java b/activemq-stomp/src/main/java/org/apache/activemq/transport/stomp/StompNIOSSLTransport.java index cb199aec40..d2e394b86e 100644 --- a/activemq-stomp/src/main/java/org/apache/activemq/transport/stomp/StompNIOSSLTransport.java +++ b/activemq-stomp/src/main/java/org/apache/activemq/transport/stomp/StompNIOSSLTransport.java @@ -49,13 +49,20 @@ public class StompNIOSSLTransport extends NIOSSLTransport { super(wireFormat, socket, null, null, null); } - - public StompNIOSSLTransport(WireFormat wireFormat, Socket socket, SSLEngine engine, InitBuffer initBuffer, ByteBuffer inputBuffer) throws IOException { super(wireFormat, socket, engine, initBuffer, inputBuffer); } + @Override + public String getRemoteAddress() { + String remoteAddress = super.getRemoteAddress(); + if (remoteAddress == null) { + return remoteLocation.toString(); + } + return remoteAddress; + } + @Override protected void initializeStreams() throws IOException { codec = new StompCodec(this);