camel-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From RomualdoGobbo <Romualdo.Go...@newlog.it>
Subject Re: Messages queue filtered depending on info received by another queue
Date Wed, 08 Sep 2010 08:32:38 GMT

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.

Mime
View raw message