You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by bh...@apache.org on 2006/12/19 16:09:51 UTC

svn commit: r488701 - in /incubator/qpid/trunk/qpid/java: broker/src/main/java/org/apache/qpid/server/protocol/AMQMinaProtocolSession.java systests/src/test/java/org/apache/qpid/server/protocol/MockIoSession.java

Author: bhupendrab
Date: Tue Dec 19 07:09:50 2006
New Revision: 488701

URL: http://svn.apache.org/viewvc?view=rev&rev=488701
Log:
QPID-188 
Adding unit tests for Java broker JMX functionality

Modified:
    incubator/qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQMinaProtocolSession.java
    incubator/qpid/trunk/qpid/java/systests/src/test/java/org/apache/qpid/server/protocol/MockIoSession.java

Modified: incubator/qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQMinaProtocolSession.java
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQMinaProtocolSession.java?view=diff&rev=488701&r1=488700&r2=488701
==============================================================================
--- incubator/qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQMinaProtocolSession.java (original)
+++ incubator/qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQMinaProtocolSession.java Tue Dec 19 07:09:50 2006
@@ -412,6 +412,7 @@
         {
             channel.close(this);
         }
+        _channelMap.clear();
     }
 
     /**

Modified: incubator/qpid/trunk/qpid/java/systests/src/test/java/org/apache/qpid/server/protocol/MockIoSession.java
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/systests/src/test/java/org/apache/qpid/server/protocol/MockIoSession.java?view=diff&rev=488701&r1=488700&r2=488701
==============================================================================
--- incubator/qpid/trunk/qpid/java/systests/src/test/java/org/apache/qpid/server/protocol/MockIoSession.java (original)
+++ incubator/qpid/trunk/qpid/java/systests/src/test/java/org/apache/qpid/server/protocol/MockIoSession.java Tue Dec 19 07:09:50 2006
@@ -25,6 +25,7 @@
 import org.apache.mina.common.support.DefaultWriteFuture;
 
 import java.net.SocketAddress;
+import java.net.InetSocketAddress;
 import java.util.Set;
 
 public class MockIoSession implements IoSession
@@ -151,7 +152,7 @@
 
     public SocketAddress getRemoteAddress()
     {
-        return null;  //To change body of implemented methods use File | Settings | File Templates.
+        return new InetSocketAddress("127.0.0.1", 1234);  //To change body of implemented methods use File | Settings | File Templates.
     }
 
     public SocketAddress getLocalAddress()