|
@@ -213,11 +213,15 @@ class VertxMqttConnection implements MqttConnection {
|
|
|
|
|
|
@Override
|
|
@Override
|
|
public InetSocketAddress getClientAddress() {
|
|
public InetSocketAddress getClientAddress() {
|
|
- if (clientAddress == null) {
|
|
|
|
- SocketAddress address = endpoint.remoteAddress();
|
|
|
|
- if (address != null) {
|
|
|
|
- clientAddress = new InetSocketAddress(address.host(), address.port());
|
|
|
|
|
|
+ try {
|
|
|
|
+ if (clientAddress == null && endpoint != null) {
|
|
|
|
+ SocketAddress address = endpoint.remoteAddress();
|
|
|
|
+ if (address != null) {
|
|
|
|
+ clientAddress = new InetSocketAddress(address.host(), address.port());
|
|
|
|
+ }
|
|
}
|
|
}
|
|
|
|
+ }catch (Throwable ignore){
|
|
|
|
+
|
|
}
|
|
}
|
|
return clientAddress;
|
|
return clientAddress;
|
|
}
|
|
}
|