Hi Manuranga, The shared subscription feature works fine and we used to test it with HornetQ broker. This could be due to some missing configuration. Could you please follow the blog post [1], and check the correctness in your configuration.
[1] http://ravindraranwala.blogspot.com/ Thanks & Regards, On Fri, May 27, 2016 at 8:51 PM, Manuranga Perera <m...@wso2.com> wrote: > I am trying to connect to IBM MQ using JMS 2 > > <proxy xmlns="http://ws.apache.org/ns/synapse"; name="TReaderPxy2" > startOnLoad="true"> > <target> > <inSequence> > <property name="OUT_ONLY" value="true"/> > <log level="full"/> > <drop/> > </inSequence> > </target> > <parameter name="transport.jms.DestinationType">topic</parameter> > <parameter name="transport.jms.DurableSubscriberName">mySub</parameter> > <parameter name="transport.jms.Destination">TestQ49</parameter> > <parameter name="transport.jms.SubscriptionDurable">true</parameter> > <parameter name="transport.jms.DurableSubscriberClientID">1</parameter> > <parameter > name="transport.jms.ConnectionFactory">myTopicParams</parameter> > <parameter name="transport.jms.JMSSpecVersion">2.0</parameter> > <parameter name="transport.jms.SharedSubscription">true</parameter> > </proxy> > > First ESB instance can connect successfully and I can publish messages. > But when I start another identical instance I see following error. > It connects if subscriber names are distinct, but then messages are > cloned, not shared. > > Please help me identify the issue. > > TID: [-1234] [] [2016-05-27 11:11:07,719] INFO > {org.apache.axis2.transport.jms.JMSListener} - JMS listener started > {org.apache.axis2.transport.jms.JMSListener} > TID: [-1234] [] [2016-05-27 11:11:07,720] DEBUG > {org.apache.axis2.transport.jms.JMSEndpoint} - JMS reply destination type > not given. default queue {org.apache.axis2.transport.jms.JMSEndpoint} > TID: [-1234] [] [2016-05-27 11:11:07,738] DEBUG > {org.apache.axis2.transport.jms.JMSUtils} - Creating a GenericConnection > using credentials : (null/null) {org.apache.axis2.transport.jms.JMSUtils} > TID: [-1234] [] [2016-05-27 11:11:08,011] INFO > {org.apache.axis2.transport.jms.JMSListener} - Connection attempt: 1 for > JMS Provider for service: TReaderPxy2 was successful! > {org.apache.axis2.transport.jms.JMSListener} > TID: [-1234] [] [2016-05-27 11:11:08,011] DEBUG > {org.apache.axis2.transport.jms.ServiceTaskManager} - The JMS Connection, > Session and MessageConsumer will be cached and shared between successive > poller task invocations {org.apache.axis2.transport.jms.ServiceTaskManager} > TID: [-1234] [] [2016-05-27 11:11:08,017] INFO > {org.apache.axis2.transport.jms.ServiceTaskManager} - Task manager for > service : TReaderPxy2 [re-]initialized > {org.apache.axis2.transport.jms.ServiceTaskManager} > TID: [-1] [] [2016-05-27 11:11:08,020] DEBUG > {org.apache.axis2.transport.jms.ServiceTaskManager} - New poll task > starting : thread id = 82 > {org.apache.axis2.transport.jms.ServiceTaskManager} > TID: [-1] [] [2016-05-27 11:11:08,026] DEBUG > {org.apache.axis2.transport.jms.ServiceTaskManager} - Connected to the JMS > connection factory : USAPP2D.TCF > {org.apache.axis2.transport.jms.ServiceTaskManager} > TID: [-1] [] [2016-05-27 11:11:08,027] DEBUG > {org.apache.axis2.transport.jms.JMSUtils} - Creating a TopicConnection > using credentials : (null/null) {org.apache.axis2.transport.jms.JMSUtils} > TID: [-1] [] [2016-05-27 11:11:08,055] DEBUG > {org.apache.axis2.transport.jms.ServiceTaskManager} - JMS Connection for > service : TReaderPxy2 created and started > {org.apache.axis2.transport.jms.ServiceTaskManager} > TID: [-1] [] [2016-05-27 11:11:08,056] DEBUG > {org.apache.axis2.transport.jms.ServiceTaskManager} - Creating a new JMS > Session for service : TReaderPxy2 > {org.apache.axis2.transport.jms.ServiceTaskManager} > TID: [-1] [] [2016-05-27 11:11:08,113] DEBUG > {org.apache.axis2.transport.jms.ServiceTaskManager} - Creating a new JMS > MessageConsumer for service : TReaderPxy2 > {org.apache.axis2.transport.jms.ServiceTaskManager} > TID: [-1] [] [2016-05-27 11:11:08,143] DEBUG > {org.apache.axis2.transport.jms.ServiceTaskManager} - JMS Destination with > JNDI name : TestQ49 found for service TReaderPxy2 > {org.apache.axis2.transport.jms.ServiceTaskManager} > TID: [-1] [] [2016-05-27 11:11:08,198] ERROR > {org.apache.axis2.transport.jms.ServiceTaskManager} - Error creating JMS > consumer for service : TReaderPxy2. JMSWMQ0026: Failed to subscribe to > topic 'TestQ49' with selector 'none' using MQSUB. > {org.apache.axis2.transport.jms.ServiceTaskManager} > com.ibm.msg.client.jms.DetailedIllegalStateException: JMSWMQ0026: Failed > to subscribe to topic 'TestQ49' with selector 'none' using MQSUB. > There may have been a problem creating the subscription due to it being > used by another message consumer. > Make sure any message consumers using this subscription are closed before > trying to create a new subscription under the same name. Please see the > linked exception for more information. > at > com.ibm.msg.client.wmq.common.internal.Reason.reasonToException(Reason.java:472) > at > com.ibm.msg.client.wmq.common.internal.Reason.createException(Reason.java:214) > at > com.ibm.msg.client.wmq.internal.WMQMessageConsumer.checkJmqiCallSuccess(WMQMessageConsumer.java:212) > at > com.ibm.msg.client.wmq.internal.WMQMessageConsumer.checkJmqiCallSuccess(WMQMessageConsumer.java:112) > at > com.ibm.msg.client.wmq.internal.WMQConsumerShadow.initialize(WMQConsumerShadow.java:1038) > at > com.ibm.msg.client.wmq.internal.WMQSyncConsumerShadow.initialize(WMQSyncConsumerShadow.java:134) > at > com.ibm.msg.client.wmq.internal.WMQMessageConsumer.<init>(WMQMessageConsumer.java:470) > at > com.ibm.msg.client.wmq.internal.WMQSession.createDurableSubscriber(WMQSession.java:897) > at > com.ibm.msg.client.jms.internal.JmsSessionImpl.createDurableSubscriber(JmsSessionImpl.java:1166) > at com.ibm.mq.jms.MQSession.createDurableSubscriber(MQSession.java:539) > at > org.apache.axis2.transport.jms.JMSUtils.createConsumer(JMSUtils.java:794) > at > org.apache.axis2.transport.jms.ServiceTaskManager$MessageListenerTask.createConsumer(ServiceTaskManager.java:924) > at > org.apache.axis2.transport.jms.ServiceTaskManager$MessageListenerTask.getMessageConsumer(ServiceTaskManager.java:785) > at > org.apache.axis2.transport.jms.ServiceTaskManager$MessageListenerTask.receiveMessage(ServiceTaskManager.java:535) > at > org.apache.axis2.transport.jms.ServiceTaskManager$MessageListenerTask.run(ServiceTaskManager.java:447) > at > org.apache.axis2.transport.base.threads.NativeWorkerPool$1.run(NativeWorkerPool.java:172) > at > java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) > at > java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) > at java.lang.Thread.run(Thread.java:745) > 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:202) > ... 17 more > -- > With regards, > *Manu*ranga Perera. > > phone : 071 7 70 20 50 > mail : m...@wso2.com > -- Ravindra Ranwala Software Engineer WSO2, Inc: http://wso2.com <http://www.google.com/url?q=http%3A%2F%2Fwso2.com&sa=D&sntz=1&usg=AFQjCNEZvyc0uMD1HhBaEGCBxs6e9fBObg> Mobile: +94714198770
_______________________________________________ Dev mailing list Dev@wso2.org http://wso2.org/cgi-bin/mailman/listinfo/dev
