[hornetq-commits] JBoss hornetq SVN: r10316 - branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/integration.

[do-not-reply at jboss.org]

Author: clebert.suconic at jboss.com
Date: 2011-03-10 15:55:26 -0500 (Thu, 10 Mar 2011)
New Revision: 10316

Modified:
   branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/integration/DuplicateDetectionTest.java
Log:
https://issues.jboss.org/browse/JBPAPP-6080 - Adding test

Modified: branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/integration/DuplicateDetectionTest.java
===================================================================
--- branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/integration/DuplicateDetectionTest.java	2011-03-10 20:35:19 UTC (rev 10315)
+++ branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/integration/DuplicateDetectionTest.java	2011-03-10 20:55:26 UTC (rev 10316)
@@ -528,15 +528,23 @@
       session.start();
 
       final SimpleString queueName = new SimpleString("DuplicateDetectionTestQueue");
+      
+      final SimpleString queue2 = new SimpleString("queue2");
 
       session.createQueue(queueName, queueName, null, false);
 
+      session.createQueue(queue2, queue2, null, false);
+
       ClientProducer producer = session.createProducer(queueName);
 
       ClientMessage message = createMessage(session, 0);
       SimpleString dupID = new SimpleString("abcdefg");
       message.putBytesProperty(Message.HDR_DUPLICATE_DETECTION_ID, dupID.getData());
       producer.send(message);
+      
+      ClientMessage message2 = createMessage(session,0);
+      ClientProducer producer2 = session.createProducer(queue2);
+      producer2.send(message2);
 
       session.commit();
 
@@ -545,6 +553,8 @@
       session = sf.createSession(false, false, false);
 
       session.start();
+      
+      ClientConsumer consumer2 = session.createConsumer(queue2);
 
       producer = session.createProducer(queueName);
 
@@ -560,6 +570,11 @@
 
       message = createMessage(session, 4);
       producer.send(message);
+      
+      message = consumer2.receive(5000);
+      assertNotNull(message);
+      message.acknowledge();
+      
 
       try
       {
@@ -578,6 +593,14 @@
 
       message = consumer.receiveImmediate();
       Assert.assertNull(message);
+      
+      
+      message = consumer2.receive(5000);
+      assertNotNull(message);
+      
+      message.acknowledge();
+      
+      session.commit();
 
       session.close();