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,endpoint=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/}soapExtractor,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/}getPerson,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/";><SOAP-ENV:Header/
<SOAP-ENV:Body><wn1:getPerson
xmlns:wn1="http://systinet.com/wsdl/com/cexp/ws/test/"/></SOAP-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/}soapExtractor,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/}soapInjector,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,endpoint=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/}soapExtractor,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://localhost: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
