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