camel-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From salemi <sal...@avaya.com>
Subject Re: Incoming message from the queue need to be send to multiple consumer but keep the ordering
Date Thu, 08 Aug 2013 18:25:30 GMT
Hi,

I started to use message groups but camel throws the following exception.
What am I doing wrong?

013-08-08 12:15:35,030 [main           ] INFO  MainSupport                   
- Apache Camel 2.10.1 stopping
Exception in thread "main" 2013-08-08 12:15:35,047 [Thread-0       ] INFO 
MainSupport$HangupInterceptor  - Received hang up - stopping the main
instance.
org.apache.camel.RuntimeCamelException:
org.apache.camel.FailedToStartRouteException: Failed to start route
operationalreceive2 because of Multiple consumers for the same endpoint is
not allowed: Endpoint[jms://queue:coperation]
	at
org.apache.camel.util.ObjectHelper.wrapRuntimeCamelException(ObjectHelper.java:1280)

The route is as followed
<route id="operationalsend" shutdownRunningTask="CompleteCurrentTaskOnly"
autoStartup="false">
    		<from
uri="file:target/classes?fileName=operational_msgs&amp;noop=true&amp;idempotent=false"/>
			<log message="Processing big file: ${header.CamelFileName}"/>
			<delay>
            	<constant>20000</constant>
            </delay>
			<split streaming="true">
				<tokenize token="\n"/>
				<unmarshal ref="cJSON"/>
				<process ref="jmsMessageGroupProcessor"/> 
                                
				<marshal ref="cJSON"/>
				<to uri="{{operational.topic.prefix}}.{{source.type}}.{{source.name}}"/>
			</split>
			<log message="Done processing big file: ${header.CamelFileName}"/>
			<process ref="restartPuRouteProcessor"/>
			<delay>
                <constant>5000</constant>
            </delay>
    	</route>
        <route id="operationalreceive1"
shutdownRunningTask="CompleteCurrentTaskOnly" autoStartup="true">
             <from
uri="{{operational.topic.prefix}}.{{source.type}}.{{source.name}}"/>
             <log message="${header.JMSXGroupID}"/>
        </route>    	
        <route id="operationalreceive2"
shutdownRunningTask="CompleteCurrentTaskOnly" autoStartup="true">
             <from
uri="{{operational.topic.prefix}}.{{source.type}}.{{source.name}}"/>
             <log message="${header.JMSXGroupID}"/>
        </route>   



-----
Alireza Salemi
--
View this message in context: http://camel.465427.n5.nabble.com/Incoming-message-from-a-JMS-queue-need-to-be-processed-in-parallel-but-keep-the-ordering-of-messages-tp5735406p5737008.html
Sent from the Camel - Users mailing list archive at Nabble.com.

Mime
View raw message