You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@servicemix.apache.org by pawan269 <pa...@gmail.com> on 2010/01/27 04:38:24 UTC

Routing message from queue to log

Hi All,

I am trying to route messages from a queue to log.

Here is the content of my camel.xml present under
/usr/local/apache-servicemix-4.0.0/deploy folder

<beans xmlns="http://www.springframework.org/schema/beans" 
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" 
       xsi:schemaLocation=" 
       http://www.springframework.org/schema/beans 
         http://www.springframework.org/schema/beans/spring-beans-2.5.xsd 
       http://activemq.apache.org/camel/schema/spring 
         http://activemq.apache.org/camel/schema/spring/camel-spring.xsd"> 

  <camelContext xmlns="http://activemq.apache.org/camel/schema/spring"> 
    <route> 
      <from uri="activemq:queue.test"/> 
      <to uri="log:demo?showBodyType=true"/> 
    </route> 
  </camelContext> 
</beans> 

As soon as i save it servicemix throws an error at prompt as 

smx@root:/> Exception in thread "SpringOsgiExtenderThread-71"
org.apache.camel.NoSuchEndpointException: No endpoint could be found for:
activemq:queue.test, please check your classpath contains the needed camel
component jar. 
	at
org.apache.camel.util.CamelContextHelper.getMandatoryEndpoint(CamelContextHelper.java:55) 
	at org.apache.camel.model.RouteType.resolveEndpoint(RouteType.java:99) 
	at
org.apache.camel.impl.DefaultRouteContext.resolveEndpoint(DefaultRouteContext.java:106) 
	at
org.apache.camel.impl.DefaultRouteContext.resolveEndpoint(DefaultRouteContext.java:112) 
	at org.apache.camel.model.FromType.resolveEndpoint(FromType.java:73) 
	at
org.apache.camel.impl.DefaultRouteContext.getEndpoint(DefaultRouteContext.java:81) 
	at org.apache.camel.model.RouteType.addRoutes(RouteType.java:213) 
	at org.apache.camel.model.RouteType.addRoutes(RouteType.java:89) 
	at
org.apache.camel.impl.DefaultCamelContext.startRouteDefinitions(DefaultCamelContext.java:644) 
	at
org.apache.camel.impl.DefaultCamelContext.doStart(DefaultCamelContext.java:634) 
	at
org.apache.camel.spring.SpringCamelContext.maybeDoStart(SpringCamelContext.java:166) 
	at
org.apache.camel.spring.SpringCamelContext.doStart(SpringCamelContext.java:161) 
	at org.apache.camel.impl.ServiceSupport.start(ServiceSupport.java:49) 
	at
org.apache.camel.spring.SpringCamelContext.maybeStart(SpringCamelContext.java:96) 
	at
org.apache.camel.spring.SpringCamelContext.onApplicationEvent(SpringCamelContext.java:115) 
	at
org.springframework.context.event.SimpleApplicationEventMulticaster$1.run(SimpleApplicationEventMulticaster.java:78) 
	at
org.springframework.core.task.SyncTaskExecutor.execute(SyncTaskExecutor.java:49) 
	at
org.springframework.context.event.SimpleApplicationEventMulticaster.multicastEvent(SimpleApplicationEventMulticaster.java:76) 
	at
org.springframework.context.support.AbstractApplicationContext.publishEvent(AbstractApplicationContext.java:274) 
	at
org.springframework.context.support.AbstractApplicationContext.finishRefresh(AbstractApplicationContext.java:736) 
	at
org.springframework.osgi.context.support.AbstractDelegatedExecutionApplicationContext.finishRefresh(AbstractDelegatedExecutionApplicationContext.java:380) 
	at
org.springframework.osgi.context.support.AbstractDelegatedExecutionApplicationContext$4.run(AbstractDelegatedExecutionApplicationContext.java:346) 
	at
org.springframework.osgi.util.internal.PrivilegedUtils.executeWithCustomTCCL(PrivilegedUtils.java:85) 
	at
org.springframework.osgi.context.support.AbstractDelegatedExecutionApplicationContext.completeRefresh(AbstractDelegatedExecutionApplicationContext.java:308) 
	at
org.springframework.osgi.extender.internal.dependencies.startup.DependencyWaiterApplicationContextExecutor$CompleteRefreshTask.run(DependencyWaiterApplicationContextExecutor.java:138) 
	at java.lang.Thread.run(Thread.java:636) 


I have did an osgi/list

here is the output

smx@root:/> osgi/list | grep camel

[  65] [Active     ] [       ] [   60] camel-core (1.6.0)

[  66] [Active     ] [       ] [   60] camel-osgi (1.6.0)

[  67] [Active     ] [       ] [   60] camel-spring (1.6.0)

[ 158] [Active     ] [Failed ] [   60] camel.xml (0.0.0)


