1 files changed, 92 insertions, 6 deletions

diff --git a/qpid/java/systests/src/main/java/org/apache/qpid/client/SimpleConnectionTest.java b/qpid/java/systests/src/main/java/org/apache/qpid/client/SimpleConnectionTest.java
index 0c432eba6f..bbdf994d2f 100644
--- a/qpid/java/systests/src/main/java/org/apache/qpid/client/SimpleConnectionTest.java
+++ b/qpid/java/systests/src/main/java/org/apache/qpid/client/SimpleConnectionTest.java
@@ -28,21 +28,43 @@ import javax.jms.*;
 
 public class SimpleConnectionTest extends TestCase
 {
-    public void testConnection()
+/*    public void testConnection()
     {
         try
         {
             AMQConnection conn = new AMQConnection("127.0.0.1", 5673, "guest", "guest", "test", "/test");
+
+
             QueueSession s = conn.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
             QueueSender p = s.createSender(new AMQQueue("amq.direct", "queue"));
-            p.send(s.createTextMessage("test"));
+            for(int i = 0; i < 6000; i++)
+            {
+                p.send(s.createTextMessage("test("+i+")"));
+            }
 
             QueueReceiver r = s.createReceiver(new AMQQueue("amq.direct", "queue"));
             conn.start();
-            Message m = r.receive();
-
-            Thread.sleep(60000L);
+            Thread.sleep(1000L);
+            for(int i = 0; i < 3000; i++)
+            {
+                Message m = r.receive();
+            }
             conn.close();
+
+            conn = new AMQConnection("127.0.0.1", 5673, "guest", "guest", "test", "/test");
+            s = conn.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
+            r = s.createReceiver(new AMQQueue("amq.direct", "queue"));
+            conn.start();
+            Message m;
+            int rcvCnt = 0;
+            while((m = r.receive(1000))!= null)
+            {
+                rcvCnt++;
+            }
+            System.out.print(rcvCnt);
+
+            Thread.sleep(60000l);
+
         }
         catch (AMQException e)
         {
@@ -61,4 +83,68 @@ public class SimpleConnectionTest extends TestCase
             e.printStackTrace();  //To change body of catch statement use File | Settings | File Templates.
         }
     }
-}
+
+
+    public void testConnection2()
+    {
+        try
+        {
+            AMQConnection conn = new AMQConnection("127.0.0.1", 5673, "guest", "guest", "test", "/test");
+            AMQConnection conn2 = new AMQConnection("127.0.0.1", 5673, "guest", "guest", "test", "/test");
+
+            AMQQueue amqQueue = new AMQQueue("amq.direct", "queue");
+
+            QueueSession s = conn.createQueueSession(true, Session.SESSION_TRANSACTED);
+            QueueSender p = s.createSender(amqQueue);
+
+            QueueSession s2 = conn2.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
+            QueueReceiver r2 = s2.createReceiver(amqQueue);
+            r2.setMessageListener(new MessageListener()
+            {
+
+                public void onMessage(Message message)
+                {
+                    try
+                    {
+                        System.out.println("***************************************************************************");
+                        System.out.println("***************************************************************************");
+                        System.out.println("**  " +((TextMessage)message).getText());
+                        System.out.println("***************************************************************************");
+                        System.out.println("***************************************************************************");
+                    }
+                    catch (JMSException e)
+                    {
+                        e.printStackTrace();  //To change body of catch statement use File | Settings | File Templates.
+                    }
+                }
+            });
+            conn2.start();
+
+            for(int i = 0; i < 6000; i++)
+            {
+                p.send(s.createTextMessage("test("+i+")"));
+                if(i%10 == 0)
+                {   Thread.sleep(5000);
+                    s.commit();
+
+                }
+            }
+        }
+        catch (JMSException e)
+        {
+            e.printStackTrace();  //To change body of catch statement use File | Settings | File Templates.
+        }
+        catch (URLSyntaxException e)
+        {
+            e.printStackTrace();  //To change body of catch statement use File | Settings | File Templates.
+        }
+        catch (AMQException e)
+        {
+            e.printStackTrace();  //To change body of catch statement use File | Settings | File Templates.
+        }
+        catch (InterruptedException e)
+        {
+            e.printStackTrace();  //To change body of catch statement use File | Settings | File Templates.
+        }
+    }
+*/}