Re: Incoming message from the queue need to be send to multiple consumer but keep the ordering

[salemi]

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.