You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ai...@apache.org on 2009/01/22 13:19:48 UTC
svn commit: r736618 -
/qpid/trunk/qpid/java/systests/src/main/java/org/apache/qpid/server/queue/TimeToLiveTest.java
Author: aidan
Date: Thu Jan 22 04:19:47 2009
New Revision: 736618
URL: http://svn.apache.org/viewvc?rev=736618&view=rev
Log:
QPID-1418: Destroy and recreate consumer once all messages are
sent so that they have enough time to expire.
Modified:
qpid/trunk/qpid/java/systests/src/main/java/org/apache/qpid/server/queue/TimeToLiveTest.java
Modified: qpid/trunk/qpid/java/systests/src/main/java/org/apache/qpid/server/queue/TimeToLiveTest.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/systests/src/main/java/org/apache/qpid/server/queue/TimeToLiveTest.java?rev=736618&r1=736617&r2=736618&view=diff
==============================================================================
--- qpid/trunk/qpid/java/systests/src/main/java/org/apache/qpid/server/queue/TimeToLiveTest.java (original)
+++ qpid/trunk/qpid/java/systests/src/main/java/org/apache/qpid/server/queue/TimeToLiveTest.java Thu Jan 22 04:19:47 2009
@@ -55,8 +55,13 @@
Session clientSession = clientConnection.createSession(false, Session.AUTO_ACKNOWLEDGE);
Queue queue = clientSession.createQueue(QUEUE);
-
+
+ // Create then close the consumer so the queue is actually created
+ // Closing it then reopening it ensures that the consumer shouldn't get messages
+ // which should have expired and allows a shorter sleep period. See QPID-1418
+
MessageConsumer consumer = clientSession.createConsumer(queue);
+ consumer.close();
//Create Producer
Connection producerConnection = getConnection();
@@ -82,10 +87,11 @@
producer.setTimeToLive(0L);
producer.send(nextMessage(String.valueOf(msg), false, producerSession, producer));
- try
+ consumer = clientSession.createConsumer(queue);
+ try
{
// Sleep to ensure TTL reached
- Thread.sleep(2000);
+ Thread.sleep(TIME_TO_LIVE);
}
catch (InterruptedException e)
{
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:commits-subscribe@qpid.apache.org