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()