You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ja...@apache.org on 2009/11/17 19:12:21 UTC
svn commit: r881426 - in /camel/trunk:
camel-core/src/main/java/org/apache/camel/processor/
camel-core/src/main/java/org/apache/camel/processor/interceptor/
components/camel-test/src/test/java/org/apache/camel/test/patterns/
Author: janstey
Date: Tue Nov 17 18:12:21 2009
New Revision: 881426
URL: http://svn.apache.org/viewvc?rev=881426&view=rev
Log:
fix CS
Modified:
camel/trunk/camel-core/src/main/java/org/apache/camel/processor/RedeliveryPolicy.java
camel/trunk/camel-core/src/main/java/org/apache/camel/processor/SendAsyncProcessor.java
camel/trunk/camel-core/src/main/java/org/apache/camel/processor/interceptor/TraceInterceptor.java
camel/trunk/components/camel-test/src/test/java/org/apache/camel/test/patterns/JMSFilterTest.java
Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/processor/RedeliveryPolicy.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/RedeliveryPolicy.java?rev=881426&r1=881425&r2=881426&view=diff
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/processor/RedeliveryPolicy.java (original)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/processor/RedeliveryPolicy.java Tue Nov 17 18:12:21 2009
@@ -71,9 +71,9 @@
* @version $Revision$
*/
public class RedeliveryPolicy implements Cloneable, Serializable {
+ protected static transient Random randomNumberGenerator;
private static final long serialVersionUID = -338222777701473252L;
private static final transient Log LOG = LogFactory.getLog(RedeliveryPolicy.class);
- protected static transient Random randomNumberGenerator;
protected long redeliverDelay = 1000L;
protected int maximumRedeliveries;
Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/processor/SendAsyncProcessor.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/SendAsyncProcessor.java?rev=881426&r1=881425&r2=881426&view=diff
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/processor/SendAsyncProcessor.java (original)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/processor/SendAsyncProcessor.java Tue Nov 17 18:12:21 2009
@@ -134,7 +134,7 @@
*/
protected void doSimulateAsyncProcess(final Processor producer, final Exchange exchange, final AsyncCallback callback) throws Exception {
if (LOG.isTraceEnabled()) {
- LOG.trace("Producer "+ producer + " is not an instanceof AsyncProcessor"
+ LOG.trace("Producer " + producer + " is not an instanceof AsyncProcessor"
+ ". Will fallback to simulate async behavior by transferring task to a producer thread pool for further processing.");
}
Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/processor/interceptor/TraceInterceptor.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/interceptor/TraceInterceptor.java?rev=881426&r1=881425&r2=881426&view=diff
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/processor/interceptor/TraceInterceptor.java (original)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/processor/interceptor/TraceInterceptor.java Tue Nov 17 18:12:21 2009
@@ -24,11 +24,11 @@
import org.apache.camel.Exchange;
import org.apache.camel.Processor;
import org.apache.camel.Producer;
+import org.apache.camel.impl.AggregateRouteNode;
import org.apache.camel.impl.DefaultExchange;
import org.apache.camel.impl.DefaultRouteNode;
import org.apache.camel.impl.DoCatchRouteNode;
import org.apache.camel.impl.DoFinallyRouteNode;
-import org.apache.camel.impl.AggregateRouteNode;
import org.apache.camel.impl.OnCompletionRouteNode;
import org.apache.camel.impl.OnExceptionRouteNode;
import org.apache.camel.model.AggregateDefinition;
Modified: camel/trunk/components/camel-test/src/test/java/org/apache/camel/test/patterns/JMSFilterTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-test/src/test/java/org/apache/camel/test/patterns/JMSFilterTest.java?rev=881426&r1=881425&r2=881426&view=diff
==============================================================================
--- camel/trunk/components/camel-test/src/test/java/org/apache/camel/test/patterns/JMSFilterTest.java (original)
+++ camel/trunk/components/camel-test/src/test/java/org/apache/camel/test/patterns/JMSFilterTest.java Tue Nov 17 18:12:21 2009
@@ -24,9 +24,9 @@
import org.apache.camel.Produce;
import org.apache.camel.ProducerTemplate;
import org.apache.camel.builder.RouteBuilder;
+import org.apache.camel.component.jms.JmsComponent;
import org.apache.camel.component.mock.MockEndpoint;
import org.apache.camel.test.CamelTestSupport;
-import org.apache.camel.component.jms.JmsComponent;
/**
* Tests filtering using Camel Test