Return-Path: X-Original-To: apmail-camel-commits-archive@www.apache.org Delivered-To: apmail-camel-commits-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 042CA8E47 for ; Mon, 5 Sep 2011 12:57:17 +0000 (UTC) Received: (qmail 70561 invoked by uid 500); 5 Sep 2011 12:57:16 -0000 Delivered-To: apmail-camel-commits-archive@camel.apache.org Received: (qmail 70498 invoked by uid 500); 5 Sep 2011 12:57:12 -0000 Mailing-List: contact commits-help@camel.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@camel.apache.org Delivered-To: mailing list commits@camel.apache.org Received: (qmail 70484 invoked by uid 99); 5 Sep 2011 12:57:10 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 05 Sep 2011 12:57:10 +0000 X-ASF-Spam-Status: No, hits=-2000.0 required=5.0 tests=ALL_TRUSTED X-Spam-Check-By: apache.org Received: from [140.211.11.4] (HELO eris.apache.org) (140.211.11.4) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 05 Sep 2011 12:57:07 +0000 Received: from eris.apache.org (localhost [127.0.0.1]) by eris.apache.org (Postfix) with ESMTP id 1142923889EB for ; Mon, 5 Sep 2011 12:56:46 +0000 (UTC) Content-Type: text/plain; charset="utf-8" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit Subject: svn commit: r1165267 - in /camel/trunk: camel-core/src/main/java/org/apache/camel/component/bean/ camel-core/src/main/java/org/apache/camel/component/file/ components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/seda/ components/c... Date: Mon, 05 Sep 2011 12:56:45 -0000 To: commits@camel.apache.org From: cschneider@apache.org X-Mailer: svnmailer-1.0.8 Message-Id: <20110905125646.1142923889EB@eris.apache.org> X-Virus-Checked: Checked by ClamAV on apache.org Author: cschneider Date: Mon Sep 5 12:56:45 2011 New Revision: 1165267 URL: http://svn.apache.org/viewvc?rev=1165267&view=rev Log: Avoiding new DefaultExchange where it can be easily created using the endpoint Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/component/bean/CamelInvocationHandler.java camel/trunk/camel-core/src/main/java/org/apache/camel/component/file/FileEndpoint.java camel/trunk/camel-core/src/main/java/org/apache/camel/component/file/GenericFileConsumer.java camel/trunk/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/seda/HazelcastSedaConsumer.java camel/trunk/components/camel-jms/src/main/java/org/apache/camel/component/jms/EndpointMessageListener.java Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/component/bean/CamelInvocationHandler.java URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/component/bean/CamelInvocationHandler.java?rev=1165267&r1=1165266&r2=1165267&view=diff ============================================================================== --- camel/trunk/camel-core/src/main/java/org/apache/camel/component/bean/CamelInvocationHandler.java (original) +++ camel/trunk/camel-core/src/main/java/org/apache/camel/component/bean/CamelInvocationHandler.java Mon Sep 5 12:56:45 2011 @@ -33,7 +33,6 @@ import org.apache.camel.ExchangePattern; import org.apache.camel.InvalidPayloadException; import org.apache.camel.Producer; import org.apache.camel.RuntimeCamelException; -import org.apache.camel.impl.DefaultExchange; import org.apache.camel.util.ObjectHelper; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -65,7 +64,7 @@ public class CamelInvocationHandler impl MethodInfo methodInfo = methodInfoCache.getMethodInfo(method); final ExchangePattern pattern = methodInfo != null ? methodInfo.getPattern() : ExchangePattern.InOut; - final Exchange exchange = new DefaultExchange(endpoint, pattern); + final Exchange exchange = endpoint.createExchange(pattern); exchange.getIn().setBody(invocation); // is the return type a future Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/component/file/FileEndpoint.java URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/component/file/FileEndpoint.java?rev=1165267&r1=1165266&r2=1165267&view=diff ============================================================================== --- camel/trunk/camel-core/src/main/java/org/apache/camel/component/file/FileEndpoint.java (original) +++ camel/trunk/camel-core/src/main/java/org/apache/camel/component/file/FileEndpoint.java Mon Sep 5 12:56:45 2011 @@ -22,7 +22,6 @@ import java.io.FileNotFoundException; import org.apache.camel.Component; import org.apache.camel.Exchange; import org.apache.camel.Processor; -import org.apache.camel.impl.DefaultExchange; import org.apache.camel.processor.idempotent.MemoryIdempotentRepository; import org.apache.camel.util.FileUtil; import org.apache.camel.util.ObjectHelper; @@ -104,7 +103,7 @@ public class FileEndpoint extends Generi } public Exchange createExchange(GenericFile file) { - Exchange exchange = new DefaultExchange(this); + Exchange exchange = createExchange(); if (file != null) { file.bindToExchange(exchange); } Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/component/file/GenericFileConsumer.java URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/component/file/GenericFileConsumer.java?rev=1165267&r1=1165266&r2=1165267&view=diff ============================================================================== --- camel/trunk/camel-core/src/main/java/org/apache/camel/component/file/GenericFileConsumer.java (original) +++ camel/trunk/camel-core/src/main/java/org/apache/camel/component/file/GenericFileConsumer.java Mon Sep 5 12:56:45 2011 @@ -27,7 +27,6 @@ import org.apache.camel.BatchConsumer; import org.apache.camel.Exchange; import org.apache.camel.Processor; import org.apache.camel.ShutdownRunningTask; -import org.apache.camel.impl.DefaultExchange; import org.apache.camel.impl.ScheduledPollConsumer; import org.apache.camel.spi.ShutdownAware; import org.apache.camel.util.CastUtils; @@ -518,7 +517,7 @@ public abstract class GenericFileConsume private void evaluateFileExpression() { if (fileExpressionResult == null) { // create a dummy exchange as Exchange is needed for expression evaluation - Exchange dummy = new DefaultExchange(endpoint.getCamelContext()); + Exchange dummy = endpoint.createExchange(); fileExpressionResult = endpoint.getFileName().evaluate(dummy, String.class); } } Modified: camel/trunk/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/seda/HazelcastSedaConsumer.java URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/seda/HazelcastSedaConsumer.java?rev=1165267&r1=1165266&r2=1165267&view=diff ============================================================================== --- camel/trunk/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/seda/HazelcastSedaConsumer.java (original) +++ camel/trunk/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/seda/HazelcastSedaConsumer.java Mon Sep 5 12:56:45 2011 @@ -27,7 +27,6 @@ import org.apache.camel.Endpoint; import org.apache.camel.Exchange; import org.apache.camel.Processor; import org.apache.camel.impl.DefaultConsumer; -import org.apache.camel.impl.DefaultExchange; import org.apache.camel.impl.DefaultExchangeHolder; import org.apache.camel.impl.converter.AsyncProcessorTypeConverter; import org.slf4j.Logger; @@ -73,7 +72,7 @@ public class HazelcastSedaConsumer exten final BlockingQueue queue = endpoint.getQueue(); while (queue != null && isRunAllowed()) { - final Exchange exchange = new DefaultExchange(this.getEndpoint().getCamelContext()); + final Exchange exchange = this.getEndpoint().createExchange(); try { final Object body = queue.poll(endpoint.getConfiguration().getPollInterval(), TimeUnit.MILLISECONDS); Modified: camel/trunk/components/camel-jms/src/main/java/org/apache/camel/component/jms/EndpointMessageListener.java URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-jms/src/main/java/org/apache/camel/component/jms/EndpointMessageListener.java?rev=1165267&r1=1165266&r2=1165267&view=diff ============================================================================== --- camel/trunk/components/camel-jms/src/main/java/org/apache/camel/component/jms/EndpointMessageListener.java (original) +++ camel/trunk/components/camel-jms/src/main/java/org/apache/camel/component/jms/EndpointMessageListener.java Mon Sep 5 12:56:45 2011 @@ -27,7 +27,6 @@ import org.apache.camel.ExchangePattern; import org.apache.camel.Processor; import org.apache.camel.RollbackExchangeException; import org.apache.camel.RuntimeCamelException; -import org.apache.camel.impl.DefaultExchange; import org.apache.camel.impl.LoggingExceptionHandler; import org.apache.camel.spi.ExceptionHandler; import org.apache.camel.util.ObjectHelper; @@ -156,7 +155,7 @@ public class EndpointMessageListener imp } public Exchange createExchange(Message message, Object replyDestination) { - Exchange exchange = new DefaultExchange(endpoint, endpoint.getExchangePattern()); + Exchange exchange = endpoint.createExchange(); JmsBinding binding = getBinding(); exchange.setProperty(Exchange.BINDING, binding); exchange.setIn(new JmsMessage(message, binding));