Hi there I'm not using JBI. Each route is deployed as OSGi bundle.
Claus Ibsen <claus.ib...@gmail.com> 24.11.2010 20:15 Please respond to users@camel.apache.org To users@camel.apache.org cc Subject Re: Is it possible to cluster camel endpoint? Hi Are you using JBI or not? The last statement was kinda confusing how I read it. If you use JBI I suggest to use jbi to pass messages between applications. On Wed, Nov 24, 2010 at 5:01 PM, <sergey_zhemzhit...@troika.ru> wrote: > Well, it seems that my attachments have been dropped. > > Here are camel routes: > > route for cluster node 1: > > <?xml version="1.0" encoding="UTF-8"?> > > <beans xmlns="http://www.springframework.org/schema/beans"; > xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"; > xmlns:osgi="http://www.springframework.org/schema/osgi"; > xsi:schemaLocation="http://www.springframework.org/schema/beans > http://www.springframework.org/schema/beans/spring-beans-3.0.xsd > http://camel.apache.org/schema/spring > http://camel.apache.org/schema/spring/camel-spring.xsd > http://www.springframework.org/schema/osgi > http://www.springframework.org/schema/osgi/spring-osgi.xsd";> > > <camelContext id="smx.cluster.publisher" xmlns=" > http://camel.apache.org/schema/spring";> > <route id="publishRoute"> > <from uri="timer://events?fixedRate=true&period=1000"/> > <transform> > <constant>Hello World!!!</constant> > </transform> > <multicast> > <to uri="log://smx.cluster.publisher?level=INFO"/> > <to uri="nmr://smx.cluster"/> > </multicast> > </route> > </camelContext> > > <bean id="nmr" > class="org.apache.servicemix.camel.nmr.ServiceMixComponent"> > <property name="nmr"> > <osgi:reference > interface="org.apache.servicemix.nmr.api.NMR"/> > </property> > </bean> > > </beans> > > route for cluster node 2: > > <?xml version="1.0" encoding="UTF-8"?> > > <beans xmlns="http://www.springframework.org/schema/beans"; > xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"; > xmlns:osgi="http://www.springframework.org/schema/osgi"; > xsi:schemaLocation="http://www.springframework.org/schema/beans > http://www.springframework.org/schema/beans/spring-beans-3.0.xsd > http://camel.apache.org/schema/spring > http://camel.apache.org/schema/spring/camel-spring.xsd > http://www.springframework.org/schema/osgi > http://www.springframework.org/schema/osgi/spring-osgi.xsd";> > > <camelContext id="smx.cluster.subscriber" xmlns=" > http://camel.apache.org/schema/spring";> > <route id="receiveRoute"> > <from uri="nmr://smx.cluster" /> > <to uri="log://smx.cluster.subscriber?level=INFO"/> > </route> > </camelContext> > > <bean id="nmr" > class="org.apache.servicemix.camel.nmr.ServiceMixComponent"> > <property name="nmr"> > <osgi:reference > interface="org.apache.servicemix.nmr.api.NMR"/> > </property> > </bean> > > <bean class="org.apache.servicemix.common.osgi.EndpointExporter" /> > > </beans> > > It is important to note that routes are not deployed are service units for > servicemix-camel jbi component. > > Regards, Sergey > > > > > sergey_zhemzhit...@troika.ru > 24.11.2010 18:55 > Please respond to > users@camel.apache.org > > > To > users@camel.apache.org > cc > > Subject > Re: Is it possible to cluster camel endpoint? > > > > > > > Hi > > I have attached sample application (SMX-CLUSTER.zip) and configuration of > activemq in ServiceMix (SMX-CONFIG.zip) for clustering: > > To install the application please execute mvn install from command line. > It is necessary to have two instances of ServiceMix for the cluster > (configurations for activemq are in SMX-CONFIG.zip). > > Start both ServiceMix nodes and execute the following command in the > console of the first one: > > features:addUrl > mvn:org.sample.smx.cluster/smx.cluster.features/1.0.0-SNAPSHOT/xml > features:refreshUrl > features:install org.sample.smx.subscriber > > Execute the following commands in the console of the second node: > > features:addUrl > mvn:org.sample.smx.cluster/smx.cluster.features/1.0.0-SNAPSHOT/xml > features:refreshUrl > features:install org.sample.smx.publisher > > I have expected that messages which were sent from the first node would > reach the second node. > > I'm using: > > Fuse ESB: 4.3.0-fuse-01-00 > JDK: 1.6.0_21-b07 (Sun) > OS: Win XP Pro SP3 > > > Regards, > Sergey > > > > > Claus Ibsen <claus.ib...@gmail.com> > 24.11.2010 14:52 > Please respond to > users@camel.apache.org > > > To > users@camel.apache.org > cc > > Subject > Re: Is it possible to cluster camel endpoint? > > > > > > > Hi > > Can you post more details > > FUSE ESB version used > JDK used > OS used > And the Camel route you are using. > > And you can try using the latest release: v4.3.0-fuse-02-00 > > > On Wed, Nov 24, 2010 at 10:06 AM, <sergey_zhemzhit...@troika.ru> wrote: >> Hello all. >> >> I'm trying to use camel on the ServiceMix 4 cluster. >> >> According to http://camel.apache.org/clustering-and-loadbalancing.html > we >> can use NMR endpoint but there isn't an example there. >> I have tried to connect from one node of a cluster to another using >> camel's nmr component, but without success. An exception has occured. >> >> org.apache.servicemix.nmr.api.ServiceMixException: Could not dispatch >> exchange. No matching endpoints. >> at >> > org.apache.servicemix.nmr.core.FlowRegistryImpl.dispatch(FlowRegistryImpl.java:110)[58:org.apache.servicemix.nmr.core:1.3.0.fuse-00-00] >> at >> > org.apache.servicemix.nmr.core.ChannelImpl.dispatch(ChannelImpl.java:286)[58:org.apache.servicemix.nmr.core:1.3.0.fuse-00-00] >> at >> > org.apache.servicemix.nmr.core.ChannelImpl.send(ChannelImpl.java:117)[58:org.apache.servicemix.nmr.core:1.3.0.fuse-00-00] >> at >> > org.apache.servicemix.camel.nmr.ServiceMixProducer.process(ServiceMixProducer.java:86)[191:org.apache.servicemix.camel.component:4.3.0.fuse-01-00] >> at >> > org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:91)[92:org.apache.camel.camel-core:2.4.0.fuse-00-00] >> at >> > org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:62)[92:org.apache.camel.camel-core:2.4.0.fuse-00-00] >> at >> > org.apache.camel.processor.SendProcessor$2.doInAsyncProducer(SendProcessor.java:104)[92:org.apache.camel.camel-core:2.4.0.fuse-00-00] >> at >> > org.apache.camel.impl.ProducerCache.doInAsyncProducer(ProducerCache.java:272)[92:org.apache.camel.camel-core:2.4.0.fuse-00-00] >> at >> > org.apache.camel.processor.SendProcessor.process(SendProcessor.java:98)[92:org.apache.camel.camel-core:2.4.0.fuse-00-00] >> at >> > org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:91)[92:org.apache.camel.camel-core:2.4.0.fuse-00-00] >> at >> > org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:62)[92:org.apache.camel.camel-core:2.4.0.fuse-00-00] >> at >> > org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:98)[92:org.apache.camel.camel-core:2.4.0.fuse-00-00] >> at >> > org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:89)[92:org.apache.camel.camel-core:2.4.0.fuse-00-00] >> >> Is it possible to use clustered endpoints in camel? >> >> >> Best Regards, >> Sergey > > > > -- > Claus Ibsen > ----------------- > FuseSource > Email: cib...@fusesource.com > Web: http://fusesource.com > Twitter: davsclaus > Blog: http://davsclaus.blogspot.com/ > Author of Camel in Action: http://www.manning.com/ibsen/ > > > -- Claus Ibsen ----------------- FuseSource Email: cib...@fusesource.com Web: http://fusesource.com Twitter: davsclaus Blog: http://davsclaus.blogspot.com/ Author of Camel in Action: http://www.manning.com/ibsen/
