Author: rajdavies
Date: Mon Feb 22 18:40:04 2010
New Revision: 915010
URL: http://svn.apache.org/viewvc?rev=915010&view=rev
Log:
removed topic test
Modified:
activemq/trunk/activemq-core/src/test/java/org/apache/activemq/bugs/AMQ2616Test.java
Modified: activemq/trunk/activemq-core/src/test/java/org/apache/activemq/bugs/AMQ2616Test.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/bugs/AMQ2616Test.java?rev=915010&r1=915009&r2=915010&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/test/java/org/apache/activemq/bugs/AMQ2616Test.java (original)
+++ activemq/trunk/activemq-core/src/test/java/org/apache/activemq/bugs/AMQ2616Test.java Mon
Feb 22 18:40:04 2010
@@ -25,7 +25,6 @@
import javax.jms.MessageProducer;
import javax.jms.Queue;
import javax.jms.Session;
-import javax.jms.Topic;
import junit.framework.TestCase;
import org.apache.activemq.ActiveMQConnectionFactory;
import org.apache.activemq.broker.BrokerService;
@@ -68,33 +67,7 @@
endUsage = brokerService.getSystemUsage().getMemoryUsage().getUsage();
assertEquals(startUsage,endUsage);
}
-
- public void testTopicResourcesReleased() throws Exception{
- ActiveMQConnectionFactory fac = new ActiveMQConnectionFactory(ACTIVEMQ_BROKER_BIND);
- Connection tempConnection = fac.createConnection();
- tempConnection.start();
- Session tempSession = tempConnection.createSession(false, Session.AUTO_ACKNOWLEDGE);
- Topic tempTopic = tempSession.createTemporaryTopic();
- final MessageConsumer tempConsumer = tempSession.createConsumer(tempTopic);
-
- Connection testConnection = fac.createConnection();
- long startUsage = brokerService.getSystemUsage().getMemoryUsage().getUsage();
- Session testSession = testConnection.createSession(false, Session.AUTO_ACKNOWLEDGE);
- MessageProducer testProducer = testSession.createProducer(tempTopic);
- byte[] payload = new byte[1024*4];
- for (int i = 0; i < NUMBER; i++ ) {
- BytesMessage msg = testSession.createBytesMessage();
- msg.writeBytes(payload);
- testProducer.send(msg);
- }
- long endUsage = brokerService.getSystemUsage().getMemoryUsage().getUsage();
- assertFalse(startUsage==endUsage);
- tempConnection.close();
- Thread.sleep(1000);
- endUsage = brokerService.getSystemUsage().getMemoryUsage().getUsage();
- assertEquals(startUsage,endUsage);
- }
-
+
@Override
protected void setUp() throws Exception {
|