[hornetq-commits] JBoss hornetq SVN: r9353 - trunk/tests/jms-tests/src/org/hornetq/jms/tests/selector.

[do-not-reply at jboss.org]

Author: clebert.suconic at jboss.com
Date: 2010-06-22 15:56:19 -0400 (Tue, 22 Jun 2010)
New Revision: 9353

Modified:
   trunk/tests/jms-tests/src/org/hornetq/jms/tests/selector/SelectorTest.java
Log:
Adding test to investigate a customer / user issue

Modified: trunk/tests/jms-tests/src/org/hornetq/jms/tests/selector/SelectorTest.java
===================================================================
--- trunk/tests/jms-tests/src/org/hornetq/jms/tests/selector/SelectorTest.java	2010-06-22 19:53:54 UTC (rev 9352)
+++ trunk/tests/jms-tests/src/org/hornetq/jms/tests/selector/SelectorTest.java	2010-06-22 19:56:19 UTC (rev 9353)
@@ -19,6 +19,7 @@
 import java.util.concurrent.CountDownLatch;
 
 import javax.jms.Connection;
+import javax.jms.ConnectionFactory;
 import javax.jms.DeliveryMode;
 import javax.jms.Message;
 import javax.jms.MessageConsumer;
@@ -26,6 +27,7 @@
 import javax.jms.Session;
 import javax.jms.TextMessage;
 
+import org.hornetq.jms.client.HornetQConnectionFactory;
 import org.hornetq.jms.tests.HornetQServerTestCase;
 import org.hornetq.jms.tests.util.ProxyAssertSupport;
 
@@ -937,14 +939,19 @@
   
    // Test case proposed by a customer on this user forum:
    // http://community.jboss.org/thread/153426?tstart=0
-   public void under_investigation_testMultipleConsumers() throws Exception
+   public void testMultipleConsumers() throws Exception
    {
       Connection conn = null;
 
       try
       {
-         conn = getConnectionFactory().createConnection();
+         ConnectionFactory factory = getConnectionFactory();
+         HornetQConnectionFactory hcf = (HornetQConnectionFactory) factory;
          
+         hcf.setConsumerWindowSize(0);
+         
+         conn = hcf.createConnection();
+         
          conn.setClientID("SomeClientID");
 
          conn.start();