1 files changed, 5 insertions, 23 deletions
diff --git a/src/com/isode/stroke/network/JavaConnection.java b/src/com/isode/stroke/network/JavaConnection.java
index 745655f..c7464ba 100644
--- a/src/com/isode/stroke/network/JavaConnection.java
+++ b/src/com/isode/stroke/network/JavaConnection.java
@@ -9,6 +9,4 @@ import java.net.InetSocketAddress;
 import java.net.Socket;
-import java.net.SocketAddress;
 import java.nio.ByteBuffer;
 import java.nio.channels.CancelledKeyException;
-import java.nio.channels.ClosedChannelException;
 import java.nio.channels.ClosedSelectorException;
@@ -50,2 +48,6 @@ public class JavaConnection extends Connection implements EventOwner {
         }
+        
+        public HostAddressPort getRemoteAddress() {
+            return address_;
+        }
 
@@ -520,23 +522,3 @@ public class JavaConnection extends Connection implements EventOwner {
     public HostAddressPort getRemoteAddress() {
-        if (socketChannel_ == null) {
-            return null;
-        }
-        SocketAddress remoteAddress;
-        try {
-            remoteAddress = socketChannel_.getRemoteAddress();
-        } catch (ClosedChannelException e) {
-            return null;
-        } catch (IOException e) {
-            return null;
-        }
-        if (!(remoteAddress instanceof InetSocketAddress)) {
-            // SocketChannel.getRemoteAddress should return a
-            // InetSocketAddress if it is bound to an IP Socket
-            // Address so return null if it does not
-            return null;
-        }
-        InetSocketAddress remoteInetAddress = (InetSocketAddress) remoteAddress;
-        return new HostAddressPort(
-                new HostAddress(remoteInetAddress.getAddress()),
-                remoteInetAddress.getPort());
+        return worker_.getRemoteAddress();
     }