Yeah, I have understood it. It's a pitty that camel's nmr can't behave as
jbi nmr.
I far as I understand, it's impossible to use jbi functionality of
servicemix in camel too, at least until it won't be deployed as jbi
service unit.
Best Regards,
Sergey Zhemzhitsky
Information Technology Division
Troika Dialog, 4, Romanov lane, Moscow 125009, Russia
Phone. +7 495 2580500 ext. 1246
Guillaume Nodet <gno...@gmail.com>
25.11.2010 14:03
Please respond to
users@camel.apache.org
To
users@camel.apache.org
cc
Subject
Re: Is it possible to cluster camel endpoint?
Note that the cluster engine is a 'jbi' cluster engine and currently
only works with JBI endpoints. It's possible to use those with NMR
endpoints, but you'd have to use the JBI targetting system in order to
make that possible.
On Thu, Nov 25, 2010 at 11:16, Jérémie <jeremie.bre...@gmail.com> wrote:
> Hi,
>
> I have the same requirement : Using shared NMR endpoints with camel.
>
> After reading the source of the NMR implementation of smx :
> - NMR Endpoint are not automatically shared. You have to declare them
using
> a ClusterRegistration and configure the "JBI Cluster Engine" (smx come
with
> a spring xml with defaults values which should work - maybe just rename
the
> cluster of each smx instance)
>
> The registration is something like this :
>
> <bean
class="org.apache.servicemix.jbi.cluster.engine.OsgiSimpleClusterRegistration">
> <property name="endpointName" value="xxx" />
> </bean>
>
>
> I managed to call from camel a remote "standard" nmr endpoint (in fact a
JBI
> Component), but this did'nt work with a nmr consumer created with camel.
In
> fact, only a NMR Endpoint producing message in his channel can be shared
> between node, because the ClusterEngine use hook through
EndpointListener,
> or something like that. Camel NMR Endpoint are just consumer, and in
this
> case, the ClusterEngine can't see it.
>
> Of course, i did'nt find any usefull documentation about this part, so i
can
> be wrong :-)
>
> In my project, i have replaced all nmr endpoint with activemq. I don't
see
> the benefice of using NMR Endpoints in a distributed environment (?).
>
>
> Jeremie
>
> On Thu, Nov 25, 2010 at 9:58 AM, <sergey_zhemzhit...@troika.ru> wrote:
>
>> I've removed the nmr. Exception
>> "org.apache.servicemix.nmr.api.ServiceMixException: Could not dispatch
>> exchange. No matching endpoints." still happens.
>>
>> Is NMR camel endpoint shared accross multiple nodes of a cluster? And
is
>> declaration of "org.apache.servicemix.common.osgi.EndpointExporter"
>> required?
>>
>> Accorging to the source code of EndpointExporter
>>
>> public Collection<Endpoint> getEndpoints() {
>> Collection<Endpoint> eps = this.endpoints;
>> if (eps == null) {
>> eps = this.applicationContext.getBeansOfType(Endpoint.class
>> ).values();
>> }
>> return eps;
>> }
>>
>> it requres org.apache.servicemix.common.Endpoint, so it is not
applicable
>> to org.apache.camel.Endpoint created by camel.
>>
>> I'm asking because I have a route that produces events and publishes
them
>> to a camel's nmr enpoint on one node of a cluster (separate servicemix
>> instance) and I have a route that listens to events on a canel's nmr
>> enpoint on the second node of the same cluster.
>>
>> I have changed etc/activemq-broker.xml on both nodes of a cluster so
that
>> they will know about each other
>>
>> node1:
>>
>> <networkConnectors>
>> <networkConnector uri="static://(tcp://localhost:62616)"
>> conduitSubscriptions="false"/>
>> </networkConnectors>
>>
>> node2:
>>
>> <networkConnectors>
>> <networkConnector uri="static://(tcp://localhost:63616)"
>> conduitSubscriptions="false"/>
>> </networkConnectors>
>>
>> How to make sure that the cluster is working and is it possible to
share
>> org.apache.camel.Endpoint accross the cluster?
>>
>>
>>
>>
>>
>> Claus Ibsen <claus.ib...@gmail.com>
>> 25.11.2010 11:09
>> Please respond to
>> users@camel.apache.org
>>
>>
>> To
>> users@camel.apache.org
>> cc
>>
>> Subject
>> Re: Is it possible to cluster camel endpoint?
>>
>>
>>
>>
>>
>>
>> Hi
>>
>> Try removing the nmr bean, as it should work out of the box, without
>> the need to specify such a bean.
>>
>> This should be removed:
>>
>> <bean id="nmr"
>> class="org.apache.servicemix.camel.nmr.ServiceMixComponent">
>> <property name="nmr">
>> <osgi:reference
>> interface="org.apache.servicemix.nmr.api.NMR"/>
>> </property>
>> </bean>
>>
>> On Thu, Nov 25, 2010 at 7:12 AM, <sergey_zhemzhit...@troika.ru> wrote:
>> > 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/
>> >
>> >
>>
>>
>>
>> --
>> 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/
>>
>>
>
--
Cheers,
Guillaume Nodet
------------------------
Blog: http://gnodet.blogspot.com/
------------------------
Open Source SOA
http://fusesource.com
