svn commit: r560294 - /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/util/MessageIdList.java

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

svn commit: r560294 - /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/util/MessageIdList.java

chirino-2
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;
  }
 
 }