activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From magellings <mark.gelli...@qg.com>
Subject camel delayer with transaction/reliablity
Date Thu, 25 Feb 2010 14:53:46 GMT

Hello.  When using the camel delayer the camel consumer takes a message off
the queue and sleeps the specified time.  You can see in the web console
that the messages received column indicates a message was received, it then
waits X amount of time, and then forwards the message to the destination
queue.

>From what I understand, this should be done in a transaction so as if during
the sleep the broker goes down the message isn't lost.  This is not the
case.  For me if I stop the broker the message is indeed lost.  This becomes
more of a problem when you are dealing with longer sleep times (e.g. 60
minutes).

Should the camel delayer be consuming inside a transaction by default?  If
not is there a way to configure this in the activemq configuration?

My current configuration:

<camelContext id="camel"
xmlns="http://activemq.apache.org/camel/schema/spring">
 
     <!-- You can use a <package> element for each root package to search
for Java routes -->
     <!--<package>org.foo.bar</package>-->
 
     <!-- You can use Spring XML syntax to define the routes here using the
<route> element -->
     
     <route>
       <from uri="activemq:delayedSyncQueue"/>
       <delayer>
         <simple>header.delayme</simple>
         <to uri="activemq:syncQueue21"/>
       </delayer>
     </route>

   </camelContext>
 
   <!--
     ** Lets configure some Camel endpoints
     **
     ** http://activemq.apache.org/camel/components.html
     -->
 
   <!-- configure the camel activemq component to use the current broker -->
   <bean id="activemq"
class="org.apache.activemq.camel.component.ActiveMQComponent" >
     <property name="connectionFactory">
       <bean class="org.apache.activemq.ActiveMQConnectionFactory">
         <property name="brokerURL"
value="vm://localhost?create=false&amp;waitForStart=10000" />
         <property name="userName" value="${activemq.username}"/>
         <property name="password" value="${activemq.password}"/>
       </bean>
     </property>
   </bean>
-- 
View this message in context: http://old.nabble.com/camel-delayer-with-transaction-reliablity-tp27714449p27714449.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.


Mime
View raw message