activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chir...@apache.org
Subject svn commit: r560294 - /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/util/MessageIdList.java
Date Fri, 27 Jul 2007 16:02:05 GMT
Author: chirino
Date: Fri Jul 27 09:02:04 2007
New Revision: 560294

URL: http://svn.apache.org/viewvc?view=rev&rev=560294
Log:
Added a handy processingDelay option to the MessageIdList so that a test case and simulate
a slow consumer

Modified:
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/util/MessageIdList.java

Modified: activemq/trunk/activemq-core/src/test/java/org/apache/activemq/util/MessageIdList.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/util/MessageIdList.java?view=diff&rev=560294&r1=560293&r2=560294
==============================================================================
--- activemq/trunk/activemq-core/src/test/java/org/apache/activemq/util/MessageIdList.java
(original)
+++ activemq/trunk/activemq-core/src/test/java/org/apache/activemq/util/MessageIdList.java
Fri Jul 27 09:02:04 2007
@@ -51,7 +51,8 @@
     private boolean verbose;
     private MessageListener parent;
     private long maximumDuration = 15000L;
-
+    private long processingDelay=0;
+    
 	private CountDownLatch countDownLatch;
 
     public MessageIdList() {
@@ -119,6 +120,12 @@
         if (parent != null) {
             parent.onMessage(message);
         }
+        if( processingDelay > 0 ) {
+        	try {
+				Thread.sleep(processingDelay);
+			} catch (InterruptedException e) {
+			}
+        }
     }
 
     public int getMessageCount() {
@@ -239,6 +246,26 @@
 
 	public void setCountDownLatch(CountDownLatch countDownLatch) {
 		this.countDownLatch = countDownLatch;
+	}
+
+	/**
+	 * Gets the amount of time the message listener will spend sleeping to
+	 * simulate a processing delay.
+	 * 
+	 * @return
+	 */
+	public long getProcessingDelay() {
+		return processingDelay;
+	}
+
+	/**
+	 * Sets the amount of time the message listener will spend sleeping to
+	 * simulate a processing delay.
+	 * 
+	 * @param processingDelay
+	 */
+	public void setProcessingDelay(long processingDelay) {
+		this.processingDelay = processingDelay;
 	}
 
 }



Mime
View raw message