Permalink
Browse files

accidental commit

  • Loading branch information...
clebertsuconic committed Feb 13, 2011
1 parent 61d9c46 commit 0f3c06c868bfa3c1a2f33120da3920112bacae1d
View
@@ -1,7 +1,6 @@
<?xml version="1.0" encoding="UTF-8"?>
<classpath>
<classpathentry excluding="**/.svn/**/*" kind="src" path="src/main"/>
- <classpathentry kind="src" path="order-test"/>
<classpathentry kind="src" path="src/config/common"/>
<classpathentry kind="src" path="build/src"/>
<classpathentry kind="src" path="tests/jms-tests/config"/>
View
@@ -20,11 +20,4 @@
<nature>org.eclipse.jdt.core.javanature</nature>
<nature>net.sourceforge.metrics.nature</nature>
</natures>
- <linkedResources>
- <link>
- <name>order-test</name>
- <type>2</type>
- <location>/Users/clebertsuconic/Dropbox/HornetQ-Stuff/order-test</location>
- </link>
- </linkedResources>
</projectDescription>
@@ -98,68 +98,6 @@ public void testOutOfOrder() throws Exception
}
}
- public void testCancelationOrder() throws Exception
- {
- Connection conn = null;
- try
- {
- conn = JMSTestCase.cf.createConnection();
-
- Session sess = conn.createSession(true, Session.SESSION_TRANSACTED);
-
- Session sess2 = conn.createSession(true, Session.SESSION_TRANSACTED);
-
- MessageProducer prod = sess.createProducer(HornetQServerTestCase.queue1);
-
- MessageConsumer cons = sess2.createConsumer(HornetQServerTestCase.queue1);
-
- final int NUM_MESSAGES = 5;
-
- conn.start();
-
- for (int i = 0; i < NUM_MESSAGES; i++)
- {
- TextMessage tm = sess.createTextMessage("message" + i);
-
- prod.send(tm);
- }
- sess.commit();
-
- for (int i = 0 ; i < NUM_MESSAGES; i++)
- {
- TextMessage tm = (TextMessage)cons.receive(5000);
- assertNotNull(tm);
- assertEquals("message" + i, tm.getText());
- }
-
- cons.close();
-
- sess2.close();
-
-
- sess2 = conn.createSession(true, Session.SESSION_TRANSACTED);
-
- cons = sess2.createConsumer(queue1);
-
- for (int i = 0 ; i < NUM_MESSAGES; i++)
- {
- TextMessage tm = (TextMessage)cons.receive(5000);
- assertNotNull(tm);
- assertEquals("message" + i, tm.getText());
- }
-
- sess2.commit();
-
- }
- finally
- {
- if (conn != null)
- {
- conn.close();
- }
- }
- }
-
class MyListener implements MessageListener
{
private int c;
@@ -983,19 +983,6 @@ public void testMixtureLoadBalancedAndNonLoadBalancedQueuesWithConsumersWithFilt
verifyReceiveRoundRobinInSomeOrder(10, 23, 24, 25);
}
-
-
- /*public void testLoop() throws Exception
- {
- for (int i = 0 ; i < 1000; i++)
- {
- System.out.println("#test "+ i);
- Thread.sleep(1000);
- testRouteWhenNoConsumersTrueLoadBalancedQueues();
- tearDown();
- setUp();
- }
- }*/
public void testRouteWhenNoConsumersTrueLoadBalancedQueues() throws Exception
{

0 comments on commit 0f3c06c

Please sign in to comment.