svn commit: r592388 - /incubator/qpid/branches/M2.1/java/systests/src/main/java/org/apache/qpid/server/txn/TxnTest.java

[ritchiem]

Author: ritchiem
Date: Tue Nov  6 03:40:13 2007
New Revision: 592388

URL: http://svn.apache.org/viewvc?rev=592388&view=rev
Log:
QPID-662 Transactional state not correctly reported after fail over. We now 
record if we have sent any messages
from here we can check if we have failed over and so have lost messages from 
the transaction making it invalid.

Modified:
    
incubator/qpid/branches/M2.1/java/systests/src/main/java/org/apache/qpid/server/txn/TxnTest.java

Modified: 
incubator/qpid/branches/M2.1/java/systests/src/main/java/org/apache/qpid/server/txn/TxnTest.java
URL: 
http://svn.apache.org/viewvc/incubator/qpid/branches/M2.1/java/systests/src/main/java/org/apache/qpid/server/txn/TxnTest.java?rev=592388&r1=592387&r2=592388&view=diff
==============================================================================
--- 
incubator/qpid/branches/M2.1/java/systests/src/main/java/org/apache/qpid/server/txn/TxnTest.java
 (original)
+++ 
incubator/qpid/branches/M2.1/java/systests/src/main/java/org/apache/qpid/server/txn/TxnTest.java
 Tue Nov  6 03:40:13 2007
@@ -351,6 +351,7 @@
         {
             txProducer.send(_clientSession.createTextMessage(MESSAGE_TXT));
             txProducer.send(_clientSession.createTextMessage(MESSAGE_TXT));
+            _clientSession.commit();
         }
         catch (JMSException jmse)
         {
@@ -360,6 +361,17 @@
             }
         }
 
+        received = _consumer.receive(10000);
+        assertNotNull("Message should be received.", received);
+        assertEquals("Incorrect Message Received.", MESSAGE_TXT, 
((TextMessage) received).getText());
+
+        received = _consumer.receive(10000);
+        assertNotNull("Message should be received.", received);
+        assertEquals("Incorrect Message Received.", MESSAGE_TXT, 
((TextMessage) received).getText());
+
+        //Check that the message isn't received.
+        received = _consumer.receive(1000);
+        assertNull("Additional message received", received);
 
         _consumer.close();
     }