On Fri, Feb 1, 2013 at 5:37 AM, am.raheem <am.rah...@gmail.com> wrote: > Hi > > Thanks for the response. > > In our scenario at one time 7 messages are getting published. Out of that , > it consumes only one message and ignoring 6 messages. > > Even there is no JMS message in the log files too. I can see the JMS > message(with JMSCorrelation Id) only once in the log. > > Also, when I am running MQ client java program, i am getting all the 7 > messages. I tried lot of options like setting cacheLevel. >
Are you using durable subscriber on the topic? If you set clientId and durableSubscriptionName on the JMS endpoint then you ought to receive all messages, even if you are offline and come back again (eg like persistent queues). http://camel.apache.org/jms > Thanks, > Abdul > > > > On Thu, Jan 31, 2013 at 9:46 PM, Willem.Jiang [via Camel] < > ml-node+s465427n5726696...@n5.nabble.com> wrote: > >> 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). >> >> >> >> >> >> ------------------------------ >> If you reply to this email, your message will be added to the discussion >> below: >> >> http://camel.465427.n5.nabble.com/CAMEL-IBM-MQ7-Spring3-0-tp5726692p5726696.html >> To unsubscribe from CAMEL + IBM MQ7 + Spring3.0, click >> here<http://camel.465427.n5.nabble.com/template/NamlServlet.jtp?macro=unsubscribe_by_code&node=5726692&code=YW0ucmFoZWVtQGdtYWlsLmNvbXw1NzI2NjkyfDE2OTMwOTk3Mw==> >> . >> NAML<http://camel.465427.n5.nabble.com/template/NamlServlet.jtp?macro=macro_viewer&id=instant_html%21nabble%3Aemail.naml&base=nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.NodeNamespace&breadcrumbs=notify_subscribers%21nabble%3Aemail.naml-instant_emails%21nabble%3Aemail.naml-send_instant_email%21nabble%3Aemail.naml> >> > > > > > -- > View this message in context: > http://camel.465427.n5.nabble.com/CAMEL-IBM-MQ7-Spring3-0-tp5726692p5726698.html > Sent from the Camel - Users mailing list archive at Nabble.com. -- Claus Ibsen ----------------- Red Hat, Inc. FuseSource is now part of Red Hat Email: cib...@redhat.com Web: http://fusesource.com Twitter: davsclaus Blog: http://davsclaus.com Author of Camel in Action: http://www.manning.com/ibsen
