You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2008/09/18 11:17:13 UTC
svn commit: r696611 -
/activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/interceptor/Delayer.java
Author: davsclaus
Date: Thu Sep 18 02:17:13 2008
New Revision: 696611
URL: http://svn.apache.org/viewvc?rev=696611&view=rev
Log:
CAMEL-640: Added Delayer (interceptor) to slow processing of messages down so you can watch what happens nice and slowly.
Modified:
activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/interceptor/Delayer.java (contents, props changed)
Modified: activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/interceptor/Delayer.java
URL: http://svn.apache.org/viewvc/activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/interceptor/Delayer.java?rev=696611&r1=696610&r2=696611&view=diff
==============================================================================
--- activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/interceptor/Delayer.java (original)
+++ activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/interceptor/Delayer.java Thu Sep 18 02:17:13 2008
@@ -1,66 +1,66 @@
-package org.apache.camel.processor.interceptor;
-
-import java.util.List;
-
-import org.apache.camel.spi.InterceptStrategy;
-import org.apache.camel.CamelContext;
-import org.apache.camel.Processor;
-import org.apache.camel.model.ProcessorType;
-import org.apache.camel.impl.DefaultCamelContext;
-
-/**
- * An interceptor strategy for delaying routes.
- */
-public class Delayer implements InterceptStrategy {
-
- private boolean enabled = true;
- private long delay;
-
- public Delayer() {
- }
-
- public Delayer(long delay) {
- this.delay = delay;
- }
-
- /**
- * A helper method to return the Delayer instance for a given {@link org.apache.camel.CamelContext} if one is enabled
- *
- * @param context the camel context the delayer is connected to
- * @return the delayer or null if none can be found
- */
- public static DelayInterceptor getDelayer(CamelContext context) {
- if (context instanceof DefaultCamelContext) {
- DefaultCamelContext defaultCamelContext = (DefaultCamelContext) context;
- List<InterceptStrategy> list = defaultCamelContext.getInterceptStrategies();
- for (InterceptStrategy interceptStrategy : list) {
- if (interceptStrategy instanceof DelayInterceptor) {
- return (DelayInterceptor)interceptStrategy;
- }
- }
- }
- return null;
- }
-
- public Processor wrapProcessorInInterceptors(ProcessorType processorType, Processor target)
- throws Exception {
- DelayInterceptor delayer = new DelayInterceptor(processorType, target, this);
- return delayer;
- }
-
- public boolean isEnabled() {
- return enabled;
- }
-
- public void setEnabled(boolean enabled) {
- this.enabled = enabled;
- }
-
- public long getDelay() {
- return delay;
- }
-
- public void setDelay(long delay) {
- this.delay = delay;
- }
-}
+package org.apache.camel.processor.interceptor;
+
+import java.util.List;
+
+import org.apache.camel.spi.InterceptStrategy;
+import org.apache.camel.CamelContext;
+import org.apache.camel.Processor;
+import org.apache.camel.model.ProcessorType;
+import org.apache.camel.impl.DefaultCamelContext;
+
+/**
+ * An interceptor strategy for delaying routes.
+ */
+public class Delayer implements InterceptStrategy {
+
+ private boolean enabled = true;
+ private long delay;
+
+ public Delayer() {
+ }
+
+ public Delayer(long delay) {
+ this.delay = delay;
+ }
+
+ /**
+ * A helper method to return the Delayer instance for a given {@link org.apache.camel.CamelContext} if one is enabled
+ *
+ * @param context the camel context the delayer is connected to
+ * @return the delayer or null if none can be found
+ */
+ public static DelayInterceptor getDelayer(CamelContext context) {
+ if (context instanceof DefaultCamelContext) {
+ DefaultCamelContext defaultCamelContext = (DefaultCamelContext) context;
+ List<InterceptStrategy> list = defaultCamelContext.getInterceptStrategies();
+ for (InterceptStrategy interceptStrategy : list) {
+ if (interceptStrategy instanceof DelayInterceptor) {
+ return (DelayInterceptor)interceptStrategy;
+ }
+ }
+ }
+ return null;
+ }
+
+ public Processor wrapProcessorInInterceptors(ProcessorType processorType, Processor target)
+ throws Exception {
+ DelayInterceptor delayer = new DelayInterceptor(processorType, target, this);
+ return delayer;
+ }
+
+ public boolean isEnabled() {
+ return enabled;
+ }
+
+ public void setEnabled(boolean enabled) {
+ this.enabled = enabled;
+ }
+
+ public long getDelay() {
+ return delay;
+ }
+
+ public void setDelay(long delay) {
+ this.delay = delay;
+ }
+}
Propchange: activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/interceptor/Delayer.java
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/interceptor/Delayer.java
------------------------------------------------------------------------------
svn:keywords = Rev Date