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 2010/11/29 09:55:53 UTC
svn commit: r1040040 -
/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/DefaultChannel.java
Author: davsclaus
Date: Mon Nov 29 08:55:53 2010
New Revision: 1040040
URL: http://svn.apache.org/viewvc?rev=1040040&view=rev
Log:
CAMEL-3266: InterceptStrategy is now ordered in the order they are added. Use Ordered interface to control the exact order.
Modified:
camel/trunk/camel-core/src/main/java/org/apache/camel/processor/DefaultChannel.java
Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/processor/DefaultChannel.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/DefaultChannel.java?rev=1040040&r1=1040039&r2=1040040&view=diff
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/processor/DefaultChannel.java (original)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/processor/DefaultChannel.java Mon Nov 29 08:55:53 2010
@@ -141,7 +141,6 @@ public class DefaultChannel extends Serv
}
@Override
- @SuppressWarnings("unchecked")
protected void doStart() throws Exception {
ServiceHelper.startServices(errorHandler, output);
}
@@ -151,6 +150,7 @@ public class DefaultChannel extends Serv
ServiceHelper.stopServices(output, errorHandler);
}
+ @SuppressWarnings("unchecked")
public void initChannel(ProcessorDefinition<?> outputDefinition, RouteContext routeContext) throws Exception {
this.routeContext = routeContext;
this.definition = outputDefinition;
@@ -176,7 +176,7 @@ public class DefaultChannel extends Serv
// sort interceptors according to ordered
Collections.sort(interceptors, new OrderedComparator());
- // then reverse list so the first will be wrapped last, as it would then be first being invoced
+ // then reverse list so the first will be wrapped last, as it would then be first being invoked
Collections.reverse(interceptors);
// wrap the output with the configured interceptors
for (InterceptStrategy strategy : interceptors) {