Author: clebert.suconic(a)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();