so I sorted that error but persistent messages are destroyed by camel routes. As soon as camel moves a persistent message from the src topic to the dest topic, it's no longer persistent and is discarded on restart. Even if the route is transacted. Of course, I'm prolly not understanding what transacted means in this case.
I'm just trying to send a persistent message to a topic and have it routed as a persistent message to another topic. Is this possible without transaction specific code in the clients? Alistair -- mov eax,1 mov ebx,0 int 80h On 23 Jun 2011, at 12:41, Alistair Young wrote: > forgot to add transacted to the route: > > <route> > <from uri="activemq:topic:src"/> > <transacted /> > <to uri="activemq:topic:dest"/> > </route> > > but I just get the error: > > Invalid content was found starting with element 'transacted'. One of .. > expected > > Alistair > > -- > mov eax,1 > mov ebx,0 > int 80h > > > > > On 23 Jun 2011, at 12:00, Alistair Young wrote: > >> If I declare a route: >> >> <from uri="activemq:topic:src"/> >> <to uri="activemq:topic:dest"/> >> >> when I restart tomcat, the activemq:topic:src is still there as it has >> persistent messages but the activemq:topic:dest topic disappears along with >> all messages waiting for durable subscribers in it. >> >> Camel takes all the messages from dest and puts them in src, and they are >> all then lost as src is destroyed on restart. Somehow the messages are not >> marked as persistent in the dest topic. >> >> I've tried transacted routing but it still doesn't work. I'm using ruby >> clients over STOMP to send and receive persistent messages via the route: >> >> <broker brokerName="matrixBroker" id="matrixBrokerID" useJmx="true" >> persistent="true" xmlns="http://activemq.apache.org/schema/core";> >> <transportConnectors> >> <transportConnector uri="tcp://localhost:61616" /> >> <transportConnector name="stomp" uri="stomp://localhost:61613"/> >> </transportConnectors> >> </broker> >> >> <bean id="jmsConnectionFactory" >> class="org.apache.activemq.ActiveMQConnectionFactory" >> depends-on="matrixBrokerID"> >> <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="connectionFactory" ref="jmsConnectionFactory"/> >> <property name="transacted" value="true"/> >> <property name="transactionManager" >> ref="jmsTransactionManager"/> >> </bean> >> >> >> can anyone help please? >> >> thanks, >> >> Alistair >> >> -- >> mov eax,1 >> mov ebx,0 >> int 80h >> >> >> >> >