Just to add I am very new to ESB and Java world. Not sure what wrong I am
doing... :(

Any little help will be much appreciated 

Many Thanks
Pawan
-- 
View this message in context: http://old.nabble.com/Routing-message-from-queue-to-log-tp27333706p27333706.html
Sent from the ServiceMix - User mailing list archive at Nabble.com.


Re: Routing message from queue to log

Posted by Stan Lewis <ga...@gmail.com>.
Hi Pawan, check here - http://camel.apache.org/activemq.html

I think you just need to add the bean for the activemq component and a
connection pool, look under "using connection pooling" in the linked
page.

On Tue, Jan 26, 2010 at 10:38 PM, pawan269 <pa...@gmail.com> wrote:
>
> Hi All,
>
> I am trying to route messages from a queue to log.
>
> Here is the content of my camel.xml present under
> /usr/local/apache-servicemix-4.0.0/deploy folder
>
> <beans xmlns="http://www.springframework.org/schema/beans"
>       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
>       xsi:schemaLocation="
>       http://www.springframework.org/schema/beans
>         http://www.springframework.org/schema/beans/spring-beans-2.5.xsd
>       http://activemq.apache.org/camel/schema/spring
>         http://activemq.apache.org/camel/schema/spring/camel-spring.xsd">
>
>  <camelContext xmlns="http://activemq.apache.org/camel/schema/spring">
>    <route>
>      <from uri="activemq:queue.test"/>
>      <to uri="log:demo?showBodyType=true"/>
>    </route>
>  </camelContext>
> </beans>
>
> As soon as i save it servicemix throws an error at prompt as
>
> smx@root:/> Exception in thread "SpringOsgiExtenderThread-71"
> org.apache.camel.NoSuchEndpointException: No endpoint could be found for:
> activemq:queue.test, please check your classpath contains the needed camel
> component jar.
>        at
> org.apache.camel.util.CamelContextHelper.getMandatoryEndpoint(CamelContextHelper.java:55)
>        at org.apache.camel.model.RouteType.resolveEndpoint(RouteType.java:99)
>        at
> org.apache.camel.impl.DefaultRouteContext.resolveEndpoint(DefaultRouteContext.java:106)
>        at
> org.apache.camel.impl.DefaultRouteContext.resolveEndpoint(DefaultRouteContext.java:112)
>        at org.apache.camel.model.FromType.resolveEndpoint(FromType.java:73)
>        at
> org.apache.camel.impl.DefaultRouteContext.getEndpoint(DefaultRouteContext.java:81)
>        at org.apache.camel.model.RouteType.addRoutes(RouteType.java:213)
>        at org.apache.camel.model.RouteType.addRoutes(RouteType.java:89)
>        at
> org.apache.camel.impl.DefaultCamelContext.startRouteDefinitions(DefaultCamelContext.java:644)
>        at
> org.apache.camel.impl.DefaultCamelContext.doStart(DefaultCamelContext.java:634)
>        at
> org.apache.camel.spring.SpringCamelContext.maybeDoStart(SpringCamelContext.java:166)
>        at
> org.apache.camel.spring.SpringCamelContext.doStart(SpringCamelContext.java:161)
>        at org.apache.camel.impl.ServiceSupport.start(ServiceSupport.java:49)
>        at
> org.apache.camel.spring.SpringCamelContext.maybeStart(SpringCamelContext.java:96)
>        at
> org.apache.camel.spring.SpringCamelContext.onApplicationEvent(SpringCamelContext.java:115)
>        at
> org.springframework.context.event.SimpleApplicationEventMulticaster$1.run(SimpleApplicationEventMulticaster.java:78)
>        at
> org.springframework.core.task.SyncTaskExecutor.execute(SyncTaskExecutor.java:49)
>        at
> org.springframework.context.event.SimpleApplicationEventMulticaster.multicastEvent(SimpleApplicationEventMulticaster.java:76)
>        at
> org.springframework.context.support.AbstractApplicationContext.publishEvent(AbstractApplicationContext.java:274)
>        at
> org.springframework.context.support.AbstractApplicationContext.finishRefresh(AbstractApplicationContext.java:736)
>        at
> org.springframework.osgi.context.support.AbstractDelegatedExecutionApplicationContext.finishRefresh(AbstractDelegatedExecutionApplicationContext.java:380)
>        at
> org.springframework.osgi.context.support.AbstractDelegatedExecutionApplicationContext$4.run(AbstractDelegatedExecutionApplicationContext.java:346)
>        at
> org.springframework.osgi.util.internal.PrivilegedUtils.executeWithCustomTCCL(PrivilegedUtils.java:85)
>        at
> org.springframework.osgi.context.support.AbstractDelegatedExecutionApplicationContext.completeRefresh(AbstractDelegatedExecutionApplicationContext.java:308)
>        at
> org.springframework.osgi.extender.internal.dependencies.startup.DependencyWaiterApplicationContextExecutor$CompleteRefreshTask.run(DependencyWaiterApplicationContextExecutor.java:138)
>        at java.lang.Thread.run(Thread.java:636)
>
>
> I have did an osgi/list
>
> here is the output
>
> smx@root:/> osgi/list | grep camel
>
> [  65] [Active     ] [       ] [   60] camel-core (1.6.0)
>
> [  66] [Active     ] [       ] [   60] camel-osgi (1.6.0)
>
> [  67] [Active     ] [       ] [   60] camel-spring (1.6.0)
>
> [ 158] [Active     ] [Failed ] [   60] camel.xml (0.0.0)
>
>
> Just to add I am very new to ESB and Java world. Not sure what wrong I am
> doing... :(
>
> Any little help will be much appreciated
>
> Many Thanks
> Pawan
> --
> View this message in context: http://old.nabble.com/Routing-message-from-queue-to-log-tp27333706p27333706.html
> Sent from the ServiceMix - User mailing list archive at Nabble.com.
>
>