Author: aidan
Date: Mon Jun 22 14:39:08 2009
New Revision: 787250
URL: http://svn.apache.org/viewvc?rev=787250&view=rev
Log:
QPID-1914: make send() transacted so we know the messages got there.
Modified:
qpid/trunk/qpid/java/systests/src/main/java/org/apache/qpid/test/client/QueueBrowserAutoAckTest.java
qpid/trunk/qpid/java/systests/src/main/java/org/apache/qpid/test/unit/ack/AcknowledgeTest.java
Modified:
qpid/trunk/qpid/java/systests/src/main/java/org/apache/qpid/test/client/QueueBrowserAutoAckTest.java
URL:
http://svn.apache.org/viewvc/qpid/trunk/qpid/java/systests/src/main/java/org/apache/qpid/test/client/QueueBrowserAutoAckTest.java?rev=787250&r1=787249&r2=787250&view=diff
==============================================================================
---
qpid/trunk/qpid/java/systests/src/main/java/org/apache/qpid/test/client/QueueBrowserAutoAckTest.java
(original)
+++
qpid/trunk/qpid/java/systests/src/main/java/org/apache/qpid/test/client/QueueBrowserAutoAckTest.java
Mon Jun 22 14:39:08 2009
@@ -116,7 +116,7 @@
{
producerConnection.start();
- Session producerSession = producerConnection.createSession(false,
Session.AUTO_ACKNOWLEDGE);
+ Session producerSession = producerConnection.createSession(true,
Session.AUTO_ACKNOWLEDGE);
//Ensure _queue is created
producerSession.createConsumer(_queue).close();
@@ -129,6 +129,7 @@
textMsg.setIntProperty(MESSAGE_ID_PROPERTY, messsageID);
producer.send(textMsg);
}
+ producerSession.commit();
producerConnection.close();
}
Modified:
qpid/trunk/qpid/java/systests/src/main/java/org/apache/qpid/test/unit/ack/AcknowledgeTest.java
URL:
http://svn.apache.org/viewvc/qpid/trunk/qpid/java/systests/src/main/java/org/apache/qpid/test/unit/ack/AcknowledgeTest.java?rev=787250&r1=787249&r2=787250&view=diff
==============================================================================
---
qpid/trunk/qpid/java/systests/src/main/java/org/apache/qpid/test/unit/ack/AcknowledgeTest.java
(original)
+++
qpid/trunk/qpid/java/systests/src/main/java/org/apache/qpid/test/unit/ack/AcknowledgeTest.java
Mon Jun 22 14:39:08 2009
@@ -57,22 +57,12 @@
}
private void init(boolean transacted, int mode) throws JMSException {
- _producerSession = _con.createSession(false,
Session.AUTO_ACKNOWLEDGE);
+ _producerSession = _con.createSession(true,
Session.AUTO_ACKNOWLEDGE);
_consumerSession = _con.createSession(transacted, mode);
_producer = _producerSession.createProducer(_queue);
_consumerA = _consumerSession.createConsumer(_queue);
}
-
-
- private void sendMessages(int totalMessages) throws JMSException
- {
- for (int i = 0; i < totalMessages; i++)
- {
- _producer.send(_producerSession.createTextMessage("message " + i));
- }
- }
-
/**
* Produces and consumes messages an either ack or commit the receipt of
those messages
*
@@ -83,10 +73,11 @@
private void testMessageAck(boolean transacted, int mode) throws Exception
{
init(transacted, mode);
- sendMessages(NUM_MESSAGES/2);
- Thread.sleep(1500);
+ sendMessage(_producerSession, _queue, NUM_MESSAGES/2);
+ _producerSession.commit();
MessageConsumer consumerB = _consumerSession.createConsumer(_queue);
- sendMessages(NUM_MESSAGES/2);
+ sendMessage(_producerSession, _queue, NUM_MESSAGES/2);
+ _producerSession.commit();
int count = 0;
Message msg = consumerB.receive(1500);
while (msg != null)
@@ -146,7 +137,8 @@
public void testIndividualAck() throws Exception
{
init(false, Session.CLIENT_ACKNOWLEDGE);
- sendMessages(3);
+ sendMessage(_producerSession, _queue, 3);
+ _producerSession.commit();
Message msg = null;
for (int i = 0; i < 2; i++)
{
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:[email protected]
