You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@camel.apache.org by "am.raheem" <am...@gmail.com> on 2013/01/31 23:50:10 UTC
CAMEL + IBM MQ7 + Spring3.0
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" />
<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.
Re: CAMEL + IBM MQ7 + Spring3.0
Posted by Claus Ibsen <cl...@gmail.com>.
On Fri, Feb 1, 2013 at 6:30 PM, am.raheem <am...@gmail.com> wrote:
> We are setting the clientId & durableSubscriptionName at CAMEL JMS
> component level. If we use same component for all the topics , definitely
> there will be SUBSCRIPTION_IN_USE error will come. So, i am using different
> component for every topic.
>
I think you can also set these 2 options on each endpoint, and reuse
the same component.
>
>
>
> On Fri, Feb 1, 2013 at 11:23 AM, James Carman-2 [via Camel] <
> ml-node+s465427n5726789h80@n5.nabble.com> wrote:
>
>> I don't think that was what they were asking. You shouldn't have to use a
>> specific component for each topic.
>>
>> On Feb 1, 2013, at 12:19 PM, "am.raheem" <[hidden email]<http://user/SendEmail.jtp?type=node&node=5726789&i=0>>
>> wrote:
>>
>> > Hi,
>> >
>> > It was my problem. I was using same jms component for three different
>> > topics. That's why i was getting that error. Now I made three different
>> > camel jms components it worked.
>> > Thanks for the suggestion to use durableSubscriber.
>> >
>> > Thanks,
>> > Raheem
>> > On Fri, Feb 1, 2013 at 9:33 AM, Claus Ibsen-2 [via Camel] <
>> > [hidden email] <http://user/SendEmail.jtp?type=node&node=5726789&i=1>>
>> wrote:
>> >
>> >> Hi
>> >>
>> >> Do you have any connection pooling or some sort?
>> >>
>> >> On Fri, Feb 1, 2013 at 4:25 PM, am.raheem <[hidden email]<
>> http://user/SendEmail.jtp?type=node&node=5726768&i=0>>
>> >> wrote:
>> >>
>> >>> Hi
>> >>>
>> >>>
>> >>> When Iam trying with the below durable 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="clientId" value="819" />
>> >>> <property name="durableSubscriptionName" value="myTopic" />
>> >>>
>> >>> </bean>
>> >>> </property>
>> >>> </bean>
>> >>>
>> >>> I am getting the below error:
>> >>>
>> >>> Caused by: com.ibm.mq.MQException: JMSCMQ0001: WebSphere MQ call
>> failed
>> >> with
>> >>> compcode '2' ('MQCC_FAILED') reason '2429'
>> ('MQRC_SUBSCRIPTION_IN_USE').
>> >>> at
>> >>>
>> >>
>> com.ibm.msg.client.wmq.common.internal.Reason.createException(Reason.java:223)
>>
>> >>
>> >>> ~[com.ibm.mqjms-7.0.1.1.jar:7.0.1.1 - k701-101-091116].
>> >>> Any sugessions on this error?
>> >>>
>> >>> Thanks,
>> >>> Raheem
>> >>>
>> >>>
>> >>>
>> >>> --
>> >>> View this message in context:
>> >>
>> http://camel.465427.n5.nabble.com/CAMEL-IBM-MQ7-Spring3-0-tp5726692p5726765.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: [hidden email]<
>> http://user/SendEmail.jtp?type=node&node=5726768&i=1>
>> >> Web: http://fusesource.com
>> >> Twitter: davsclaus
>> >> Blog: http://davsclaus.com
>> >> Author of Camel in Action: http://www.manning.com/ibsen
>> >>
>> >>
>> >> ------------------------------
>> >> If you reply to this email, your message will be added to the
>> discussion
>> >> below:
>> >>
>> >>
>>
>> >> .
>> >> 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-tp5726692p5726788.html
>>
>> > Sent from the Camel - Users mailing list archive at 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-tp5726692p5726789.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-tp5726692p5726791.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: cibsen@redhat.com
Web: http://fusesource.com
Twitter: davsclaus
Blog: http://davsclaus.com
Author of Camel in Action: http://www.manning.com/ibsen
Re: CAMEL + IBM MQ7 + Spring3.0
Posted by James Carman <jc...@carmanconsulting.com>.
Ahhh. Sorry, didn't see the "durable subscription" part there.
On Feb 1, 2013, at 12:30 PM, am.raheem <am...@gmail.com> wrote:
> We are setting the clientId & durableSubscriptionName at CAMEL JMS
> component level. If we use same component for all the topics , definitely
> there will be SUBSCRIPTION_IN_USE error will come. So, i am using different
> component for every topic.
>
>
>
>
> On Fri, Feb 1, 2013 at 11:23 AM, James Carman-2 [via Camel] <
> ml-node+s465427n5726789h80@n5.nabble.com> wrote:
>
>> I don't think that was what they were asking. You shouldn't have to use a
>> specific component for each topic.
>>
>> On Feb 1, 2013, at 12:19 PM, "am.raheem" <[hidden email]<http://user/SendEmail.jtp?type=node&node=5726789&i=0>>
>> wrote:
>>
>>> Hi,
>>>
>>> It was my problem. I was using same jms component for three different
>>> topics. That's why i was getting that error. Now I made three different
>>> camel jms components it worked.
>>> Thanks for the suggestion to use durableSubscriber.
>>>
>>> Thanks,
>>> Raheem
>>> On Fri, Feb 1, 2013 at 9:33 AM, Claus Ibsen-2 [via Camel] <
>>> [hidden email] <http://user/SendEmail.jtp?type=node&node=5726789&i=1>>
>> wrote:
>>>
>>>> Hi
>>>>
>>>> Do you have any connection pooling or some sort?
>>>>
>>>> On Fri, Feb 1, 2013 at 4:25 PM, am.raheem <[hidden email]<
>> http://user/SendEmail.jtp?type=node&node=5726768&i=0>>
>>>> wrote:
>>>>
>>>>> Hi
>>>>>
>>>>>
>>>>> When Iam trying with the below durable 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="clientId" value="819" />
>>>>> <property name="durableSubscriptionName" value="myTopic" />
>>>>>
>>>>> </bean>
>>>>> </property>
>>>>> </bean>
>>>>>
>>>>> I am getting the below error:
>>>>>
>>>>> Caused by: com.ibm.mq.MQException: JMSCMQ0001: WebSphere MQ call
>> failed
>>>> with
>>>>> compcode '2' ('MQCC_FAILED') reason '2429'
>> ('MQRC_SUBSCRIPTION_IN_USE').
>>>>> at
>>>>>
>>>>
>> com.ibm.msg.client.wmq.common.internal.Reason.createException(Reason.java:223)
>>
>>>>
>>>>> ~[com.ibm.mqjms-7.0.1.1.jar:7.0.1.1 - k701-101-091116].
>>>>> Any sugessions on this error?
>>>>>
>>>>> Thanks,
>>>>> Raheem
>>>>>
>>>>>
>>>>>
>>>>> --
>>>>> View this message in context:
>>>>
>> http://camel.465427.n5.nabble.com/CAMEL-IBM-MQ7-Spring3-0-tp5726692p5726765.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: [hidden email]<
>> http://user/SendEmail.jtp?type=node&node=5726768&i=1>
>>>> Web: http://fusesource.com
>>>> Twitter: davsclaus
>>>> Blog: http://davsclaus.com
>>>> Author of Camel in Action: http://www.manning.com/ibsen
>>>>
>>>>
>>>> ------------------------------
>>>> If you reply to this email, your message will be added to the
>> discussion
>>>> below:
>>>>
>>>>
>>
>>>> .
>>>> 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-tp5726692p5726788.html
>>
>>> Sent from the Camel - Users mailing list archive at 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-tp5726692p5726789.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-tp5726692p5726791.html
> Sent from the Camel - Users mailing list archive at Nabble.com.
Re: CAMEL + IBM MQ7 + Spring3.0
Posted by "am.raheem" <am...@gmail.com>.
We are setting the clientId & durableSubscriptionName at CAMEL JMS
component level. If we use same component for all the topics , definitely
there will be SUBSCRIPTION_IN_USE error will come. So, i am using different
component for every topic.
On Fri, Feb 1, 2013 at 11:23 AM, James Carman-2 [via Camel] <
ml-node+s465427n5726789h80@n5.nabble.com> wrote:
> I don't think that was what they were asking. You shouldn't have to use a
> specific component for each topic.
>
> On Feb 1, 2013, at 12:19 PM, "am.raheem" <[hidden email]<http://user/SendEmail.jtp?type=node&node=5726789&i=0>>
> wrote:
>
> > Hi,
> >
> > It was my problem. I was using same jms component for three different
> > topics. That's why i was getting that error. Now I made three different
> > camel jms components it worked.
> > Thanks for the suggestion to use durableSubscriber.
> >
> > Thanks,
> > Raheem
> > On Fri, Feb 1, 2013 at 9:33 AM, Claus Ibsen-2 [via Camel] <
> > [hidden email] <http://user/SendEmail.jtp?type=node&node=5726789&i=1>>
> wrote:
> >
> >> Hi
> >>
> >> Do you have any connection pooling or some sort?
> >>
> >> On Fri, Feb 1, 2013 at 4:25 PM, am.raheem <[hidden email]<
> http://user/SendEmail.jtp?type=node&node=5726768&i=0>>
> >> wrote:
> >>
> >>> Hi
> >>>
> >>>
> >>> When Iam trying with the below durable 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="clientId" value="819" />
> >>> <property name="durableSubscriptionName" value="myTopic" />
> >>>
> >>> </bean>
> >>> </property>
> >>> </bean>
> >>>
> >>> I am getting the below error:
> >>>
> >>> Caused by: com.ibm.mq.MQException: JMSCMQ0001: WebSphere MQ call
> failed
> >> with
> >>> compcode '2' ('MQCC_FAILED') reason '2429'
> ('MQRC_SUBSCRIPTION_IN_USE').
> >>> at
> >>>
> >>
> com.ibm.msg.client.wmq.common.internal.Reason.createException(Reason.java:223)
>
> >>
> >>> ~[com.ibm.mqjms-7.0.1.1.jar:7.0.1.1 - k701-101-091116].
> >>> Any sugessions on this error?
> >>>
> >>> Thanks,
> >>> Raheem
> >>>
> >>>
> >>>
> >>> --
> >>> View this message in context:
> >>
> http://camel.465427.n5.nabble.com/CAMEL-IBM-MQ7-Spring3-0-tp5726692p5726765.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: [hidden email]<
> http://user/SendEmail.jtp?type=node&node=5726768&i=1>
> >> Web: http://fusesource.com
> >> Twitter: davsclaus
> >> Blog: http://davsclaus.com
> >> Author of Camel in Action: http://www.manning.com/ibsen
> >>
> >>
> >> ------------------------------
> >> If you reply to this email, your message will be added to the
> discussion
> >> below:
> >>
> >>
>
> >> .
> >> 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-tp5726692p5726788.html
>
> > Sent from the Camel - Users mailing list archive at 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-tp5726692p5726789.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-tp5726692p5726791.html
Sent from the Camel - Users mailing list archive at Nabble.com.
Re: CAMEL + IBM MQ7 + Spring3.0
Posted by James Carman <jc...@carmanconsulting.com>.
I don't think that was what they were asking. You shouldn't have to use a specific component for each topic.
On Feb 1, 2013, at 12:19 PM, "am.raheem" <am...@gmail.com> wrote:
> Hi,
>
> It was my problem. I was using same jms component for three different
> topics. That's why i was getting that error. Now I made three different
> camel jms components it worked.
> Thanks for the suggestion to use durableSubscriber.
>
> Thanks,
> Raheem
> On Fri, Feb 1, 2013 at 9:33 AM, Claus Ibsen-2 [via Camel] <
> ml-node+s465427n5726768h29@n5.nabble.com> wrote:
>
>> Hi
>>
>> Do you have any connection pooling or some sort?
>>
>> On Fri, Feb 1, 2013 at 4:25 PM, am.raheem <[hidden email]<http://user/SendEmail.jtp?type=node&node=5726768&i=0>>
>> wrote:
>>
>>> Hi
>>>
>>>
>>> When Iam trying with the below durable 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="clientId" value="819" />
>>> <property name="durableSubscriptionName" value="myTopic" />
>>>
>>> </bean>
>>> </property>
>>> </bean>
>>>
>>> I am getting the below error:
>>>
>>> Caused by: com.ibm.mq.MQException: JMSCMQ0001: WebSphere MQ call failed
>> with
>>> compcode '2' ('MQCC_FAILED') reason '2429' ('MQRC_SUBSCRIPTION_IN_USE').
>>> at
>>>
>> com.ibm.msg.client.wmq.common.internal.Reason.createException(Reason.java:223)
>>
>>> ~[com.ibm.mqjms-7.0.1.1.jar:7.0.1.1 - k701-101-091116].
>>> Any sugessions on this error?
>>>
>>> Thanks,
>>> Raheem
>>>
>>>
>>>
>>> --
>>> View this message in context:
>> http://camel.465427.n5.nabble.com/CAMEL-IBM-MQ7-Spring3-0-tp5726692p5726765.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: [hidden email]<http://user/SendEmail.jtp?type=node&node=5726768&i=1>
>> Web: http://fusesource.com
>> Twitter: davsclaus
>> Blog: http://davsclaus.com
>> Author of Camel in Action: http://www.manning.com/ibsen
>>
>>
>> ------------------------------
>> 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-tp5726692p5726768.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-tp5726692p5726788.html
> Sent from the Camel - Users mailing list archive at Nabble.com.
Re: CAMEL + IBM MQ7 + Spring3.0
Posted by "am.raheem" <am...@gmail.com>.
Hi,
It was my problem. I was using same jms component for three different
topics. That's why i was getting that error. Now I made three different
camel jms components it worked.
Thanks for the suggestion to use durableSubscriber.
Thanks,
Raheem
On Fri, Feb 1, 2013 at 9:33 AM, Claus Ibsen-2 [via Camel] <
ml-node+s465427n5726768h29@n5.nabble.com> wrote:
> Hi
>
> Do you have any connection pooling or some sort?
>
> On Fri, Feb 1, 2013 at 4:25 PM, am.raheem <[hidden email]<http://user/SendEmail.jtp?type=node&node=5726768&i=0>>
> wrote:
>
> > Hi
> >
> >
> > When Iam trying with the below durable 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="clientId" value="819" />
> > <property name="durableSubscriptionName" value="myTopic" />
> >
> > </bean>
> > </property>
> > </bean>
> >
> > I am getting the below error:
> >
> > Caused by: com.ibm.mq.MQException: JMSCMQ0001: WebSphere MQ call failed
> with
> > compcode '2' ('MQCC_FAILED') reason '2429' ('MQRC_SUBSCRIPTION_IN_USE').
> > at
> >
> com.ibm.msg.client.wmq.common.internal.Reason.createException(Reason.java:223)
>
> > ~[com.ibm.mqjms-7.0.1.1.jar:7.0.1.1 - k701-101-091116].
> > Any sugessions on this error?
> >
> > Thanks,
> > Raheem
> >
> >
> >
> > --
> > View this message in context:
> http://camel.465427.n5.nabble.com/CAMEL-IBM-MQ7-Spring3-0-tp5726692p5726765.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: [hidden email]<http://user/SendEmail.jtp?type=node&node=5726768&i=1>
> Web: http://fusesource.com
> Twitter: davsclaus
> Blog: http://davsclaus.com
> Author of Camel in Action: http://www.manning.com/ibsen
>
>
> ------------------------------
> 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-tp5726692p5726768.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-tp5726692p5726788.html
Sent from the Camel - Users mailing list archive at Nabble.com.
Re: CAMEL + IBM MQ7 + Spring3.0
Posted by Claus Ibsen <cl...@gmail.com>.
Hi
Do you have any connection pooling or some sort?
On Fri, Feb 1, 2013 at 4:25 PM, am.raheem <am...@gmail.com> wrote:
> Hi
>
>
> When Iam trying with the below durable 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="clientId" value="819" />
> <property name="durableSubscriptionName" value="myTopic" />
>
> </bean>
> </property>
> </bean>
>
> I am getting the below error:
>
> Caused by: com.ibm.mq.MQException: JMSCMQ0001: WebSphere MQ call failed with
> compcode '2' ('MQCC_FAILED') reason '2429' ('MQRC_SUBSCRIPTION_IN_USE').
> at
> com.ibm.msg.client.wmq.common.internal.Reason.createException(Reason.java:223)
> ~[com.ibm.mqjms-7.0.1.1.jar:7.0.1.1 - k701-101-091116].
> Any sugessions on this error?
>
> Thanks,
> Raheem
>
>
>
> --
> View this message in context: http://camel.465427.n5.nabble.com/CAMEL-IBM-MQ7-Spring3-0-tp5726692p5726765.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: cibsen@redhat.com
Web: http://fusesource.com
Twitter: davsclaus
Blog: http://davsclaus.com
Author of Camel in Action: http://www.manning.com/ibsen
Re: CAMEL + IBM MQ7 + Spring3.0
Posted by "am.raheem" <am...@gmail.com>.
Hi
When Iam trying with the below durable 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="clientId" value="819" />
<property name="durableSubscriptionName" value="myTopic" />
</bean>
</property>
</bean>
I am getting the below error:
Caused by: com.ibm.mq.MQException: JMSCMQ0001: WebSphere MQ call failed with
compcode '2' ('MQCC_FAILED') reason '2429' ('MQRC_SUBSCRIPTION_IN_USE').
at
com.ibm.msg.client.wmq.common.internal.Reason.createException(Reason.java:223)
~[com.ibm.mqjms-7.0.1.1.jar:7.0.1.1 - k701-101-091116].
Any sugessions on this error?
Thanks,
Raheem
--
View this message in context: http://camel.465427.n5.nabble.com/CAMEL-IBM-MQ7-Spring3-0-tp5726692p5726765.html
Sent from the Camel - Users mailing list archive at Nabble.com.
Re: CAMEL + IBM MQ7 + Spring3.0
Posted by Claus Ibsen <cl...@gmail.com>.
On Fri, Feb 1, 2013 at 5:37 AM, am.raheem <am...@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+s465427n5726696h97@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: cibsen@redhat.com
Web: http://fusesource.com
Twitter: davsclaus
Blog: http://davsclaus.com
Author of Camel in Action: http://www.manning.com/ibsen
Re: CAMEL + IBM MQ7 + Spring3.0
Posted by "am.raheem" <am...@gmail.com>.
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.
Thanks,
Abdul
On Thu, Jan 31, 2013 at 9:46 PM, Willem.Jiang [via Camel] <
ml-node+s465427n5726696h97@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.
Re: CAMEL + IBM MQ7 + Spring3.0
Posted by Willem jiang <wi...@gmail.com>.
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).