Re: Messages queue filtered depending on info received by another queue

[RomualdoGobbo]

camelContext.xml:
-------------------------------------------------------------------------->


<beans xmlns="http://www.springframework.org/schema/beans";
       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.5.xsd
       http://camel.apache.org/schema/spring
http://camel.apache.org/schema/spring/camel-spring.xsd";>
  
  <!-- START SNIPPET: example -->
  <camelContext id="Telelink-context" trace="true"
xmlns="http://camel.apache.org/schema/spring";>
        <template id="producer" />
        <consumerTemplate id="consumer" />

        <route>
<!--    <from uri="file:src/data?noop=true"/>  -->
                <from uri="file:src/data"/>
                <to uri="jms:toTelelinkQ"/>
        </route>

 <!-- OPEN Server Socket and send them to internal bean   -->
        <route>
 <!--           <from uri="timer://foo?period=5000"/>     -->
        <from uri="netty:tcp://localhost:5000?textline=true&amp;sync=true"/>
                <bean ref="myBeanId" method="getTelelinkCommand"/>
                <to uri="jms:MyQueue"/>
        </route>

    <!-- now command integration and lets write messages from the queue to a
directory     -->   
    <route>
                <from uri="jms:MyQueue"/>
                <to uri="file:target/outputFiles"/>
        </route>

    <!-- now lets write messages from the directory to some queues directory
-->      
    <route>
                <from uri="file:target/outputFiles"/>
                <to uri="jms:toDroolsQ"/>
                <to uri="jms:toTrackingQ"/>
        </route>
   
  </camelContext>
  

        <!-- lets configure Bean -->
        <bean id="myBeanId" class="newlog.camel.TelelinkCommandBean"/>

        <!-- lets configure the default ActiveMQ broker URL -->
        <bean id="jms" class="org.apache.camel.component.jms.JmsComponent">
                <property name="connectionFactory">
                <bean class="org.apache.activemq.ActiveMQConnectionFactory">
<!--                    <property name="brokerURL"
value="vm://localhost?broker.persistent=false"/>  -->
                                <property name="brokerURL" 
value="tcp://localhost:61616"/>  
                </bean>
        </property>
        </bean>
  <!-- END SNIPPET: example -->

</beans>
-- 
View this message in context: 
http://camel.465427.n5.nabble.com/Messages-queue-filtered-depending-on-info-received-by-another-queue-tp2805911p2807533.html
Sent from the Camel Development mailing list archive at Nabble.com.