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/18 09:44:45 UTC
svn commit: r1036350 -
/camel/trunk/camel-core/src/main/java/org/apache/camel/component/bean/ProxyHelper.java
Author: davsclaus
Date: Thu Nov 18 08:44:45 2010
New Revision: 1036350
URL: http://svn.apache.org/viewvc?rev=1036350&view=rev
Log:
CAMEL-3341: Fixed proxy endpoint did not start producer. Thanks to Caspar MacRae for patch.
Modified:
camel/trunk/camel-core/src/main/java/org/apache/camel/component/bean/ProxyHelper.java
Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/component/bean/ProxyHelper.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/component/bean/ProxyHelper.java?rev=1036350&r1=1036349&r2=1036350&view=diff
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/component/bean/ProxyHelper.java (original)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/component/bean/ProxyHelper.java Thu Nov 18 08:44:45 2010
@@ -20,6 +20,7 @@ import java.lang.reflect.Proxy;
import org.apache.camel.Endpoint;
import org.apache.camel.Producer;
+import org.apache.camel.util.ServiceHelper;
/**
* A helper class for creating proxies which delegate to Camel
@@ -47,7 +48,10 @@ public final class ProxyHelper {
*/
@SuppressWarnings("unchecked")
public static <T> T createProxy(Endpoint endpoint, ClassLoader cl, Class[] interfaces, MethodInfoCache methodCache) throws Exception {
- return (T) createProxyObject(endpoint, endpoint.createProducer(), cl, interfaces, methodCache);
+ Producer producer = endpoint.createProducer();
+ // ensure the producer is started
+ ServiceHelper.startService(producer);
+ return (T) createProxyObject(endpoint, producer, cl, interfaces, methodCache);
}
/**