camel-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Willem jiang <willem.ji...@gmail.com>
Subject Re: CAMEL + IBM MQ7 + Spring3.0
Date Fri, 01 Feb 2013 03:45:47 GMT
Hi,
I just have a quick question:
Does the camel route can only consume one message ?
Or it just ignore the second message which is just follow by the first message.


--  
Willem Jiang

Red Hat, Inc.
FuseSource is now part of Red Hat
Web: http://www.fusesource.com | http://www.redhat.com
Blog: http://willemjiang.blogspot.com (http://willemjiang.blogspot.com/) (English)
          http://jnn.iteye.com (http://jnn.javaeye.com/) (Chinese)
Twitter: willemjiang  
Weibo: 姜宁willem





On Friday, February 1, 2013 at 6:50 AM, am.raheem wrote:

> Hi All,
>  
> I am using Camel2.8, IBM MQ7.0 and Spring3.0. Using all these I am trying to
> consume the message from TOPIC.  
>  
> If 1 message is published in TOPIC , camel route is consuming perfectly. But
> when more than 1 message is published almost at sametime with milliseconds
> gap, Camel is not able to consume morethan 1 message. It is ignoring rest of
> the messages. The below are the configurations:
>  
> -------------------------------------------------------------------------------------
> <bean id="jms" class="org.apache.camel.component.jms.JmsComponent">  
> <property name="configuration">
> <bean class="org.apache.camel.component.jms.JmsConfiguration">  
> <property name="connectionFactory"
> ref="jmsConnectionFactory"/>  
> <property name="transacted" value="true" />
> <property name="transactionManager" ref="jmsTxManager" />
> </bean>  
> </property>
> </bean>
>  
> -------------------------------------------------------------------------------------
>  
> <bean id="jmsConnectionFactory"
> class="com.ibm.mq.jms.MQTopicConnectionFactory">
> <property name="hostName" value="abc.com (http://abc.com)" />  
> <property name="port" value="1414" />  
> <property name="channel" value="admin" />  
> <property name="queueManager" value="xyz" />
> <property name="transportType" value="1" />
> <property name="syncpointAllGets" value="true" />
> </bean>
>  
> -------------------------------------------------------------------------------------
>  
>  
> <camel:route id="HazmatCreate" errorHandlerRef="defaultErrorHandler">
> <camel:from uri="jms:topic:createTopic" />
> <camel:log message="received from CREATE topic - ${body}"
> loggingLevel="INFO" />
> <camel:setHeader headerName="CamelFileName">
>  
> <camel:simple>CREATE-${date:now:yyyy-MM-dd'T'hh:mm:ss.SSS}.xml</camel:simple>
> </camel:setHeader>  
> <camel:to uri="file://u/abc/hello/" />
> </camel:route>
> -------------------------------------------------------------------------------------
>  
> Please suggest, am i missing anything.
>  
> Thanks,
> Raheem
>  
>  
>  
>  
>  
>  
> --
> View this message in context: http://camel.465427.n5.nabble.com/CAMEL-IBM-MQ7-Spring3-0-tp5726692.html
> Sent from the Camel - Users mailing list archive at Nabble.com (http://Nabble.com).




Mime
View raw message