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 : [email protected]
_______________________________________________
Dev mailing list
[email protected]
http://wso2.org/cgi-bin/mailman/listinfo/dev
