You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@servicemix.apache.org by arun kumar <ar...@gmail.com> on 2014/03/25 12:39:17 UTC

JBI cluster not working with ActiveMQPool

Hi All,

I am trying to test the JBI clustering with the servicemix version 4.5.3,
smx-http Binding component and ActiveMQ ( network of brokers ).
I have the consumer endpoint deployed on instance 1 and the provider
endpoint deployed on instance 2 successfully.

I have both the activeMQ instances interconnected by a network of brokers.

I am getting log of successful deployment and publishing of my service when
deployed on instance 1, but
while deploying the service on instance 1 do we get the evidence of service
being registered over the cluster from logs on instance 2?
Similarly for instance 1 when service is  deployed on instance 2?
I don't see any thing  happening of this sort on the Smx instances.

I guess I am missing a step somewhere not able to figure out where?

Can anyone throw some light on this if you have got the JBI clustering to
work?

Thanks in advance,
Arun
 

*My bean for instance 1 is getting defined but I don't see the service
endpoint getting published on the instnace 2:*
11:44:42,281 | INFO  | ESB/Test1/deploy | DefaultListableBeanFactory       |
46 - org.springframework.beans - 3.0.7.RELEASE | Pre-instantiating
singletons in
org.springframework.beans.factory.support.DefaultListableBeanFactory@4096b7:
defining beans
[org.apache.servicemix.http.endpoints.HttpSoapConsumerEndpoint#0,org.apache.servicemix.jbi.cluster.engine.OsgiSimpleClusterRegistration#0];
parent: org.apache.servicemix.common.xbean.SimpleBeanFactory@96836c


*when I try to access the consumer endpoint I get the error (Could not
dispatch exchange no matching end points found):*
11:45:31,675 | WARN  | qtp26051605-129  | NMR                              |
193 - org.apache.servicemix.nmr.core - 1.6.1 | Error processing exchange [
  id:        978509557-50994-1395743863697-0-8
  mep:       InOut
  status:    Active
  role:      Consumer
  target:   
PropertyMatchingReference[{SERVICE_NAME={http://jbimulti2.iaas.uni-stuttgart.de/taxiscenario}httpSoapProvider}]
  operation:
{http://jbimulti2.iaas.uni-stuttgart.de/taxiscenario}EchoServiceOperation
  properties: [
      org.apache.servicemix.senderEndpoint =
{http://jbimulti2.iaas.uni-stuttgart.de/taxiscenario}httpSoapConsumer:TaxiProviderHttpSoapConsumerEndpoint
      javax.jbi.messaging.MessageExchange =
org.apache.servicemix.jbi.runtime.impl.InOutImpl@4f68aa
      javax.jbi.messaging.sendSync = <null>
      javax.jbi.InterfaceName = <null>
      javax.jbi.transaction.jta = <null>
      org.apache.servicemix.correlationId =
978509557-50994-1395743863697-0-8
      javax.jbi.ServiceName =
{http://jbimulti2.iaas.uni-stuttgart.de/taxiscenario}httpSoapProvider
  ]
]

org.apache.servicemix.nmr.api.ServiceMixException: Could not dispatch
exchange. No matching endpoints.
	at
org.apache.servicemix.nmr.core.FlowRegistryImpl.dispatch(FlowRegistryImpl.java:123)[193:org.apache.servicemix.nmr.core:1.6.1]
	at
org.apache.servicemix.nmr.core.ChannelImpl.dispatch(ChannelImpl.java:308)[193:org.apache.servicemix.nmr.core:1.6.1]
	at 


*Consumer endpoint deployed on Instance 1:*
<http:soap-consumer service="tx:httpSoapConsumer"
		endpoint="TaxiProviderHttpSoapConsumerEndpoint" 
	
locationURI="http://localhost:8163/httpSoapConsumer/TaxiProviderHttpSoapConsumerEndpoint"
		targetService="tx:httpSoapProvider"
		targetEndpoint="httpSoapProviderEndpoint" wsdl="classpath:service.wsdl"
		useJbiWrapper="false"
		/>
		
	<bean
class="org.apache.servicemix.jbi.cluster.engine.OsgiSimpleClusterRegistration">
  		<property name="serviceName" value="tx:httpSoapConsumer" />
  		<property name="endpointName"
value="TaxiProviderHttpSoapConsumerEndpoint" />
	</bean>		


*Provider endpoint ( Clustered ) deployed on Instance 2:*
<http:soap-provider service="tx:httpSoapProvider"
                 endpoint="httpSoapProviderEndpoint"
				
locationURI="http://localhost:8080/ESBPerformanceEchoServiceWithResponse/services/EchoServiceWithResponse/"
                 interfaceName="tx:EchoServicePortType"
         		 wsdl="classpath:service.wsdl"
         		 useJbiWrapper="false"
         		 validateWsdl="false"/>
				 
	<bean
class="org.apache.servicemix.jbi.cluster.engine.OsgiSimpleClusterRegistration">
  		<property name="serviceName" value="tx:httpSoapProvider" />
  		<property name="endpointName" value="httpSoapProviderEndpoint" />


*jbi-cluster.xml from the JBI cluster config:*
<blueprint xmlns="http://www.osgi.org/xmlns/blueprint/v1.0.0"
          
xmlns:cm="http://aries.apache.org/blueprint/xmlns/blueprint-cm/v1.0.0"
          
xmlns:ext="http://aries.apache.org/blueprint/xmlns/blueprint-ext/v1.0.0">

    <bean id="clusterEngine"
class="org.apache.servicemix.jbi.cluster.engine.ClusterEngine"
init-method="afterPropertiesSet" destroy-method="destroy">
        <property name="pool" ref="pool" />
        <property name="name" value="${clusterName}" />
    </bean>

    <bean id="pool"
class="org.apache.servicemix.jbi.cluster.requestor.ActiveMQJmsRequestorPool"
init-method="afterPropertiesSet" destroy-method="destroy">
        <property name="connectionFactory" ref="connectionFactory" />
        <property name="destinationName" value="${destinationName}" />
    </bean>

    <reference-list id="clusterRegistrations"
              
interface="org.apache.servicemix.jbi.cluster.engine.ClusterRegistration"
               availability="optional">
       <reference-listener ref="clusterEngine" bind-method="register"
unbind-method="unregister" />
    </reference-list>

    <reference id="connectionFactory"
interface="javax.jms.ConnectionFactory" />

    <service ref="clusterEngine">
        <interfaces>
            <value>org.apache.servicemix.nmr.api.Endpoint</value>
            <value>org.apache.servicemix.nmr.api.event.Listener</value>
           
<value>org.apache.servicemix.nmr.api.event.EndpointListener</value>
           
<value>org.apache.servicemix.nmr.api.event.ExchangeListener</value>
        </interfaces>
        <service-properties>
            <entry key="NAME" value="${clusterName}" />
        </service-properties>
    </service>

    <ext:property-placeholder placeholder-prefix="$["
placeholder-suffix="]">
        <ext:default-properties>
            <ext:property name="servicemix.cluster.destination"
value="org.apache.servicemix.jbi.cluster"/>
        </ext:default-properties>
    </ext:property-placeholder>

    <cm:property-placeholder
persistent-id="org.apache.servicemix.jbi.cluster.config">
        <cm:default-properties>
            <cm:property name="clusterName" value="$[karaf.name]"/>
            <cm:property name="destinationName"
value="$[servicemix.cluster.destination]"/>
        </cm:default-properties>
    </cm:property-placeholder>

</blueprint>



--
View this message in context: http://servicemix.396122.n5.nabble.com/JBI-cluster-not-working-with-ActiveMQPool-tp5719698.html
Sent from the ServiceMix - User mailing list archive at Nabble.com.

Re: JBI cluster not working with ActiveMQPool

Posted by Gert Vanthienen <ge...@gmail.com>.
Hi Arun,


If you're using JBI packaging (SU and SA) as you are doing, you don't
need that bean.  The JBI deployer will take care of correctly setting
up and registering your endpoints for you.

It's only needed when you use plain Spring files or bundles containing
Spring files to deploy your JBI endpoints. The Spring file will only
create the endpoint instances and this bean will make sure that they
get registered with the JBI runtime.


Regards,

Gert Vanthienen


On Fri, Apr 4, 2014 at 5:34 PM, arun kumar <ar...@gmail.com> wrote:
> Hello Gert,
>
> Thanks, I will try with the second option.
>
> Just one question though:
>
> <bean class="org.apache.servicemix.common.osgi.EndpointExporter" />
>
> I am using JBI packaged service assembly, Is EndpointExporter the right
> class to register the JBI endpoints ?.
> I get a null pointer exception in this class when deploying the service ie
> on this line inside deploy() api.
> "this.assemblyName = bundleContext.getBundle().getSymbolicName();".
> Basically the bundleContext is null, I will put an Activator class to set
> the bundleContext and test this perhaps.
>
> Thanks,
> Arun
>
>
>
> --
> View this message in context: http://servicemix.396122.n5.nabble.com/JBI-cluster-not-working-with-ActiveMQPool-tp5719698p5719885.html
> Sent from the ServiceMix - User mailing list archive at Nabble.com.

Re: JBI cluster not working with ActiveMQPool

Posted by arun kumar <ar...@gmail.com>.
Hello Gert,

Thanks, I will try with the second option.

Just one question though:

<bean class="org.apache.servicemix.common.osgi.EndpointExporter" />

I am using JBI packaged service assembly, Is EndpointExporter the right
class to register the JBI endpoints ?. 
I get a null pointer exception in this class when deploying the service ie
on this line inside deploy() api.
"this.assemblyName = bundleContext.getBundle().getSymbolicName();". 
Basically the bundleContext is null, I will put an Activator class to set
the bundleContext and test this perhaps.

Thanks,
Arun



--
View this message in context: http://servicemix.396122.n5.nabble.com/JBI-cluster-not-working-with-ActiveMQPool-tp5719698p5719885.html
Sent from the ServiceMix - User mailing list archive at Nabble.com.

Re: JBI cluster not working with ActiveMQPool

Posted by Gert Vanthienen <ge...@gmail.com>.
Hi Arun,


I have been looking into this a bit more, but seem to have a hard time
getting this to reproduce the exact same error that you're seeing.  I
suspect there either is a problem with the Filter in the
OsgiSimpleClusterRegistration (that's what I had earlier on with the
plain Spring syntax, where the ref fixed it) or something like that.
Perhaps with a simple example, we can troubleshoot this further but
I'm a bit out of ideas here at the moment, I'm afraid.

Given that JBI is deprecated, another option could be to look at an
alternative and explicitly introduce JMS endpoints between the two
HTTP endpoints.  Since you already have the ActiveMQ
network-of-brokers setup, you can put a message on a queue on machine
1 and receive it on machine 2.  You could do http -> jms on machine 1
and then jms -> http on machine 2.  If you ever migrate the
application the application to plain Camel routes, that approach would
remain the same.


Regards,

Gert Vanthienen


On Mon, Mar 31, 2014 at 10:54 PM, arun kumar <ar...@gmail.com> wrote:
> Hello Gert,
>
> Its an xbean.xml file package in a SU and the SU inturn packaged in a SA.
>
> Regards,
> Arun
>
>
>
> --
> View this message in context: http://servicemix.396122.n5.nabble.com/JBI-cluster-not-working-with-ActiveMQPool-tp5719698p5719771.html
> Sent from the ServiceMix - User mailing list archive at Nabble.com.

Re: JBI cluster not working with ActiveMQPool

Posted by arun kumar <ar...@gmail.com>.
Hello Gert,

Its an xbean.xml file package in a SU and the SU inturn packaged in a SA.

Regards,
Arun



--
View this message in context: http://servicemix.396122.n5.nabble.com/JBI-cluster-not-working-with-ActiveMQPool-tp5719698p5719771.html
Sent from the ServiceMix - User mailing list archive at Nabble.com.

Re: JBI cluster not working with ActiveMQPool

Posted by Gert Vanthienen <ge...@gmail.com>.
L.S.,


What kind of packaging are you using to deploy this application?  Is a
plain Spring file or a bundle you're using or is this an xbean.xml
file, packaged up in a SA/SU?


Regards,

Gert Vanthienen


On Mon, Mar 31, 2014 at 11:38 AM, arun kumar <ar...@gmail.com> wrote:
> Hello Gert,
>
> Thank you for the reply.
>
> I had modified as you had suggested by giving a reference to the endpoint,
> but I was getting a NullPointerException when trying to deploy the SU.
>
> Below is my consumer xbean.xml.
>
> Do you see anything wrong in my below config?
>
> Thanks,
> Arun
>
> <beans xmlns:http="http://servicemix.apache.org/http/1.0"
>     xmlns:tx="http://jbimulti2.iaas.uni-stuttgart.de/taxiscenario"
> xmlns="http://www.springframework.org/schema/beans"
>     xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
>     xsi:schemaLocation="
>        http://servicemix.apache.org/http/1.0
> http://servicemix.apache.org/schema/servicemix-http-2011.01.xsd
>        http://www.springframework.org/schema/beans
> http://www.springframework.org/schema/beans/spring-beans-2.0.xsd">
>
>      <classpath>
>                 <library>osgi:org.apache.servicemix.jbi.cluster.engine</library>
>         </classpath>
>
>     <http:soap-consumer id="soapConsumer" service="tx:httpSoapConsumer"
>                 endpoint="TaxiProviderHttpSoapConsumerEndpoint"
>
> locationURI="http://localhost:8163/httpSoapConsumer/TaxiProviderHttpSoapConsumerEndpoint"
>                 targetService="tx:httpSoapProvider"
>                 targetEndpoint="httpSoapProviderEndpoint" wsdl="classpath:service.wsdl"
>                 useJbiWrapper="false"
>                 />
>
>         <bean
> class="org.apache.servicemix.jbi.cluster.engine.OsgiSimpleClusterRegistration">
>                 <property name="endpoint" ref="soapConsumer" />
>         </bean>
>
>         *<bean class="org.apache.servicemix.common.osgi.EndpointExporter" />*
>
> </beans>
>
> <task-id>deploy</task-id>
>                         <task-result>FAILED</task-result>
>                         <message-type>ERROR</message-type>
>
> <task-status-msg><msg-loc-info><loc-token/><loc-message>Could not deploy
> xbean service unit</loc-message></msg-loc-info></task-status-msg>
>
> Caused by: java.lang.NullPointerException
>         at
> org.apache.servicemix.common.osgi.EndpointExporter.deploy(EndpointExporter.java:110)
>         at
> org.apache.servicemix.common.osgi.EndpointExporter.afterPropertiesSet(EndpointExporter.java:184)
>         at
> org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.invokeInitMethods(AbstractAutowireCapableBeanFactory.java:1479)
>         at
> org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.initializeBean(AbstractAutowireCapableBeanFactory.java:1419)
>         ... 27 more
>
>
>
> --
> View this message in context: http://servicemix.396122.n5.nabble.com/JBI-cluster-not-working-with-ActiveMQPool-tp5719698p5719766.html
> Sent from the ServiceMix - User mailing list archive at Nabble.com.

Re: JBI cluster not working with ActiveMQPool

Posted by arun kumar <ar...@gmail.com>.
Hello Gert,

Thank you for the reply.

I had modified as you had suggested by giving a reference to the endpoint,
but I was getting a NullPointerException when trying to deploy the SU.

Below is my consumer xbean.xml.

Do you see anything wrong in my below config?

Thanks,
Arun

<beans xmlns:http="http://servicemix.apache.org/http/1.0"
    xmlns:tx="http://jbimulti2.iaas.uni-stuttgart.de/taxiscenario"
xmlns="http://www.springframework.org/schema/beans"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xsi:schemaLocation="
       http://servicemix.apache.org/http/1.0
http://servicemix.apache.org/schema/servicemix-http-2011.01.xsd
       http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans-2.0.xsd">
	
     <classpath>
		<library>osgi:org.apache.servicemix.jbi.cluster.engine</library>
	</classpath>	
	   
    <http:soap-consumer id="soapConsumer" service="tx:httpSoapConsumer"
		endpoint="TaxiProviderHttpSoapConsumerEndpoint" 
	
locationURI="http://localhost:8163/httpSoapConsumer/TaxiProviderHttpSoapConsumerEndpoint"
		targetService="tx:httpSoapProvider"
		targetEndpoint="httpSoapProviderEndpoint" wsdl="classpath:service.wsdl"
		useJbiWrapper="false"
		/>
		
	<bean
class="org.apache.servicemix.jbi.cluster.engine.OsgiSimpleClusterRegistration">
  		<property name="endpoint" ref="soapConsumer" />
	</bean>		
	
	*<bean class="org.apache.servicemix.common.osgi.EndpointExporter" />*

</beans>

<task-id>deploy</task-id>
                        <task-result>FAILED</task-result>
                        <message-type>ERROR</message-type>
                       
<task-status-msg><msg-loc-info><loc-token/><loc-message>Could not deploy
xbean service unit</loc-message></msg-loc-info></task-status-msg>

Caused by: java.lang.NullPointerException
        at
org.apache.servicemix.common.osgi.EndpointExporter.deploy(EndpointExporter.java:110)
        at
org.apache.servicemix.common.osgi.EndpointExporter.afterPropertiesSet(EndpointExporter.java:184)
        at
org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.invokeInitMethods(AbstractAutowireCapableBeanFactory.java:1479)
        at
org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.initializeBean(AbstractAutowireCapableBeanFactory.java:1419)
        ... 27 more



--
View this message in context: http://servicemix.396122.n5.nabble.com/JBI-cluster-not-working-with-ActiveMQPool-tp5719698p5719766.html
Sent from the ServiceMix - User mailing list archive at Nabble.com.

Re: JBI cluster not working with ActiveMQPool

Posted by Gert Vanthienen <ge...@gmail.com>.
L.S.,


If you're using plain Spring files to deploy those JBI endpoints, you
probably have to refer to the endpoint directly instead of using the
endpointName/serviceName properties.  Add an id to the
http:soap-consumer endpoint and then refer to the id with the cluster
registration.

  <bean class="org.apache.servicemix.jbi.cluster.engine.OsgiSimpleClusterRegistration">
    <property name="endpoint" ref="httpConsumer" />
  </bean>


Regards,

Gert Vanthienen


On Tue, Mar 25, 2014 at 12:39 PM, arun kumar <ar...@gmail.com> wrote:
> Hi All,
>
> I am trying to test the JBI clustering with the servicemix version 4.5.3,
> smx-http Binding component and ActiveMQ ( network of brokers ).
> I have the consumer endpoint deployed on instance 1 and the provider
> endpoint deployed on instance 2 successfully.
>
> I have both the activeMQ instances interconnected by a network of brokers.
>
> I am getting log of successful deployment and publishing of my service when
> deployed on instance 1, but
> while deploying the service on instance 1 do we get the evidence of service
> being registered over the cluster from logs on instance 2?
> Similarly for instance 1 when service is  deployed on instance 2?
> I don't see any thing  happening of this sort on the Smx instances.
>
> I guess I am missing a step somewhere not able to figure out where?
>
> Can anyone throw some light on this if you have got the JBI clustering to
> work?
>
> Thanks in advance,
> Arun
>
>
> *My bean for instance 1 is getting defined but I don't see the service
> endpoint getting published on the instnace 2:*
> 11:44:42,281 | INFO  | ESB/Test1/deploy | DefaultListableBeanFactory       |
> 46 - org.springframework.beans - 3.0.7.RELEASE | Pre-instantiating
> singletons in
> org.springframework.beans.factory.support.DefaultListableBeanFactory@4096b7:
> defining beans
> [org.apache.servicemix.http.endpoints.HttpSoapConsumerEndpoint#0,org.apache.servicemix.jbi.cluster.engine.OsgiSimpleClusterRegistration#0];
> parent: org.apache.servicemix.common.xbean.SimpleBeanFactory@96836c
>
>
> *when I try to access the consumer endpoint I get the error (Could not
> dispatch exchange no matching end points found):*
> 11:45:31,675 | WARN  | qtp26051605-129  | NMR                              |
> 193 - org.apache.servicemix.nmr.core - 1.6.1 | Error processing exchange [
>   id:        978509557-50994-1395743863697-0-8
>   mep:       InOut
>   status:    Active
>   role:      Consumer
>   target:
> PropertyMatchingReference[{SERVICE_NAME={http://jbimulti2.iaas.uni-stuttgart.de/taxiscenario}httpSoapProvider}]
>   operation:
> {http://jbimulti2.iaas.uni-stuttgart.de/taxiscenario}EchoServiceOperation
>   properties: [
>       org.apache.servicemix.senderEndpoint =
> {http://jbimulti2.iaas.uni-stuttgart.de/taxiscenario}httpSoapConsumer:TaxiProviderHttpSoapConsumerEndpoint
>       javax.jbi.messaging.MessageExchange =
> org.apache.servicemix.jbi.runtime.impl.InOutImpl@4f68aa
>       javax.jbi.messaging.sendSync = <null>
>       javax.jbi.InterfaceName = <null>
>       javax.jbi.transaction.jta = <null>
>       org.apache.servicemix.correlationId =
> 978509557-50994-1395743863697-0-8
>       javax.jbi.ServiceName =
> {http://jbimulti2.iaas.uni-stuttgart.de/taxiscenario}httpSoapProvider
>   ]
> ]
>
> org.apache.servicemix.nmr.api.ServiceMixException: Could not dispatch
> exchange. No matching endpoints.
>         at
> org.apache.servicemix.nmr.core.FlowRegistryImpl.dispatch(FlowRegistryImpl.java:123)[193:org.apache.servicemix.nmr.core:1.6.1]
>         at
> org.apache.servicemix.nmr.core.ChannelImpl.dispatch(ChannelImpl.java:308)[193:org.apache.servicemix.nmr.core:1.6.1]
>         at
>
>
> *Consumer endpoint deployed on Instance 1:*
> <http:soap-consumer service="tx:httpSoapConsumer"
>                 endpoint="TaxiProviderHttpSoapConsumerEndpoint"
>
> locationURI="http://localhost:8163/httpSoapConsumer/TaxiProviderHttpSoapConsumerEndpoint"
>                 targetService="tx:httpSoapProvider"
>                 targetEndpoint="httpSoapProviderEndpoint" wsdl="classpath:service.wsdl"
>                 useJbiWrapper="false"
>                 />
>
>         <bean
> class="org.apache.servicemix.jbi.cluster.engine.OsgiSimpleClusterRegistration">
>                 <property name="serviceName" value="tx:httpSoapConsumer" />
>                 <property name="endpointName"
> value="TaxiProviderHttpSoapConsumerEndpoint" />
>         </bean>
>
>
> *Provider endpoint ( Clustered ) deployed on Instance 2:*
> <http:soap-provider service="tx:httpSoapProvider"
>                  endpoint="httpSoapProviderEndpoint"
>
> locationURI="http://localhost:8080/ESBPerformanceEchoServiceWithResponse/services/EchoServiceWithResponse/"
>                  interfaceName="tx:EchoServicePortType"
>                          wsdl="classpath:service.wsdl"
>                          useJbiWrapper="false"
>                          validateWsdl="false"/>
>
>         <bean
> class="org.apache.servicemix.jbi.cluster.engine.OsgiSimpleClusterRegistration">
>                 <property name="serviceName" value="tx:httpSoapProvider" />
>                 <property name="endpointName" value="httpSoapProviderEndpoint" />
>
>
> *jbi-cluster.xml from the JBI cluster config:*
> <blueprint xmlns="http://www.osgi.org/xmlns/blueprint/v1.0.0"
>
> xmlns:cm="http://aries.apache.org/blueprint/xmlns/blueprint-cm/v1.0.0"
>
> xmlns:ext="http://aries.apache.org/blueprint/xmlns/blueprint-ext/v1.0.0">
>
>     <bean id="clusterEngine"
> class="org.apache.servicemix.jbi.cluster.engine.ClusterEngine"
> init-method="afterPropertiesSet" destroy-method="destroy">
>         <property name="pool" ref="pool" />
>         <property name="name" value="${clusterName}" />
>     </bean>
>
>     <bean id="pool"
> class="org.apache.servicemix.jbi.cluster.requestor.ActiveMQJmsRequestorPool"
> init-method="afterPropertiesSet" destroy-method="destroy">
>         <property name="connectionFactory" ref="connectionFactory" />
>         <property name="destinationName" value="${destinationName}" />
>     </bean>
>
>     <reference-list id="clusterRegistrations"
>
> interface="org.apache.servicemix.jbi.cluster.engine.ClusterRegistration"
>                availability="optional">
>        <reference-listener ref="clusterEngine" bind-method="register"
> unbind-method="unregister" />
>     </reference-list>
>
>     <reference id="connectionFactory"
> interface="javax.jms.ConnectionFactory" />
>
>     <service ref="clusterEngine">
>         <interfaces>
>             <value>org.apache.servicemix.nmr.api.Endpoint</value>
>             <value>org.apache.servicemix.nmr.api.event.Listener</value>
>
> <value>org.apache.servicemix.nmr.api.event.EndpointListener</value>
>
> <value>org.apache.servicemix.nmr.api.event.ExchangeListener</value>
>         </interfaces>
>         <service-properties>
>             <entry key="NAME" value="${clusterName}" />
>         </service-properties>
>     </service>
>
>     <ext:property-placeholder placeholder-prefix="$["
> placeholder-suffix="]">
>         <ext:default-properties>
>             <ext:property name="servicemix.cluster.destination"
> value="org.apache.servicemix.jbi.cluster"/>
>         </ext:default-properties>
>     </ext:property-placeholder>
>
>     <cm:property-placeholder
> persistent-id="org.apache.servicemix.jbi.cluster.config">
>         <cm:default-properties>
>             <cm:property name="clusterName" value="$[karaf.name]"/>
>             <cm:property name="destinationName"
> value="$[servicemix.cluster.destination]"/>
>         </cm:default-properties>
>     </cm:property-placeholder>
>
> </blueprint>
>
>
>
> --
> View this message in context: http://servicemix.396122.n5.nabble.com/JBI-cluster-not-working-with-ActiveMQPool-tp5719698.html
> Sent from the ServiceMix - User mailing list archive at Nabble.com.