I've managed to sort it after reading around. Not really sure what the problem was but it's fine now :)
Alistair -- mov eax,1 mov ebx,0 int 80h On 21 Nov 2011, at 09:06, Alistair Young wrote: > I downloaded activemq 5.5.1 and can guarantee 2 out of 100 messages sent to > it are lost when using transacted routes (route A to route B below). Is this > the right place to ask for help? This is my actiemq/camel config. > > <beans > xmlns="http://www.springframework.org/schema/beans"; > xmlns:amq="http://activemq.apache.org/schema/core"; > xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"; > xsi:schemaLocation="http://www.springframework.org/schema/beans > http://www.springframework.org/schema/beans/spring-beans-2.0.xsd > http://activemq.apache.org/schema/core > http://activemq.apache.org/schema/core/activemq-core.xsd";> > > <broker xmlns="http://activemq.apache.org/schema/core"; > id="matrixBrokerID" > brokerName="matrixBroker" > useJmx="true" > persistent="true" > > destroyApplicationContextOnStop="true" > > dataDirectory="/Users/alistair/apps/dev/activemq/data"> > > <managementContext> > <managementContext createConnector="false"/> > </managementContext> > > <persistenceAdapter> > <kahaDB directory="/Users/alistair/apps/dev/activemq/data/kahadb"/> > </persistenceAdapter> > > > <transportConnectors> > <transportConnector name="openwire" uri="tcp://0.0.0.0:61616"/> > <transportConnector name="stomp" uri="stomp://0.0.0.0:61613"/> > </transportConnectors> > > </broker> > > <import resource="jetty.xml"/> > > <import resource="camel.xml"/> > > </beans> > > > <beans > xmlns="http://www.springframework.org/schema/beans"; > xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"; > xsi:schemaLocation="http://camel.apache.org/schema/spring > http://camel.apache.org/schema/spring/camel-spring.xsd > http://www.springframework.org/schema/beans > http://www.springframework.org/schema/beans/spring-beans.xsd";> > > <camelContext xmlns="http://camel.apache.org/schema/spring"; > > id="matrixRouter" > > trace="true"> > > <route> > <from uri="activemq:topic:A"/> > <transacted /> > <to uri="activemq:topic:B"/> > </route> > > </camelContext> > > <bean id="jmsConnectionFactory" > class="org.apache.activemq.ActiveMQConnectionFactory"> > <property name="brokerURL" > value="vm://matrixBroker?create=false"/> > </bean> > > <bean id="jmsTransactionManager" > class="org.springframework.jms.connection.JmsTransactionManager"> > <property name="connectionFactory" > ref="jmsConnectionFactory"/> > </bean> > > <bean id="activemq" > class="org.apache.activemq.camel.component.ActiveMQComponent" > > <property name="transacted" value="true"/> > <property name="transactionManager" ref="jmsTransactionManager"/> > </bean> > > </beans> > > > thanks, > > Alistair > > -- > mov eax,1 > mov ebx,0 > int 80h > > > >
