From 5afc874eed2e6d9a05fdb0f152a65becc3ed7f3a Mon Sep 17 00:00:00 2001
From: Juan Carlos Roig <juan@connio.com>
Date: Mon, 9 Jul 2018 12:20:45 +0200
Subject: [PATCH] Adds client remote address getter to ConnectionDescriptor
 class.

---
 .../io/moquette/server/ConnectionDescriptor.java | 16 +++++++++-------
 1 file changed, 9 insertions(+), 7 deletions(-)

diff --git a/broker/src/main/java/io/moquette/server/ConnectionDescriptor.java b/broker/src/main/java/io/moquette/server/ConnectionDescriptor.java
index a732d862..46d6f7c9 100644
--- a/broker/src/main/java/io/moquette/server/ConnectionDescriptor.java
+++ b/broker/src/main/java/io/moquette/server/ConnectionDescriptor.java
@@ -16,20 +16,18 @@
 
 package io.moquette.server;
 
-import java.util.NoSuchElementException;
-import java.util.concurrent.TimeUnit;
-import java.util.concurrent.atomic.AtomicReference;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-import io.moquette.server.netty.AutoFlushHandler;
 import io.moquette.server.netty.NettyUtils;
 import io.moquette.server.netty.metrics.BytesMetrics;
 import io.moquette.server.netty.metrics.BytesMetricsHandler;
 import io.moquette.server.netty.metrics.MessageMetrics;
 import io.moquette.server.netty.metrics.MessageMetricsHandler;
 import io.netty.channel.Channel;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import java.net.SocketAddress;
+import java.util.concurrent.atomic.AtomicReference;
 
-import static io.netty.channel.ChannelFutureListener.CLOSE;
 import static io.netty.channel.ChannelFutureListener.CLOSE_ON_FAILURE;
 import static io.netty.channel.ChannelFutureListener.FIRE_EXCEPTION_ON_FAILURE;
 
@@ -108,6 +106,10 @@ public class ConnectionDescriptor {
         return retval;
     }
 
+    public SocketAddress getRemoteAddress() {
+        return this.channel.remoteAddress();
+    }
+
     @Override
     public String toString() {
         return "ConnectionDescriptor{" + "clientID=" + clientID + ", removeTemporaryQoS2=" + cleanSession + ", state="