activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject svn commit: r1451323 - /activemq/trunk/activemq-stomp/src/test/java/org/apache/activemq/transport/stomp/StompTest.java
Date Thu, 28 Feb 2013 20:08:57 GMT
Author: tabish
Date: Thu Feb 28 20:08:57 2013
New Revision: 1451323

URL: http://svn.apache.org/r1451323
Log:
Older Windows machine have a slow clock tick interval so make sure the message immediately
expires.  In case it still doesn't make it wait long enough for the next sweep to remove expired
messages from the Queue. 

Modified:
    activemq/trunk/activemq-stomp/src/test/java/org/apache/activemq/transport/stomp/StompTest.java

Modified: activemq/trunk/activemq-stomp/src/test/java/org/apache/activemq/transport/stomp/StompTest.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-stomp/src/test/java/org/apache/activemq/transport/stomp/StompTest.java?rev=1451323&r1=1451322&r2=1451323&view=diff
==============================================================================
--- activemq/trunk/activemq-stomp/src/test/java/org/apache/activemq/transport/stomp/StompTest.java
(original)
+++ activemq/trunk/activemq-stomp/src/test/java/org/apache/activemq/transport/stomp/StompTest.java
Thu Feb 28 20:08:57 2013
@@ -1854,14 +1854,14 @@ public class StompTest extends StompTest
         stompConnection.connect("system", "manager");
 
         HashMap<String, String> headers = new HashMap<String, String>();
-        long timestamp = System.currentTimeMillis();
+        long timestamp = System.currentTimeMillis() - 100;
         headers.put(Stomp.Headers.Message.EXPIRATION_TIME, String.valueOf(timestamp));
         headers.put(Stomp.Headers.Send.PERSISTENT, "true");
 
         stompConnection.send("/queue/" + getQueueName(), "msg", null, headers);
 
         stompConnection.subscribe("/queue/ActiveMQ.DLQ");
-        StompFrame stompMessage = stompConnection.receive(10000);
+        StompFrame stompMessage = stompConnection.receive(35000);
         assertNotNull(stompMessage);
         assertEquals(stompMessage.getHeaders().get(Stomp.Headers.Message.ORIGINAL_DESTINATION),
"/queue/" + getQueueName());
     }



Mime
View raw message