Guillaume,

I updated and rebuilt yesterday (12/1), but am still seeing this problem.

regards,
/jonathan

> -----Original Message-----
> From: Guillaume Nodet [mailto:[EMAIL PROTECTED]
> Sent: Thursday, December 01, 2005 1:47 PM
> To: [email protected]
> Subject: Re: [servicemix-user] HttpBinding + ChainedComponent 
> + JmsFlow
> = Unexpected Behavior
> 
> 
> A bug on the jms flow has been introduced at Wed Nov 30 
> 16:31:08 2005 UTC
> and fixed at  Wed Nov 30 16:52:10 2005 UTC.
>  Between these 21 minutes, the jms flow was not starting 
> queue consumers.
> Would it be possible that you updated just at this time ? ( 
> You wrote 16:40)
> Could you try to update your code base (or at least the jms 
> flow) to the 
> latest svn head and
> see if it changes something ?
> 
> Cheers,
> Guillaume Nodet/
> /
> [EMAIL PROTECTED] wrote:
> 
> >Greetings ServiceMix users (and developers),
> >
> >I have been working with a simple implementation that 
> extends the basic HTTP
> >example in the following way: An HttpBindingComponent receives a SOAP
> >request, which is then forwarded to a ChainedComponent that 
> is responsible
> >for calling XsltComponents to extract the XML payload from 
> the SOAP envelope
> >and then invoke a SaajBindingComponent which calls an 
> existing web service.
> >Using the SedaFlow, this all works properly 
> (Http->Xslt->Saaj, and back
> >again). The MEP is your basic synchronous InOut pattern. The 
> next step in my
> >testing involved setting up two ServiceMix containers in a 
> cluster, using
> >the JmsFlow, and re-running the test from the SedaFlow (the 
> activation file
> >is attached). Using either the peer:// protocol or the 
> reliable:() protocol
> >for the JmsFlow, the initial Http request is received and 
> forwarded on to
> >the ChainedComponent, but no response is ever returned. 
> Before I get ahead
> >of myself, this issue was encountered using the latest 
> version available
> >from svn (updated at 20051130 16:40 Denver/America) on the 
> 2.1 branch.
> >
> >The following is output from the SedaFlow, with debugging 
> turned on. This
> >output is from a test run with the expected results (that 
> is, the request to
> >the webservice receives a SOAP response):
> >
> >     19:34:06.391 EVENT  Starting Jetty/4.2.20RC0
> >     19:34:06.416 EVENT  Started ServletHttpContext[/]
> >     19:34:06.423 EVENT  Started SocketListener on 10.128.1.211:8912
> >     19:34:06.423 EVENT  Started [EMAIL PROTECTED]
> >     DEBUG [Timer-2] - AutoDeploymentService.monitorDirectory(508) |
> >Monitoring directory
> >/opt/apps/servicemix/servicemix-2.1-SNAPSHOT/examples/http-to
> -systinet-bindi
> >ng/./rootDir/bus_1/install for new or modified archives
> >     DEBUG [Timer-2] - AutoDeploymentService.monitorDirectory(508) |
> >Monitoring directory
> >/opt/apps/servicemix/servicemix-2.1-SNAPSHOT/examples/http-to
> -systinet-bindi
> >ng/./rootDir/bus_1/deploy for new or modified archives
> >     DEBUG [Timer-2] - AutoDeploymentService.monitorDirectory(508) |
> >Monitoring directory
> >/opt/apps/servicemix/servicemix-2.1-SNAPSHOT/examples/http-to
> -systinet-bindi
> >ng/./rootDir/bus_1/install for new or modified archives
> >     DEBUG [Timer-2] - AutoDeploymentService.monitorDirectory(508) |
> >Monitoring directory
> >/opt/apps/servicemix/servicemix-2.1-SNAPSHOT/examples/http-to
> -systinet-bindi
> >ng/./rootDir/bus_1/deploy for new or modified archives
> >     DEBUG [Timer-2] - AutoDeploymentService.monitorDirectory(508) |
> >Monitoring directory
> >/opt/apps/servicemix/servicemix-2.1-SNAPSHOT/examples/http-to
> -systinet-bindi
> >ng/./rootDir/bus_1/install for new or modified archives
> >     DEBUG [Timer-2] - AutoDeploymentService.monitorDirectory(508) |
> >Monitoring directory
> >/opt/apps/servicemix/servicemix-2.1-SNAPSHOT/examples/http-to
> -systinet-bindi
> >ng/./rootDir/bus_1/deploy for new or modified archives
> >     DEBUG [Timer-2] - AutoDeploymentService.monitorDirectory(508) |
> >Monitoring directory
> >/opt/apps/servicemix/servicemix-2.1-SNAPSHOT/examples/http-to
> -systinet-bindi
> >ng/./rootDir/bus_1/install for new or modified archives
> >     DEBUG [Timer-2] - AutoDeploymentService.monitorDirectory(508) |
> >Monitoring directory
> >/opt/apps/servicemix/servicemix-2.1-SNAPSHOT/examples/http-to
> -systinet-bindi
> >ng/./rootDir/bus_1/deploy for new or modified archives
> >     INFO [PoolThread-1] - 
> DeliveryChannelImpl.createExchangeFactory(165)
> >| default destination serviceName for httpReceiver =
> >{http://servicemix.org/demo/}chain
> >     DEBUG [PoolThread-1] - Broker.resolveAddress(373) | 
> Routing exchange
> >[EMAIL PROTECTED] to:
> >ServiceEndpoint[service={http://servicemix.org/demo/}chain,en
> dpoint=chain]
> >     DEBUG [PoolThread-1] - AbstractFlow.send(117) | Called Flow send
> >     DEBUG [PoolThread-1] - AbstractFlow.send(123) | 
> Attempting to aquire
> >lock...
> >     DEBUG [PoolThread-1] - AbstractFlow.send(125) | ...aquired lock;
> >about to doSend()...
> >     DEBUG [PoolThread-1] - AbstractFlow.doRouting(180) | Called Flow
> >doRouting
> >     DEBUG [PoolThread-1] - Broker.resolveAddress(373) | 
> Routing exchange
> >[EMAIL PROTECTED] to:
> >ServiceEndpoint[service={http://servicemix.org/demo/}soapExtr
actor,endpoint=
> >soapExtractor]
> >     DEBUG [PoolThread-1] - AbstractFlow.send(117) | Called Flow send
> >     DEBUG [PoolThread-1] - AbstractFlow.send(123) | 
> Attempting to aquire
> >lock...
> >     DEBUG [PoolThread-1] - AbstractFlow.send(125) | ...aquired lock;
> >about to doSend()...
> >     DEBUG [PoolThread-1] - AbstractFlow.doRouting(180) | Called Flow
> >doRouting
> >     DEBUG [PoolThread-1] - AbstractFlow.send(117) | Called Flow send
> >     DEBUG [PoolThread-1] - AbstractFlow.send(123) | 
> Attempting to aquire
> >lock...
> >     DEBUG [PoolThread-1] - AbstractFlow.send(125) | ...aquired lock;
> >about to doSend()...
> >     DEBUG [PoolThread-1] - AbstractFlow.doRouting(180) | Called Flow
> >doRouting
> >     DEBUG [PoolThread-1] - AbstractFlow.send(127) | ...completed
> >doSend().
> >     DEBUG [PoolThread-1] - AbstractFlow.send(129) | Attempting to
> >release lock...
> >     DEBUG [PoolThread-1] - AbstractFlow.send(131) | 
> ...released lock.
> >     DEBUG [PoolThread-1] - AbstractFlow.send(127) | ...completed
> >doSend().
> >     DEBUG [PoolThread-1] - AbstractFlow.send(129) | Attempting to
> >release lock...
> >     DEBUG [PoolThread-1] - AbstractFlow.send(131) | 
> ...released lock.
> >     DEBUG [PoolThread-1] - Broker.resolveAddress(373) | 
> Routing exchange
> >[EMAIL PROTECTED] to:
> >ServiceEndpoint[service={http://servicemix.org/demo/}getPerso
n,endpoint=getP
> >erson]
> >     DEBUG [PoolThread-1] - AbstractFlow.send(117) | Called Flow send
> >     DEBUG [PoolThread-1] - AbstractFlow.send(123) | 
> Attempting to aquire
> >lock...
> >     DEBUG [PoolThread-1] - AbstractFlow.send(125) | ...aquired lock;
> >about to doSend()...
> >     DEBUG [PoolThread-1] - AbstractFlow.doRouting(180) | Called Flow
> >doRouting
> >     DEBUG [PoolThread-1] - SaajMarshaler.createSOAPMessage(81) |
> ><SOAP-ENV:Envelope
> >xmlns:SOAP-ENV="http://schemas.xmlsoap.org/soap/envelope/";><S
OAP-ENV:Header/
> >  
> >
> >><SOAP-ENV:Body><wn1:getPerson
> >>    
> >>
> >xmlns:wn1="http://systinet.com/wsdl/com/cexp/ws/test/"/></SOA
> P-ENV:Body></SO
> >AP-ENV:Envelope>
> >     DEBUG [PoolThread-1] - AbstractFlow.send(117) | Called Flow send
> >     DEBUG [PoolThread-1] - AbstractFlow.send(123) | 
> Attempting to aquire
> >lock...
> >     DEBUG [PoolThread-1] - AbstractFlow.send(125) | ...aquired lock;
> >about to doSend()...
> >     DEBUG [PoolThread-1] - AbstractFlow.doRouting(180) | Called Flow
> >doRouting
> >     DEBUG [PoolThread-1] - AbstractFlow.send(127) | ...completed
> >doSend().
> >     DEBUG [PoolThread-1] - AbstractFlow.send(129) | Attempting to
> >release lock...
> >     DEBUG [PoolThread-1] - AbstractFlow.send(131) | 
> ...released lock.
> >     DEBUG [PoolThread-1] - AbstractFlow.send(127) | ...completed
> >doSend().
> >     DEBUG [PoolThread-1] - AbstractFlow.send(129) | Attempting to
> >release lock...
> >     DEBUG [PoolThread-1] - AbstractFlow.send(131) | 
> ...released lock.
> >     DEBUG [PoolThread-1] - Broker.resolveAddress(373) | 
> Routing exchange
> >[EMAIL PROTECTED] to:
> >ServiceEndpoint[service={http://servicemix.org/demo/}soapExtr
actor,endpoint=
> >soapExtractor]
> >     DEBUG [PoolThread-1] - AbstractFlow.send(117) | Called Flow send
> >     DEBUG [PoolThread-1] - AbstractFlow.send(123) | 
> Attempting to aquire
> >lock...
> >     DEBUG [PoolThread-1] - AbstractFlow.send(125) | ...aquired lock;
> >about to doSend()...
> >     DEBUG [PoolThread-1] - AbstractFlow.doRouting(180) | Called Flow
> >doRouting
> >     DEBUG [PoolThread-1] - AbstractFlow.send(117) | Called Flow send
> >     DEBUG [PoolThread-1] - AbstractFlow.send(123) | 
> Attempting to aquire
> >lock...
> >     DEBUG [PoolThread-1] - AbstractFlow.send(125) | ...aquired lock;
> >about to doSend()...
> >     DEBUG [PoolThread-1] - AbstractFlow.doRouting(180) | Called Flow
> >doRouting
> >     DEBUG [PoolThread-1] - AbstractFlow.send(127) | ...completed
> >doSend().
> >     DEBUG [PoolThread-1] - AbstractFlow.send(129) | Attempting to
> >release lock...
> >     DEBUG [PoolThread-1] - AbstractFlow.send(131) | 
> ...released lock.
> >     DEBUG [PoolThread-1] - AbstractFlow.send(127) | ...completed
> >doSend().
> >     DEBUG [PoolThread-1] - AbstractFlow.send(129) | Attempting to
> >release lock...
> >     DEBUG [PoolThread-1] - AbstractFlow.send(131) | 
> ...released lock.
> >     DEBUG [PoolThread-1] - Broker.resolveAddress(373) | 
> Routing exchange
> >[EMAIL PROTECTED] to:
> >ServiceEndpoint[service={http://servicemix.org/demo/}soapInje
ctor,endpoint=s
> >oapInjector]
> >     DEBUG [PoolThread-1] - AbstractFlow.send(117) | Called Flow send
> >     DEBUG [PoolThread-1] - AbstractFlow.send(123) | 
> Attempting to aquire
> >lock...
> >     DEBUG [PoolThread-1] - AbstractFlow.send(125) | ...aquired lock;
> >about to doSend()...
> >     DEBUG [PoolThread-1] - AbstractFlow.doRouting(180) | Called Flow
> >doRouting
> >     DEBUG [PoolThread-1] - AbstractFlow.send(117) | Called Flow send
> >     DEBUG [PoolThread-1] - AbstractFlow.send(123) | 
> Attempting to aquire
> >lock...
> >     DEBUG [PoolThread-1] - AbstractFlow.send(125) | ...aquired lock;
> >about to doSend()...
> >     DEBUG [PoolThread-1] - AbstractFlow.doRouting(180) | Called Flow
> >doRouting
> >     DEBUG [PoolThread-1] - AbstractFlow.send(127) | ...completed
> >doSend().
> >     DEBUG [PoolThread-1] - AbstractFlow.send(129) | Attempting to
> >release lock...
> >     DEBUG [PoolThread-1] - AbstractFlow.send(131) | 
> ...released lock.
> >     DEBUG [PoolThread-1] - AbstractFlow.send(127) | ...completed
> >doSend().
> >     DEBUG [PoolThread-1] - AbstractFlow.send(129) | Attempting to
> >release lock...
> >     DEBUG [PoolThread-1] - AbstractFlow.send(131) | 
> ...released lock.
> >     DEBUG [PoolThread-1] - AbstractFlow.send(117) | Called Flow send
> >     DEBUG [PoolThread-1] - AbstractFlow.send(123) | 
> Attempting to aquire
> >lock...
> >     DEBUG [PoolThread-1] - AbstractFlow.send(125) | ...aquired lock;
> >about to doSend()...
> >     DEBUG [PoolThread-1] - AbstractFlow.doRouting(180) | Called Flow
> >doRouting
> >     DEBUG [PoolThread-1] - AbstractFlow.send(127) | ...completed
> >doSend().
> >     DEBUG [PoolThread-1] - AbstractFlow.send(129) | Attempting to
> >release lock...
> >     DEBUG [PoolThread-1] - AbstractFlow.send(131) | 
> ...released lock.
> >     DEBUG [PoolThread-1] - AbstractFlow.send(127) | ...completed
> >doSend().
> >     DEBUG [PoolThread-1] - AbstractFlow.send(129) | Attempting to
> >release lock...
> >     DEBUG [PoolThread-1] - AbstractFlow.send(131) | 
> ...released lock.
> >     DEBUG [PoolThread-1] - AbstractFlow.send(117) | Called Flow send
> >     DEBUG [PoolThread-1] - AbstractFlow.send(123) | 
> Attempting to aquire
> >lock...
> >     DEBUG [PoolThread-1] - AbstractFlow.send(125) | ...aquired lock;
> >about to doSend()...
> >     DEBUG [PoolThread-1] - AbstractFlow.send(127) | ...completed
> >doSend().
> >     DEBUG [PoolThread-1] - AbstractFlow.send(129) | Attempting to
> >release lock...
> >     DEBUG [PoolThread-1] - AbstractFlow.send(131) | 
> ...released lock.
> >     DEBUG [Thread-9] - SedaQueue$1.run(218) |
> >[EMAIL PROTECTED] 
> dequeued exchange:
> >[EMAIL PROTECTED] [Thread-9] -
> >AbstractFlow.doRouting(180) | Called Flow doRouting
> >     DEBUG [Timer-2] - AutoDeploymentService.monitorDirectory(508) |
> >Monitoring directory
> >/opt/apps/servicemix/servicemix-2.1-SNAPSHOT/examples/http-to
> -systinet-bindi
> >ng/./rootDir/bus_1/install for new or modified archives
> >     DEBUG [Timer-2] - AutoDeploymentService.monitorDirectory(508) |
> >Monitoring directory
> >/opt/apps/servicemix/servicemix-2.1-SNAPSHOT/examples/http-to
> -systinet-bindi
> >ng/./rootDir/bus_1/deploy for new or modified archives
> >     INFO [ActiveMQ ShutdownHook] - BrokerContainerImpl.stop(195) |
> >ActiveMQ Message Broker 
> (ID:sandman.cexp.com-37491-1133404443024-1:0) is
> >shutting down
> >     INFO [ActiveMQ ShutdownHook] - BrokerConnectorImpl.stop(140) |
> >ActiveMQ connector stopped:
> >[EMAIL PROTECTED]://sandman.cexp.com:61616
> >     INFO [ActiveMQ ShutdownHook] - BrokerContainerImpl.stop(268) |
> >ActiveMQ JMS Message Broker 
> (ID:sandman.cexp.com-37491-1133404443024-1:0)
> >stopped
> >
> >Below this line is the output from a run using JmsFlow. As 
> you can see, the
> >output is much shorter because the thread of execution 
> appears to halt as
> >soon as the ChainedComponet is invoked and the 
> JmsSessionDispatcher thread
> >takes over. The ChainedComponent never calls any of its 
> services, as per the
> >configuration file (servicemix.xml, attached)
> >
> >     19:32:10.477 EVENT  Starting Jetty/4.2.20RC0
> >     19:32:10.494 EVENT  Started ServletHttpContext[/]
> >     19:32:10.497 EVENT  Started SocketListener on 10.128.1.211:8912
> >     19:32:10.497 EVENT  Started [EMAIL PROTECTED]
> >     INFO [main] - JMSFlow.start(216) | bus_1: Starting jms flow
> >     DEBUG [Timer-2] - AutoDeploymentService.monitorDirectory(508) |
> >Monitoring directory
> >/opt/apps/servicemix/servicemix-2.1-SNAPSHOT/examples/http-to
> -systinet-bindi
> >ng/./rootDir/bus_1/install for new or modified archives
> >     DEBUG [Timer-2] - AutoDeploymentService.monitorDirectory(508) |
> >Monitoring directory
> >/opt/apps/servicemix/servicemix-2.1-SNAPSHOT/examples/http-to
> -systinet-bindi
> >ng/./rootDir/bus_1/deploy for new or modified archives
> >     DEBUG [Timer-2] - AutoDeploymentService.monitorDirectory(508) |
> >Monitoring directory
> >/opt/apps/servicemix/servicemix-2.1-SNAPSHOT/examples/http-to
> -systinet-bindi
> >ng/./rootDir/bus_1/install for new or modified archives
> >     DEBUG [Timer-2] - AutoDeploymentService.monitorDirectory(508) |
> >Monitoring directory
> >/opt/apps/servicemix/servicemix-2.1-SNAPSHOT/examples/http-to
> -systinet-bindi
> >ng/./rootDir/bus_1/deploy for new or modified archives
> >     INFO [PoolThread-1] - 
> DeliveryChannelImpl.createExchangeFactory(165)
> >| default destination serviceName for httpReceiver =
> >{http://servicemix.org/demo/}chain
> >     DEBUG [PoolThread-1] - Broker.resolveAddress(373) | 
> Routing exchange
> >[EMAIL PROTECTED] to:
> >ServiceEndpoint[service={http://servicemix.org/demo/}chain,en
> dpoint=chain]
> >     DEBUG [PoolThread-1] - AbstractFlow.send(117) | Called Flow send
> >     DEBUG [PoolThread-1] - AbstractFlow.send(123) | 
> Attempting to aquire
> >lock...
> >     DEBUG [PoolThread-1] - AbstractFlow.send(125) | ...aquired lock;
> >about to doSend()...
> >     DEBUG [PoolThread-1] - AbstractFlow.send(127) | ...completed
> >doSend().
> >     DEBUG [PoolThread-1] - AbstractFlow.send(129) | Attempting to
> >release lock...
> >     DEBUG [JmsSessionDispatcher: 1] - AbstractFlow.doRouting(180) |
> >Called Flow doRouting
> >     DEBUG [JmsSessionDispatcher: 1] - Broker.resolveAddress(373) |
> >Routing exchange [EMAIL PROTECTED] to:
> >ServiceEndpoint[service={http://servicemix.org/demo/}soapExtr
actor,endpoint=
> >soapExtractor]
> >     DEBUG [JmsSessionDispatcher: 1] - 
> AbstractFlow.send(117) | Called
> >Flow send
> >     DEBUG [JmsSessionDispatcher: 1] - AbstractFlow.send(123) |
> >Attempting to aquire lock...
> >     DEBUG [JmsSessionDispatcher: 1] - AbstractFlow.send(125) |
> >...aquired lock; about to doSend()...
> >     DEBUG [JmsSessionDispatcher: 1] - AbstractFlow.send(127) |
> >...completed doSend().
> >     DEBUG [JmsSessionDispatcher: 1] - AbstractFlow.send(129) |
> >Attempting to release lock...
> >     DEBUG [JmsSessionDispatcher: 1] - AbstractFlow.send(131) |
> >...released lock.
> >     DEBUG [PoolThread-1] - AbstractFlow.send(131) | 
> ...released lock.
> >     DEBUG [Timer-2] - AutoDeploymentService.monitorDirectory(508) |
> >Monitoring directory
> >/opt/apps/servicemix/servicemix-2.1-SNAPSHOT/examples/http-to
> -systinet-bindi
> >ng/./rootDir/bus_1/install for new or modified archives
> >     DEBUG [Timer-2] - AutoDeploymentService.monitorDirectory(508) |
> >Monitoring directory
> >/opt/apps/servicemix/servicemix-2.1-SNAPSHOT/examples/http-to
> -systinet-bindi
> >ng/./rootDir/bus_1/deploy for new or modified archives
> >     INFO [ActiveMQ ShutdownHook] - BrokerContainerImpl.stop(195) |
> >ActiveMQ Message Broker 
> (ID:sandman.cexp.com-37478-1133404326792-5:0) is
> >shutting down
> >     INFO [ActiveMQ ShutdownHook] - BrokerConnectorImpl.stop(140) |
> >ActiveMQ connector stopped:
> >[EMAIL PROTECTED]://sandman.cexp.com:37484
> >     INFO [ActiveMQ ShutdownHook] - BrokerContainerImpl.stop(268) |
> >ActiveMQ JMS Message Broker 
> (ID:sandman.cexp.com-37478-1133404326792-5:0)
> >stopped
> >     INFO [ActiveMQ ShutdownHook] - BrokerContainerImpl.stop(195) |
> >ActiveMQ Message Broker 
> (ID:sandman.cexp.com-37478-1133404326792-1:0) is
> >shutting down
> >     INFO [ActiveMQ ShutdownHook] - BrokerConnectorImpl.stop(140) |
> >ActiveMQ connector stopped:
> >[EMAIL PROTECTED]://sandman.cexp.com:61616
> >     INFO [ActiveMQ ShutdownHook] - BrokerContainerImpl.stop(268) |
> >ActiveMQ JMS Message Broker 
> (ID:sandman.cexp.com-37478-1133404326792-1:0)
> >stopped
> >
> >Something isn't quite right here. I would expect that the 
> JmsFlow would
> >honor the InOut exchange, and invoke the configured beans 
> referenced by the
> >chained component, but for some reason the server is 
> behaving contrary to
> >this expectation. Is there an incompatibility between InOut 
> and the JmsFlow?
> >I am also curious as to why there are no error messages 
> thrown - the thread
> >of execution appears to exit cleanly, but there is no 
> response of fault
> >message. Any insight or help here would be greatly appreciated. The
> >configuration files follow in-line:
> >
> >*************************************************************
> ***************
> >*************************************************************
> ***************
> >**
> >[servicemix.xml]
> ><?xml version="1.0" encoding="UTF-8"?>
> ><beans xmlns="http://xbean.org/schemas/spring/1.0";
> >    xmlns:spring="http://xbean.org/schemas/spring/1.0";
> >    xmlns:sm="http://servicemix.org/config/1.0";
> >    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
> >    xsi:schemaLocation="http://xbean.org/schemas/spring/1.0
> >/opt/apps/servicemix/current/conf/spring-beans.xsd
> >http://servicemix.org/config/1.0
> >/opt/apps/servicemix/current/conf/servicemix.xsd"
> >    xmlns:foo="http://servicemix.org/demo/";>
> >
> >  <!-- the JBI container -->
> >
> >  <sm:container spring:id="jbi"
> >      name="bus_1"
> >      useMBeanServer="true"
> >      createMBeanServer="true"
> >      dumpStats="true"
> >      statsInterval="10">
> >
> >  <!--
> >  <sm:container spring:id="jbi"
> >      name="bus_1"
> >      useMBeanServer="true"
> >      createMBeanServer="true"
> >      dumpStats="true"
> >      statsInterval="10"
> >      flowName="jms">
> >  -->
> >  <!--
> >  <sm:container spring:id="jbi"
> >      name="bus_1"
> >      useMBeanServer="true"
> >      createMBeanServer="true"
> >      dumpStats="true"
> >      statsInterval="10"
> > 
> >flowName="jms?jmsURL=reliable:(tcp://localhost:61616,tcp://lo
> calhost:61618,t
> >cp://localhost:61614)">
> >   -->
> >
> >    <sm:activationSpecs>
> >        <!-- Create a http server binding on port 8912  and 
> have it forward
> >to the foo:stockQuote -->
> >      <sm:activationSpec componentName="httpReceiver"
> >          service="foo:httpReceiver"
> >          endpoint="httpReceiver"
> >          destinationService="foo:chain">
> >        <sm:component>
> >          <bean xmlns="http://xbean.org/schemas/spring/1.0";
> >              class="org.servicemix.components.http.HttpConnector">
> >            <property name="host" value="10.128.1.211"/>
> >            <property name="port" value="8912"/>
> >            <property name="defaultInOut" value="true"/>
> >          </bean>
> >        </sm:component>
> >      </sm:activationSpec>
> >
> >      <!-- Lets create a message router -->
> >      <sm:activationSpec componentName="chain" service="foo:chain">
> >        <sm:component>
> >          <bean xmlns=""
> >class="org.servicemix.components.util.ChainedComponent">
> >            <property name="services">
> >              <list>
> >                <bean class="javax.xml.namespace.QName">
> >                  <constructor-arg 
> value="http://servicemix.org/demo/"; />
> >                  <constructor-arg value="soapExtractor" />
> >                </bean>
> >
> >                <bean class="javax.xml.namespace.QName">
> >                  <constructor-arg 
> value="http://servicemix.org/demo/"; />
> >                  <constructor-arg value="getPerson" />
> >                </bean>
> >
> >                <bean class="javax.xml.namespace.QName">
> >                  <constructor-arg 
> value="http://servicemix.org/demo/"; />
> >                  <constructor-arg value="soapExtractor" />
> >                </bean>
> >
> >                <bean class="javax.xml.namespace.QName">
> >                  <constructor-arg 
> value="http://servicemix.org/demo/"; />
> >                  <constructor-arg value="soapInjector" />
> >                </bean>
> >
> >              </list>
> >            </property>
> >          </bean>
> >        </sm:component>
> >      </sm:activationSpec>
> >
> >      <!-- Provide a service to strip soap headers -->
> >      <sm:activationSpec componentName="soapExtractor"
> >          service="foo:soapExtractor">
> >        <sm:component>
> >          <bean xmlns="http://xbean.org/schemas/spring/1.0";
> >              class="org.servicemix.components.xslt.XsltComponent">
> >            <property name="xsltResource" value="SoapExtractor.xsl"/>
> >          </bean>
> >        </sm:component>
> >      </sm:activationSpec>
> >
> >
> >      <sm:activationSpec componentName="soapInjector"
> >          service="foo:soapInjector">
> >        <sm:component>
> >          <bean xmlns="http://xbean.org/schemas/spring/1.0";
> >              class="org.servicemix.components.xslt.XsltComponent">
> >            <property name="xsltResource" value="SoapInjector.xsl"/>
> >          </bean>
> >        </sm:component>
> >      </sm:activationSpec>
> >
> >                <!-- This just invokes another service -->
> >      <sm:activationSpec componentName="getPerson"
> >          service="foo:getPerson"
> >          endpoint="getPerson">
> >        <sm:component>
> >          <bean xmlns="http://xbean.org/schemas/spring/1.0";
> >              class="org.servicemix.components.saaj.SaajBinding">
> >            <property name="soapEndpoint">
> >              <bean class="javax.xml.messaging.URLEndpoint">
> >                <constructor-arg
> >value="http://10.128.1.211:8080/systinet/server/CexpObjectTest/"/>
> >              </bean>
> >            </property>
> >          </bean>
> >        </sm:component>
> >      </sm:activationSpec>
> >    </sm:activationSpecs>
> >  </sm:container>
> >
> >  <bean id="broker" class="org.activemq.spring.BrokerFactoryBean">
> >     <property name="config" value="activemq.xml"/>
> >  </bean>
> ></beans>
> >
> >*************************************************************
> ***************
> >*************************************************************
> ***************
> >**
> >
> >[activemq.xml]
> ><?xml version="1.0" encoding="UTF-8"?>
> ><!DOCTYPE beans PUBLIC  "-//ACTIVEMQ//DTD//EN"
> >"http://activemq.org/dtd/activemq.dtd";>
> ><beans>
> >
> >  <!-- 
> ====================================================================
> >-->
> >  <!-- ActiveMQ Broker Configuration -->
> >  <!-- 
> ====================================================================
> >-->
> >  <broker>
> >    <connector>
> >      <tcpServerTransport uri="tcp://localhost:61616" backlog="1000"
> >useAsyncSend="true" maxOutstandingMessages="50"/>
> >    </connector>
> >
> >    <persistence>
> >      <cachePersistence>
> >        <journalPersistence directory="var/journal">
> >          <jdbcPersistence dataSourceRef="derby-ds"/>
> >        </journalPersistence>
> >      </cachePersistence>
> >    </persistence>
> >  </broker>
> >
> >  <!-- 
> ====================================================================
> >-->
> >  <!-- JDBC DataSource Configurations -->
> >  <!-- 
> ====================================================================
> >-->
> >
> >  <!-- The Derby Datasource that will be used by the Broker -->
> >  <bean id="derby-ds" class="org.apache.commons.dbcp.BasicDataSource"
> >destroy-method="close">
> >    <property name="driverClassName">
> >      <value>org.apache.derby.jdbc.EmbeddedDriver</value>
> >    </property>
> >    <property name="url">
> >      <!-- Use a URL like 
> 'jdbc:hsqldb:hsql://localhost:9001' if you want to
> >connect to a remote hsqldb -->
> >      <value>jdbc:derby:derbydb;create=true</value>
> >    </property>
> >    <property name="username">
> >      <value></value>
> >    </property>
> >    <property name="password">
> >      <value></value>
> >    </property>
> >    <property name="poolPreparedStatements">
> >      <value>true</value>
> >    </property>
> >  </bean>
> >
> >  <!-- The MYSQL Datasource that will be used by the Broker -->
> >  <bean id="mysql-ds"
> >    class="org.apache.commons.dbcp.BasicDataSource"
> >    destroy-method="close">
> >    <property name="driverClassName">
> >      <value>com.mysql.jdbc.Driver</value>
> >    </property>
> >    <property name="url">
> >      <value>jdbc:mysql://localhost/activemq</value>
> >    </property>
> >    <property name="username">
> >      <value>myname</value>
> >    </property>
> >    <property name="password">
> >      <value>mypassword</value>
> >    </property>
> >    <property name="poolPreparedStatements">
> >      <value>true</value>
> >    </property>
> >  </bean>
> ></beans>
> >
> >*************************************************************
> ***************
> >*************************************************************
> ***************
> >**
> >Thanks for your time.
> >/jonathan
> >
> >
> >  
> >
> 

Reply via email to