camel-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From davscl...@apache.org
Subject svn commit: r754824 - in /camel/trunk/camel-core/src/main/java/org/apache/camel: impl/ processor/ processor/exceptionpolicy/
Date Mon, 16 Mar 2009 06:42:22 GMT
Author: davsclaus
Date: Mon Mar 16 06:42:20 2009
New Revision: 754824

URL: http://svn.apache.org/viewvc?rev=754824&view=rev
Log:
Polished code reported by Sonar

Modified:
    camel/trunk/camel-core/src/main/java/org/apache/camel/impl/AssignableToPackageScanFilter.java
    camel/trunk/camel-core/src/main/java/org/apache/camel/impl/DefaultComponent.java
    camel/trunk/camel-core/src/main/java/org/apache/camel/impl/DefaultFactoryFinderResolver.java
    camel/trunk/camel-core/src/main/java/org/apache/camel/impl/DefaultProducer.java
    camel/trunk/camel-core/src/main/java/org/apache/camel/impl/ProcessorPollingConsumer.java
    camel/trunk/camel-core/src/main/java/org/apache/camel/impl/ProducerCache.java
    camel/trunk/camel-core/src/main/java/org/apache/camel/impl/RouteService.java
    camel/trunk/camel-core/src/main/java/org/apache/camel/impl/StringDataFormat.java
    camel/trunk/camel-core/src/main/java/org/apache/camel/impl/WebSpherePacakageScanClassResolver.java
    camel/trunk/camel-core/src/main/java/org/apache/camel/impl/ZipDataFormat.java
    camel/trunk/camel-core/src/main/java/org/apache/camel/processor/BatchProcessor.java
    camel/trunk/camel-core/src/main/java/org/apache/camel/processor/CatchProcessor.java
    camel/trunk/camel-core/src/main/java/org/apache/camel/processor/ChoiceProcessor.java
    camel/trunk/camel-core/src/main/java/org/apache/camel/processor/DelayProcessorSupport.java
    camel/trunk/camel-core/src/main/java/org/apache/camel/processor/Delayer.java
    camel/trunk/camel-core/src/main/java/org/apache/camel/processor/FilterProcessor.java
    camel/trunk/camel-core/src/main/java/org/apache/camel/processor/LoopProcessor.java
    camel/trunk/camel-core/src/main/java/org/apache/camel/processor/RecipientList.java
    camel/trunk/camel-core/src/main/java/org/apache/camel/processor/RoutingSlip.java
    camel/trunk/camel-core/src/main/java/org/apache/camel/processor/StreamResequencer.java
    camel/trunk/camel-core/src/main/java/org/apache/camel/processor/ThroughputLogger.java
    camel/trunk/camel-core/src/main/java/org/apache/camel/processor/ThrowFaultProcessor.java
    camel/trunk/camel-core/src/main/java/org/apache/camel/processor/TransformProcessor.java
    camel/trunk/camel-core/src/main/java/org/apache/camel/processor/exceptionpolicy/ExceptionPolicyStrategy.java

Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/impl/AssignableToPackageScanFilter.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/impl/AssignableToPackageScanFilter.java?rev=754824&r1=754823&r2=754824&view=diff
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/impl/AssignableToPackageScanFilter.java
(original)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/impl/AssignableToPackageScanFilter.java
Mon Mar 16 06:42:20 2009
@@ -22,7 +22,7 @@
  * Package scan filter for testing if a given class is assignable to another class.
  */
 public class AssignableToPackageScanFilter implements PackageScanFilter {
-    private Class parent;
+    private final Class parent;
 
     public AssignableToPackageScanFilter(Class parentType) {
         this.parent = parentType;

Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/impl/DefaultComponent.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/impl/DefaultComponent.java?rev=754824&r1=754823&r2=754824&view=diff
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/impl/DefaultComponent.java (original)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/impl/DefaultComponent.java Mon Mar
16 06:42:20 2009
@@ -44,7 +44,7 @@
 public abstract class DefaultComponent extends ServiceSupport implements Component {
     private static final transient Log LOG = LogFactory.getLog(DefaultComponent.class);
 
-    private int defaultThreadPoolSize = 5;
+    private final int defaultThreadPoolSize = 5;
     private CamelContext camelContext;
     private ScheduledExecutorService executorService;
     

Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/impl/DefaultFactoryFinderResolver.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/impl/DefaultFactoryFinderResolver.java?rev=754824&r1=754823&r2=754824&view=diff
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/impl/DefaultFactoryFinderResolver.java
(original)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/impl/DefaultFactoryFinderResolver.java
Mon Mar 16 06:42:20 2009
@@ -27,10 +27,8 @@
  */
 public class DefaultFactoryFinderResolver implements FactoryFinderResolver {
 
-    public static final transient String DEFAULT_RESOURCE_PATH = "META-INF/services/org/apache/camel/";
-
     public FactoryFinder resolveDefaultFactoryFinder(ClassResolver classResolver) {
-        return new DefaultFactoryFinder(classResolver, DEFAULT_RESOURCE_PATH);
+        return resolveFactoryFinder(classResolver, "META-INF/services/org/apache/camel/");
     }
 
     public FactoryFinder resolveFactoryFinder(ClassResolver classResolver, String resourcePath)
{

Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/impl/DefaultProducer.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/impl/DefaultProducer.java?rev=754824&r1=754823&r2=754824&view=diff
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/impl/DefaultProducer.java (original)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/impl/DefaultProducer.java Mon Mar
16 06:42:20 2009
@@ -27,7 +27,7 @@
  * @version $Revision$
  */
 public abstract class DefaultProducer extends ServiceSupport implements Producer {
-    private Endpoint endpoint;
+    private final Endpoint endpoint;
 
     public DefaultProducer(Endpoint endpoint) {
         this.endpoint = endpoint;

Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/impl/ProcessorPollingConsumer.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/impl/ProcessorPollingConsumer.java?rev=754824&r1=754823&r2=754824&view=diff
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/impl/ProcessorPollingConsumer.java
(original)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/impl/ProcessorPollingConsumer.java
Mon Mar 16 06:42:20 2009
@@ -30,7 +30,7 @@
  * @version $Revision$
  */
 public class ProcessorPollingConsumer extends PollingConsumerSupport {
-    private Processor processor;
+    private final Processor processor;
 
     public ProcessorPollingConsumer(Endpoint endpoint, Processor processor) {
         super(endpoint);

Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/impl/ProducerCache.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/impl/ProducerCache.java?rev=754824&r1=754823&r2=754824&view=diff
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/impl/ProducerCache.java (original)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/impl/ProducerCache.java Mon Mar
16 06:42:20 2009
@@ -42,7 +42,7 @@
 public class ProducerCache extends ServiceSupport {
     private static final transient Log LOG = LogFactory.getLog(ProducerCache.class);
 
-    private Map<String, Producer> producers = new HashMap<String, Producer>();
+    private final Map<String, Producer> producers = new HashMap<String, Producer>();
 
     public synchronized Producer getProducer(Endpoint endpoint) {
         String key = endpoint.getEndpointUri();

Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/impl/RouteService.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/impl/RouteService.java?rev=754824&r1=754823&r2=754824&view=diff
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/impl/RouteService.java (original)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/impl/RouteService.java Mon Mar 16
06:42:20 2009
@@ -38,7 +38,7 @@
     private final RouteDefinition routeType;
     private final List<RouteContext> routeContexts;
     private final Collection<Route> routes;
-    private String id;
+    private final String id;
 
     public RouteService(DefaultCamelContext camelContext, RouteDefinition routeType, List<RouteContext>
routeContexts, Collection<Route> routes) {
         this.camelContext = camelContext;

Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/impl/StringDataFormat.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/impl/StringDataFormat.java?rev=754824&r1=754823&r2=754824&view=diff
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/impl/StringDataFormat.java (original)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/impl/StringDataFormat.java Mon Mar
16 06:42:20 2009
@@ -32,7 +32,7 @@
  */
 public class StringDataFormat implements DataFormat {
 
-    private String charset;
+    private final String charset;
 
     public StringDataFormat(String charset) {
         this.charset = charset;

Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/impl/WebSpherePacakageScanClassResolver.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/impl/WebSpherePacakageScanClassResolver.java?rev=754824&r1=754823&r2=754824&view=diff
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/impl/WebSpherePacakageScanClassResolver.java
(original)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/impl/WebSpherePacakageScanClassResolver.java
Mon Mar 16 06:42:20 2009
@@ -25,7 +25,7 @@
  */
 public class WebSpherePacakageScanClassResolver extends DefaultPackageScanClassResolver {
 
-    private String resourcePath;
+    private final String resourcePath;
 
     /**
      * Constructor.

Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/impl/ZipDataFormat.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/impl/ZipDataFormat.java?rev=754824&r1=754823&r2=754824&view=diff
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/impl/ZipDataFormat.java (original)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/impl/ZipDataFormat.java Mon Mar
16 06:42:20 2009
@@ -30,7 +30,7 @@
 
 public class ZipDataFormat implements DataFormat {
 
-    private int compressionLevel;
+    private final int compressionLevel;
 
     public ZipDataFormat() {
         this.compressionLevel = Deflater.BEST_SPEED;
@@ -61,6 +61,7 @@
             IOHelper.copy(unzipInput, bos);
             return bos.toByteArray();
         } finally {
+            unzipInput.close();
             bos.close();
         }
     }

Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/processor/BatchProcessor.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/BatchProcessor.java?rev=754824&r1=754823&r2=754824&view=diff
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/processor/BatchProcessor.java (original)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/processor/BatchProcessor.java Mon
Mar 16 06:42:20 2009
@@ -45,11 +45,11 @@
     private int outBatchSize;
     private boolean groupExchanges;
 
-    private Processor processor;
-    private Collection<Exchange> collection;
+    private final Processor processor;
+    private final Collection<Exchange> collection;
     private ExceptionHandler exceptionHandler;
 
-    private BatchSender sender;
+    private final BatchSender sender;
 
     public BatchProcessor(Processor processor, Collection<Exchange> collection) {
         ObjectHelper.notNull(processor, "processor");

Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/processor/CatchProcessor.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/CatchProcessor.java?rev=754824&r1=754823&r2=754824&view=diff
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/processor/CatchProcessor.java (original)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/processor/CatchProcessor.java Mon
Mar 16 06:42:20 2009
@@ -26,7 +26,7 @@
  * @version $Revision$
  */
 public class CatchProcessor extends DelegateProcessor {
-    private List<Class> exceptions;
+    private final List<Class> exceptions;
 
     public CatchProcessor(List<Class> exceptions, Processor processor) {
         super(processor);

Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/processor/ChoiceProcessor.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/ChoiceProcessor.java?rev=754824&r1=754823&r2=754824&view=diff
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/processor/ChoiceProcessor.java (original)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/processor/ChoiceProcessor.java Mon
Mar 16 06:42:20 2009
@@ -16,7 +16,6 @@
  */
 package org.apache.camel.processor;
 
-import java.util.ArrayList;
 import java.util.List;
 
 import org.apache.camel.Exchange;
@@ -33,8 +32,8 @@
  * @version $Revision$
  */
 public class ChoiceProcessor extends ServiceSupport implements Processor {
-    private List<FilterProcessor> filters = new ArrayList<FilterProcessor>();
-    private Processor otherwise;
+    private final List<FilterProcessor> filters;
+    private final Processor otherwise;
 
     public ChoiceProcessor(List<FilterProcessor> filters, Processor otherwise) {
         this.filters = filters;

Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/processor/DelayProcessorSupport.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/DelayProcessorSupport.java?rev=754824&r1=754823&r2=754824&view=diff
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/processor/DelayProcessorSupport.java
(original)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/processor/DelayProcessorSupport.java
Mon Mar 16 06:42:20 2009
@@ -33,7 +33,7 @@
  */
 public abstract class DelayProcessorSupport extends DelegateProcessor {
     protected final transient Log log = LogFactory.getLog(getClass());
-    private CountDownLatch stoppedLatch = new CountDownLatch(1);
+    private final CountDownLatch stoppedLatch = new CountDownLatch(1);
     private boolean fastStop = true;
 
     public DelayProcessorSupport(Processor processor) {

Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/processor/Delayer.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/Delayer.java?rev=754824&r1=754823&r2=754824&view=diff
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/processor/Delayer.java (original)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/processor/Delayer.java Mon Mar 16
06:42:20 2009
@@ -31,7 +31,7 @@
  * @version $Revision$
  */
 public class Delayer extends DelayProcessorSupport {
-    private Expression timeExpression;
+    private final Expression timeExpression;
     private long delay;
 
     public Delayer(Processor processor, Expression timeExpression, long delay) {

Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/processor/FilterProcessor.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/FilterProcessor.java?rev=754824&r1=754823&r2=754824&view=diff
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/processor/FilterProcessor.java (original)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/processor/FilterProcessor.java Mon
Mar 16 06:42:20 2009
@@ -27,7 +27,7 @@
  * @version $Revision$
  */
 public class FilterProcessor extends DelegateProcessor {
-    private Predicate predicate;
+    private final Predicate predicate;
 
     public FilterProcessor(Predicate predicate, Processor processor) {
         super(processor);

Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/processor/LoopProcessor.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/LoopProcessor.java?rev=754824&r1=754823&r2=754824&view=diff
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/processor/LoopProcessor.java (original)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/processor/LoopProcessor.java Mon
Mar 16 06:42:20 2009
@@ -32,7 +32,7 @@
 public class LoopProcessor extends DelegateProcessor {
     private static final Log LOG = LogFactory.getLog(LoopProcessor.class);
 
-    private Expression expression;
+    private final Expression expression;
 
     public LoopProcessor(Expression expression, Processor processor) {
         super(processor);

Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/processor/RecipientList.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/RecipientList.java?rev=754824&r1=754823&r2=754824&view=diff
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/processor/RecipientList.java (original)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/processor/RecipientList.java Mon
Mar 16 06:42:20 2009
@@ -41,8 +41,8 @@
  * @version $Revision$
  */
 public class RecipientList extends ServiceSupport implements Processor {
+    private final ProducerCache producerCache = new ProducerCache();
     private Expression expression;
-    private ProducerCache producerCache = new ProducerCache();
 
     public RecipientList() {
     }
@@ -91,5 +91,6 @@
     }
 
     protected void doStart() throws Exception {
+        producerCache.start();
     }
 }

Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/processor/RoutingSlip.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/RoutingSlip.java?rev=754824&r1=754823&r2=754824&view=diff
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/processor/RoutingSlip.java (original)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/processor/RoutingSlip.java Mon Mar
16 06:42:20 2009
@@ -36,11 +36,10 @@
  */
 public class RoutingSlip extends ServiceSupport implements Processor {
     private static final transient Log LOG = LogFactory.getLog(RoutingSlip.class);
+    private final ProducerCache producerCache = new ProducerCache();
     private final String header;
     private final String uriDelimiter;
 
-    private ProducerCache producerCache = new ProducerCache();
-
     public RoutingSlip(String header) {
         this(header, RoutingSlipDefinition.DEFAULT_DELIMITER);
     }
@@ -87,6 +86,7 @@
     }
 
     protected void doStart() throws Exception {
+        producerCache.start();
     }
 
     private void updateRoutingSlip(Exchange current) {

Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/processor/StreamResequencer.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/StreamResequencer.java?rev=754824&r1=754823&r2=754824&view=diff
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/processor/StreamResequencer.java
(original)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/processor/StreamResequencer.java
Mon Mar 16 06:42:20 2009
@@ -54,9 +54,9 @@
 
     private static final long DELIVERY_ATTEMPT_INTERVAL = 1000L;
     
-    private ExceptionHandler exceptionHandler;
-    private ResequencerEngine<Exchange> engine;
-    private Processor processor;
+    private final ExceptionHandler exceptionHandler;
+    private final ResequencerEngine<Exchange> engine;
+    private final Processor processor;
     private Delivery delivery;
     private int capacity;
     

Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/processor/ThroughputLogger.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/ThroughputLogger.java?rev=754824&r1=754823&r2=754824&view=diff
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/processor/ThroughputLogger.java
(original)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/processor/ThroughputLogger.java
Mon Mar 16 06:42:20 2009
@@ -32,7 +32,7 @@
     private int groupSize = 100;
     private long startTime;
     private long groupStartTime;
-    private AtomicInteger receivedCounter = new AtomicInteger();
+    private final AtomicInteger receivedCounter = new AtomicInteger();
     private NumberFormat numberFormat = NumberFormat.getNumberInstance();
     private String action = "Received";
     private String logMessage;

Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/processor/ThrowFaultProcessor.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/ThrowFaultProcessor.java?rev=754824&r1=754823&r2=754824&view=diff
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/processor/ThrowFaultProcessor.java
(original)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/processor/ThrowFaultProcessor.java
Mon Mar 16 06:42:20 2009
@@ -25,7 +25,7 @@
  * The processor which implements the ThrowFault DSL
  */
 public class ThrowFaultProcessor implements Processor {
-    private Throwable fault;
+    private final Throwable fault;
 
     public ThrowFaultProcessor(Throwable fault) {
         this.fault = fault;

Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/processor/TransformProcessor.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/TransformProcessor.java?rev=754824&r1=754823&r2=754824&view=diff
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/processor/TransformProcessor.java
(original)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/processor/TransformProcessor.java
Mon Mar 16 06:42:20 2009
@@ -24,7 +24,7 @@
  * A processor which sets the body on the OUT message with an expression
  */
 public class TransformProcessor extends DelegateProcessor implements Processor {
-    private Expression expression;
+    private final Expression expression;
 
     public TransformProcessor(Expression expression) {
         this.expression = expression;

Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/processor/exceptionpolicy/ExceptionPolicyStrategy.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/exceptionpolicy/ExceptionPolicyStrategy.java?rev=754824&r1=754823&r2=754824&view=diff
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/processor/exceptionpolicy/ExceptionPolicyStrategy.java
(original)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/processor/exceptionpolicy/ExceptionPolicyStrategy.java
Mon Mar 16 06:42:20 2009
@@ -37,7 +37,7 @@
      * @param exception          the exception that was thrown
      * @return the resolved exception type to handle this exception, <tt>null</tt>
if none found.
      */
-    OnExceptionDefinition getExceptionPolicy(Map<ExceptionPolicyKey, OnExceptionDefinition>
exceptionPolicices, Exchange exchange,
-                                            Throwable exception);
+    OnExceptionDefinition getExceptionPolicy(Map<ExceptionPolicyKey, OnExceptionDefinition>
exceptionPolicices,
+                                             Exchange exchange, Throwable exception);
 
 }



Mime
View raw message