JAVA-613: Added support for host, port, and local port to JMX connection pool mbean

Author: jyemin

src/main/com/mongodb/DBPort.java

@@ -269,6 +269,10 @@ OutMessage getOutMessageBeingProcessed() {
         return _activeOutMessage;
     }
 
+    int getLocalPort() {
+        return _socket != null ? _socket.getLocalPort() : -1;
+    }
+
     /**
      * closes the underlying connection and streams
      */

src/main/com/mongodb/DBPortPool.java

@@ -40,16 +40,28 @@ public MongoConnection[] getInUseConnections() {
                 if (!_avail.contains(port)) {
                     OutMessage curOutMessage = port.getOutMessageBeingProcessed();
                     if (curOutMessage != null) {
-                        connectionList.add(new MongoConnection(curOutMessage.getNamespace(),
+                        connectionList.add(new MongoConnection(port.getLocalPort(), curOutMessage.getNamespace(),
                                 curOutMessage.getOpCode(),
                                 curOutMessage.getQuery() != null ? curOutMessage.getQuery().toString() : null));
+                    } else {
+                        connectionList.add(new MongoConnection(port.getLocalPort()));
                     }
                 }
             }
         }
         return connectionList.toArray(new MongoConnection[connectionList.size()]);
     }
 
+    @Override
+    public String getHost() {
+        return _addr.getHost();
+    }
+
+    @Override
+    public int getPort() {
+        return _addr.getPort();
+    }
+
     static class Holder {
 
         Holder( MongoOptions options ){

src/main/com/mongodb/MongoConnection.java

@@ -17,12 +17,17 @@
 
 public class MongoConnection {
 
-    public MongoConnection(final String namespace, final OutMessage.OpCode opCode, final String query) {
+    public MongoConnection(final int localPort, final String namespace, final OutMessage.OpCode opCode, final String query) {
+        this.localPort = localPort;
         this.namespace = namespace;
         this.opCode = opCode;
         this.query = query;
     }
 
+    public MongoConnection(final int localPort) {
+        this(localPort, null, null, null);
+    }
+
     public String getNamespace() {
         return namespace;
     }
@@ -35,8 +40,13 @@ public String getQuery() {
         return query;
     }
 
+    public int getLocalPort() {
+        return localPort;
+    }
+
+
     private final String namespace;
     private final OutMessage.OpCode opCode;
     private final String query;
-
+    private final int localPort;
 }

src/main/com/mongodb/MongoConnectionPoolMXBean.java

@@ -20,4 +20,6 @@
 
 public interface MongoConnectionPoolMXBean extends SimplePoolMXBean {
     public MongoConnection[] getInUseConnections();
+    public String getHost();
+    public int getPort();
 }