Re: [Dev] ESB 5 Beta - Shared subscriber doesn't connect

[Dilshani Subasinghe]

Hi Manuranga,

Sure, will do. I also identified similar scenarios while testing JMS
Transport service parameters.

Regards,
Dilshani
___
Dev mailing list
Dev@wso2.org
http://wso2.org/cgi-bin/mailman/listinfo/dev

Re: [Dev] ESB 5 Beta - Shared subscriber doesn't connect

[Manuranga Perera]

Hi Ravindra,
I was setting up using axis2.xml, when I switched to inbound endpoint it
worked. But I believe we need to fix this for axis2 xml as well.

Hi Dilshani,
Shall we add a test case for testing shared subscription configured via
axis2 as well.

On Fri, May 27, 2016 at 11:51 PM, Ravindra Ranwala 
wrote:

> 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  wrote:
>
>> I am trying to connect to IBM MQ using JMS 2
>>
>> http://ws.apache.org/ns/synapse; name="TReaderPxy2"
>> startOnLoad="true">
>>
>>   
>>  
>>  
>>  
>>   
>>
>>topic
>>mySub
>>TestQ49
>>true
>>1
>>> name="transport.jms.ConnectionFactory">myTopicParams
>>2.0
>>true
>> 
>>
>> 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
>> 

Re: [Dev] ESB 5 Beta - Shared subscriber doesn't connect

[Ravindra Ranwala]

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  wrote:

> I am trying to connect to IBM MQ using JMS 2
>
> http://ws.apache.org/ns/synapse; name="TReaderPxy2"
> startOnLoad="true">
>
>   
>  
>  
>  
>   
>
>topic
>mySub
>TestQ49
>true
>1
> name="transport.jms.ConnectionFactory">myTopicParams
>2.0
>true
> 
>
> 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
> 

[Dev] ESB 5 Beta - Shared subscriber doesn't connect

[Manuranga Perera]

I am trying to connect to IBM MQ using JMS 2

http://ws.apache.org/ns/synapse; name="TReaderPxy2"
startOnLoad="true">
   
  
 
 
 
  
   
   topic
   mySub
   TestQ49
   true
   1
   myTopicParams
   2.0
   true


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.(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