Author: ningjiang Date: Sat Oct 20 01:04:39 2012 New Revision: 1400352 URL: http://svn.apache.org/viewvc?rev=1400352&view=rev Log: Merged revisions 1400074 via svnmerge from https://svn.apache.org/repos/asf/camel/trunk
........ r1400074 | ningjiang | 2012-10-19 20:39:01 +0800 (Fri, 19 Oct 2012) | 1 line CAMEL-5714 Throwing meaningful exception when the conetxt component cannot create a right endpoint. ........ Modified: camel/branches/camel-2.10.x/ (props changed) camel/branches/camel-2.10.x/components/camel-context/src/main/java/org/apache/camel/component/context/LocalContextComponent.java camel/branches/camel-2.10.x/components/camel-context/src/main/java/org/apache/camel/component/context/QualifiedContextComponent.java Propchange: camel/branches/camel-2.10.x/ ------------------------------------------------------------------------------ Merged /camel/trunk:r1400074 Propchange: camel/branches/camel-2.10.x/ ------------------------------------------------------------------------------ Binary property 'svnmerge-integrated' - no diff available. Modified: camel/branches/camel-2.10.x/components/camel-context/src/main/java/org/apache/camel/component/context/LocalContextComponent.java URL: http://svn.apache.org/viewvc/camel/branches/camel-2.10.x/components/camel-context/src/main/java/org/apache/camel/component/context/LocalContextComponent.java?rev=1400352&r1=1400351&r2=1400352&view=diff ============================================================================== --- camel/branches/camel-2.10.x/components/camel-context/src/main/java/org/apache/camel/component/context/LocalContextComponent.java (original) +++ camel/branches/camel-2.10.x/components/camel-context/src/main/java/org/apache/camel/component/context/LocalContextComponent.java Sat Oct 20 01:04:39 2012 @@ -23,6 +23,7 @@ import java.util.Map; import org.apache.camel.CamelContext; import org.apache.camel.Endpoint; +import org.apache.camel.ResolveEndpointFailedException; import org.apache.camel.impl.DefaultComponent; import org.apache.camel.util.ObjectHelper; import org.slf4j.Logger; @@ -90,7 +91,8 @@ public class LocalContextComponent exten } } } - return null; + throw new ResolveEndpointFailedException("Cannot find the endpoint with uri " + uri + " in the CamelContext " + getLocalCamelContext().getName()); + } protected void logUsingEndpoint(String uri, Endpoint endpoint) { Modified: camel/branches/camel-2.10.x/components/camel-context/src/main/java/org/apache/camel/component/context/QualifiedContextComponent.java URL: http://svn.apache.org/viewvc/camel/branches/camel-2.10.x/components/camel-context/src/main/java/org/apache/camel/component/context/QualifiedContextComponent.java?rev=1400352&r1=1400351&r2=1400352&view=diff ============================================================================== --- camel/branches/camel-2.10.x/components/camel-context/src/main/java/org/apache/camel/component/context/QualifiedContextComponent.java (original) +++ camel/branches/camel-2.10.x/components/camel-context/src/main/java/org/apache/camel/component/context/QualifiedContextComponent.java Sat Oct 20 01:04:39 2012 @@ -20,6 +20,7 @@ import java.util.Map; import org.apache.camel.Component; import org.apache.camel.Endpoint; +import org.apache.camel.ResolveEndpointFailedException; import org.apache.camel.impl.DefaultComponent; import org.apache.camel.util.ObjectHelper; import org.slf4j.Logger; @@ -43,11 +44,19 @@ public class QualifiedContextComponent e Component component = getCamelContext().getComponent(contextId); if (component != null) { LOG.debug("Attempting to create local endpoint: {} inside the component: {}", localEndpoint, component); - return component.createEndpoint(localEndpoint); + Endpoint endpoint = component.createEndpoint(localEndpoint); + if (endpoint == null) { + // throw the exception tell we cannot find an then endpoint from the given context + throw new ResolveEndpointFailedException("Cannot create a endpoint with uri" + localEndpoint + " for the CamelContext Component " + contextId); + } else { + return endpoint; + } + } else { + throw new ResolveEndpointFailedException("Cannot create the camel context component for context " + contextId); } + } else { // the uri is wrong + throw new ResolveEndpointFailedException("The uri " + remaining + "from camel context component is wrong"); } - - return null; } }