[hornetq-commits] JBoss hornetq SVN: r8958 - in trunk: tests/src/org/hornetq/tests/integration/client and 1 other directory.

[do-not-reply at jboss.org]

Author: timfox
Date: 2010-03-24 11:46:47 -0400 (Wed, 24 Mar 2010)
New Revision: 8958

Modified:
   trunk/src/config/common/hornetq-version.properties
   trunk/tests/src/org/hornetq/tests/integration/client/ProducerFlowControlTest.java
Log:
updated version

Modified: trunk/src/config/common/hornetq-version.properties
===================================================================
--- trunk/src/config/common/hornetq-version.properties	2010-03-24 14:56:20 UTC (rev 8957)
+++ trunk/src/config/common/hornetq-version.properties	2010-03-24 15:46:47 UTC (rev 8958)
@@ -1,8 +1,8 @@
-hornetq.version.versionName=Hornet Queen
+hornetq.version.versionName=Horny Hornet
 hornetq.version.majorVersion=2
-hornetq.version.minorVersion=0
+hornetq.version.minorVersion=1
 hornetq.version.microVersion=0
-hornetq.version.incrementingVersion=113
-hornetq.version.versionSuffix=GA
-hornetq.version.versionTag=GA
+hornetq.version.incrementingVersion=114
+hornetq.version.versionSuffix=CR1
+hornetq.version.versionTag=CR1
 hornetq.netty.version=@NETTY.VERSION@

Modified: trunk/tests/src/org/hornetq/tests/integration/client/ProducerFlowControlTest.java
===================================================================
--- trunk/tests/src/org/hornetq/tests/integration/client/ProducerFlowControlTest.java	2010-03-24 14:56:20 UTC (rev 8957)
+++ trunk/tests/src/org/hornetq/tests/integration/client/ProducerFlowControlTest.java	2010-03-24 15:46:47 UTC (rev 8958)
@@ -21,11 +21,13 @@
 import junit.framework.Assert;
 
 import org.hornetq.api.core.SimpleString;
+import org.hornetq.api.core.TransportConfiguration;
 import org.hornetq.api.core.client.ClientConsumer;
 import org.hornetq.api.core.client.ClientMessage;
 import org.hornetq.api.core.client.ClientProducer;
 import org.hornetq.api.core.client.ClientSession;
 import org.hornetq.api.core.client.ClientSessionFactory;
+import org.hornetq.api.core.client.HornetQClient;
 import org.hornetq.api.core.client.MessageHandler;
 import org.hornetq.core.client.impl.ClientProducerCreditManagerImpl;
 import org.hornetq.core.client.impl.ClientProducerCredits;
@@ -36,6 +38,7 @@
 import org.hornetq.core.settings.HierarchicalRepository;
 import org.hornetq.core.settings.impl.AddressFullMessagePolicy;
 import org.hornetq.core.settings.impl.AddressSettings;
+import org.hornetq.integration.transports.netty.NettyConnectorFactory;
 import org.hornetq.tests.util.RandomUtil;
 import org.hornetq.tests.util.ServiceTestBase;
 import org.hornetq.tests.util.UnitTestCase;
@@ -658,6 +661,76 @@
       server.stop();
    }
 
+   public void testBlockingIssue() throws Exception
+   {
+      // HornetQServer server = createServer(true, true);
+      //
+      // AddressSettings addressSettings = new AddressSettings();
+      // addressSettings.setMaxSizeBytes(300000);
+      // addressSettings.setAddressFullMessagePolicy(AddressFullMessagePolicy.BLOCK);
+      //
+      // HierarchicalRepository<AddressSettings> repos = server.getAddressSettingsRepository();
+      // repos.addMatch("bar".toString(), addressSettings);
+      //      
+      // server.start();
+
+      // ClientSessionFactory sf = createFactory(true);
+
+      TransportConfiguration tc = new TransportConfiguration(NettyConnectorFactory.class.getName());
+
+      ClientSessionFactory sf = HornetQClient.createClientSessionFactory(tc);
+
+//      ClientSession sess = sf.createSession();
+//
+//      sess.createQueue("bar", "bar");
+
+      int count = 0;
+      while (true)
+      {
+         log.info("*** ITERATION " + count++ + "\n\n\n\n");
+         ClientSession session = sf.createTransactedSession();
+
+         ClientProducer producer = session.createProducer("bar");
+
+         for (int i = 0; i < 1000; i++)
+         {
+
+            ClientMessage message = session.createMessage(true);
+
+            message.getBodyBuffer().writeString("Hello");
+
+            producer.send(message);
+
+            // log.info("sent " + i);
+
+         }
+
+         session.commit();
+
+         session.close();
+
+         session = sf.createSession();
+
+         session.start();
+
+         ClientConsumer consumer = session.createConsumer("bar");
+
+         for (int i = 0; i < 1000; i++)
+         {
+
+            ClientMessage msgReceived = consumer.receive();
+
+            msgReceived.acknowledge();
+
+            // log.info("read " + i);
+
+         }
+
+         session.close();
+
+      }
+   }
+
    public void testProducerCreditsCaching5() throws Exception
    {
       HornetQServer server = createServer(false, isNetty());