You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@qpid.apache.org by 4 Integration <4i...@gmail.com> on 2017/08/07 13:26:57 UTC
Create durable subscription to Azure Service Bus
Hi,
Testing QPid JMS (AMQP v1.0) with Azure Service Bus (SB).
Trying to get durable subscriptions to work.
I have created a topic in SB
When starting my test app I get:
javax.jms.JMSException: The messaging entity
'mynamespace:topic:test.topic~15|test1' could not be found.
TrackingId:12ecc2a3-f8f3-42a3-8bd5-ad5d9823c367_B20,
SystemTracker:jjarkebo:topic:test.topic~15|test1, Timestamp:8/7/2017
1:23:34 PM TrackingId:b1af76b2b7a44b95ad2bd0e01f406507_G20,
SystemTracker:gateway6, Timestamp:8/7/2017 1:23:34 PM
at
org.apache.qpid.amqp_1_0.jms.impl.TopicSubscriberImpl.createClientReceiver(TopicSubscriberImpl.java:111)
at
org.apache.qpid.amqp_1_0.jms.impl.MessageConsumerImpl.<init>(MessageConsumerImpl.java:129)
at
org.apache.qpid.amqp_1_0.jms.impl.TopicSubscriberImpl.<init>(TopicSubscriberImpl.java:46)
at
org.apache.qpid.amqp_1_0.jms.impl.SessionImpl.createDurableSubscriber(SessionImpl.java:544)
at
org.apache.qpid.amqp_1_0.jms.impl.SessionImpl.createDurableSubscriber(SessionImpl.java:512)
at
org.apache.qpid.amqp_1_0.jms.impl.SessionImpl.createDurableSubscriber(SessionImpl.java:59)
at com.vcrs.test.AmqpJmsSubscriberApp.<init>(AmqpJmsSubscriberApp.java:39)
at com.vcrs.test.AmqpJmsSubscriberApp.main(AmqpJmsSubscriberApp.java:67)
Any ideas why this happen?
Do you have a working example?
My test app code below
import javax.jms.*;
import javax.naming.Context;
import javax.naming.InitialContext;
import org.apache.qpid.amqp_1_0.jms.Connection;
import org.apache.qpid.amqp_1_0.jms.ConnectionFactory;
import org.apache.qpid.amqp_1_0.jms.Destination;
import org.apache.qpid.amqp_1_0.jms.MessageConsumer;
import org.apache.qpid.amqp_1_0.jms.MessageProducer;
import org.apache.qpid.amqp_1_0.jms.Session;
import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.util.Hashtable;
import java.util.Random;
public class AmqpJmsSubscriberApp {
private Connection connection;
private Session subscriberSession;
private MessageConsumer subscriber;
public AmqpJmsSubscriberApp() throws Exception {
Hashtable<String, String> env = new Hashtable<String, String>();
env.put(Context.INITIAL_CONTEXT_FACTORY,
"org.apache.qpid.amqp_1_0.jms.jndi.PropertiesFileInitialContextFactory");
env.put("connectionfactory.SBCF", "amqps://
MyUser:MySecretKey@mynamespace.servicebus.windows.net:5671");
env.put("topic.TOPIC", "test.topic");
Context context = new InitialContext(env);
ConnectionFactory cf = (ConnectionFactory) context.lookup("SBCF");
Topic topic = (Topic) context.lookup("TOPIC");
connection = cf.createConnection();
subscriberSession = connection.createSession(false,
Session.CLIENT_ACKNOWLEDGE);
subscriber = subscriberSession.createDurableSubscriber(topic,
"test1");
MessageListener messagelistener = new MessageListener()
{
public void onMessage(Message message)
{
try {
BytesMessage byteMsg = (BytesMessage)message;
byte[] byteArr = new byte[(int)byteMsg.getBodyLength()];
byteMsg.readBytes(byteArr);
String msg = new String(byteArr);
System.out.println("Received message with JMSMessageID =
" + message.getJMSMessageID());
System.out.println("You said " + msg);
message.acknowledge();
} catch (Exception e) {
e.printStackTrace();
}
}
};
subscriber.setMessageListener( messagelistener );
connection.start();
}
public static void main(String[] args) {
try {
AmqpJmsSubscriberApp simpleSubscriber = new AmqpJmsSubscriberApp();
System.out.println("Press [enter] to send a message. Type
'exit' + [enter] to quit.");
BufferedReader commandLine = new java.io.BufferedReader(new
InputStreamReader(System.in));
while (true) {
String s = commandLine.readLine();
if (s.equalsIgnoreCase("exit")) {
simpleSubscriber.close();
System.exit(0);
}
}
} catch (Exception e) {
e.printStackTrace();
}
}
public void close() throws JMSException {
connection.close();
}
}
Re: Create durable subscription to Azure Service Bus
Posted by Robbie Gemmell <ro...@gmail.com>.
The client isn't tested against RabbitMQ, the brokers current
behaviour around the 'modified' disposition will essentially prevent
them being used together for now. I filed an issue for it along with
another last year when debugging some issues with a different client:
https://github.com/rabbitmq/rabbitmq-amqp1.0/issues/34
Per the issue description I think the broker is being overly agressive
in this case, as it isn't reacting to clients actually using the
outcome but rather that the client mention supporting it at all. It
could either support it or just be nicer about not supporting it.
Robbie
On 10 August 2017 at 14:13, 4 Integration <4i...@gmail.com> wrote:
> As in a post last week:
>
> https://groups.google.com/d/msg/rabbitmq-users/_6bD9bQDlZ0/isl651WeAQAJ
>
> and:
> "*amqp:modified:list is not currently supported by the plugin. As far as I
> can see,*
> *our test suite confirms this.*"
>
>
>
> / Joacim
>
> On Thu, Aug 10, 2017 at 3:10 PM, 4 Integration <4i...@gmail.com>
> wrote:
>
>> Correct (to my understanding).
>> Also another drawback is that if you have two or more subscriptions (e.g.
>> SUB-A and SUB-B for APP-A and APP-B) on the same topic there are no
>> authorization on subscription level - only on topic. So APP-A can receive
>> "subscribe" on SUB-B. Also missing wildcard subscriptions...we are leaning
>> toward RabbitMQ as of now. But experiencing some issues with Qpid JMS 0.23
>> with that also...
>>
>> Do you know if Qpid JMS is tested to RabbitMQ?
>>
>> / Joacim
>>
>>
>> On Thu, Aug 10, 2017 at 2:07 PM, Gordon Sim <gs...@redhat.com> wrote:
>>
>>> On 10/08/17 12:01, 4 Integration wrote:
>>>
>>>> I have found the answer:
>>>> It is not possible to create durable subscriptions dynamically with
>>>> QPid/AMQ v1.0 due to:
>>>> https://docs.microsoft.com/en-us/azure/service-bus-messaging
>>>> /service-bus-java-how-to-use-jms-api-amqp#unsupported-featur
>>>> es-and-restrictions
>>>>
>>>> Unsupported features and restrictions
>>>>
>>>> The following restrictions exist when using JMS over AMQP 1.0 with
>>>> Service
>>>> Bus, namely:
>>>>
>>>> - Only one MessageProducer or MessageConsumer is allowed per
>>>> Session. If
>>>> you need to create multiple MessageProducers or MessageConsumers in
>>>> an
>>>> application, create a dedicated Session for each of them.
>>>> - Volatile topic subscriptions are not currently supported.
>>>> - MessageSelectors are not currently supported.
>>>> - Temporary destinations, i.e., TemporaryQueue, TemporaryTopic are
>>>> not
>>>> currently supported, along with the QueueRequestor and
>>>> TopicRequestor APIs
>>>> that use them.
>>>> - Transacted sessions and distributed transactions are not supported.
>>>>
>>>> If required then need to use Azure SB API
>>>> https://github.com/Azure/azure-service-bus-java
>>>>
>>>
>>> Just to clarify, for my own education, for topic subscriptions you need
>>> to set up a subscription statically and you can then use an address of the
>>> form <<topic-name>>/Subscriptions/<<subscription-name>> to consume from
>>> it, correct?
>>>
>>> But you cannot dynamically create subscriptions by an AMQP link attach.
>>>
>>>
>>> ---------------------------------------------------------------------
>>> To unsubscribe, e-mail: users-unsubscribe@qpid.apache.org
>>> For additional commands, e-mail: users-help@qpid.apache.org
>>>
>>>
>>
---------------------------------------------------------------------
To unsubscribe, e-mail: users-unsubscribe@qpid.apache.org
For additional commands, e-mail: users-help@qpid.apache.org
Re: Create durable subscription to Azure Service Bus
Posted by 4 Integration <4i...@gmail.com>.
As in a post last week:
https://groups.google.com/d/msg/rabbitmq-users/_6bD9bQDlZ0/isl651WeAQAJ
and:
"*amqp:modified:list is not currently supported by the plugin. As far as I
can see,*
*our test suite confirms this.*"
/ Joacim
On Thu, Aug 10, 2017 at 3:10 PM, 4 Integration <4i...@gmail.com>
wrote:
> Correct (to my understanding).
> Also another drawback is that if you have two or more subscriptions (e.g.
> SUB-A and SUB-B for APP-A and APP-B) on the same topic there are no
> authorization on subscription level - only on topic. So APP-A can receive
> "subscribe" on SUB-B. Also missing wildcard subscriptions...we are leaning
> toward RabbitMQ as of now. But experiencing some issues with Qpid JMS 0.23
> with that also...
>
> Do you know if Qpid JMS is tested to RabbitMQ?
>
> / Joacim
>
>
> On Thu, Aug 10, 2017 at 2:07 PM, Gordon Sim <gs...@redhat.com> wrote:
>
>> On 10/08/17 12:01, 4 Integration wrote:
>>
>>> I have found the answer:
>>> It is not possible to create durable subscriptions dynamically with
>>> QPid/AMQ v1.0 due to:
>>> https://docs.microsoft.com/en-us/azure/service-bus-messaging
>>> /service-bus-java-how-to-use-jms-api-amqp#unsupported-featur
>>> es-and-restrictions
>>>
>>> Unsupported features and restrictions
>>>
>>> The following restrictions exist when using JMS over AMQP 1.0 with
>>> Service
>>> Bus, namely:
>>>
>>> - Only one MessageProducer or MessageConsumer is allowed per
>>> Session. If
>>> you need to create multiple MessageProducers or MessageConsumers in
>>> an
>>> application, create a dedicated Session for each of them.
>>> - Volatile topic subscriptions are not currently supported.
>>> - MessageSelectors are not currently supported.
>>> - Temporary destinations, i.e., TemporaryQueue, TemporaryTopic are
>>> not
>>> currently supported, along with the QueueRequestor and
>>> TopicRequestor APIs
>>> that use them.
>>> - Transacted sessions and distributed transactions are not supported.
>>>
>>> If required then need to use Azure SB API
>>> https://github.com/Azure/azure-service-bus-java
>>>
>>
>> Just to clarify, for my own education, for topic subscriptions you need
>> to set up a subscription statically and you can then use an address of the
>> form <<topic-name>>/Subscriptions/<<subscription-name>> to consume from
>> it, correct?
>>
>> But you cannot dynamically create subscriptions by an AMQP link attach.
>>
>>
>> ---------------------------------------------------------------------
>> To unsubscribe, e-mail: users-unsubscribe@qpid.apache.org
>> For additional commands, e-mail: users-help@qpid.apache.org
>>
>>
>
Re: Create durable subscription to Azure Service Bus
Posted by 4 Integration <4i...@gmail.com>.
Correct (to my understanding).
Also another drawback is that if you have two or more subscriptions (e.g.
SUB-A and SUB-B for APP-A and APP-B) on the same topic there are no
authorization on subscription level - only on topic. So APP-A can receive
"subscribe" on SUB-B. Also missing wildcard subscriptions...we are leaning
toward RabbitMQ as of now. But experiencing some issues with Qpid JMS 0.23
with that also...
Do you know if Qpid JMS is tested to RabbitMQ?
/ Joacim
On Thu, Aug 10, 2017 at 2:07 PM, Gordon Sim <gs...@redhat.com> wrote:
> On 10/08/17 12:01, 4 Integration wrote:
>
>> I have found the answer:
>> It is not possible to create durable subscriptions dynamically with
>> QPid/AMQ v1.0 due to:
>> https://docs.microsoft.com/en-us/azure/service-bus-messaging
>> /service-bus-java-how-to-use-jms-api-amqp#unsupported-
>> features-and-restrictions
>>
>> Unsupported features and restrictions
>>
>> The following restrictions exist when using JMS over AMQP 1.0 with Service
>> Bus, namely:
>>
>> - Only one MessageProducer or MessageConsumer is allowed per Session.
>> If
>> you need to create multiple MessageProducers or MessageConsumers in an
>> application, create a dedicated Session for each of them.
>> - Volatile topic subscriptions are not currently supported.
>> - MessageSelectors are not currently supported.
>> - Temporary destinations, i.e., TemporaryQueue, TemporaryTopic are not
>> currently supported, along with the QueueRequestor and TopicRequestor
>> APIs
>> that use them.
>> - Transacted sessions and distributed transactions are not supported.
>>
>> If required then need to use Azure SB API
>> https://github.com/Azure/azure-service-bus-java
>>
>
> Just to clarify, for my own education, for topic subscriptions you need to
> set up a subscription statically and you can then use an address of the
> form <<topic-name>>/Subscriptions/<<subscription-name>> to consume from
> it, correct?
>
> But you cannot dynamically create subscriptions by an AMQP link attach.
>
>
> ---------------------------------------------------------------------
> To unsubscribe, e-mail: users-unsubscribe@qpid.apache.org
> For additional commands, e-mail: users-help@qpid.apache.org
>
>
Re: Create durable subscription to Azure Service Bus
Posted by Gordon Sim <gs...@redhat.com>.
On 10/08/17 12:01, 4 Integration wrote:
> I have found the answer:
> It is not possible to create durable subscriptions dynamically with
> QPid/AMQ v1.0 due to:
> https://docs.microsoft.com/en-us/azure/service-bus-messaging/service-bus-java-how-to-use-jms-api-amqp#unsupported-features-and-restrictions
>
> Unsupported features and restrictions
>
> The following restrictions exist when using JMS over AMQP 1.0 with Service
> Bus, namely:
>
> - Only one MessageProducer or MessageConsumer is allowed per Session. If
> you need to create multiple MessageProducers or MessageConsumers in an
> application, create a dedicated Session for each of them.
> - Volatile topic subscriptions are not currently supported.
> - MessageSelectors are not currently supported.
> - Temporary destinations, i.e., TemporaryQueue, TemporaryTopic are not
> currently supported, along with the QueueRequestor and TopicRequestor APIs
> that use them.
> - Transacted sessions and distributed transactions are not supported.
>
> If required then need to use Azure SB API
> https://github.com/Azure/azure-service-bus-java
Just to clarify, for my own education, for topic subscriptions you need
to set up a subscription statically and you can then use an address of
the form <<topic-name>>/Subscriptions/<<subscription-name>> to consume
from it, correct?
But you cannot dynamically create subscriptions by an AMQP link attach.
---------------------------------------------------------------------
To unsubscribe, e-mail: users-unsubscribe@qpid.apache.org
For additional commands, e-mail: users-help@qpid.apache.org
Re: Create durable subscription to Azure Service Bus
Posted by Gordon Sim <gs...@redhat.com>.
On 10/08/17 17:55, Robbie Gemmell wrote:
> I dont think any of the points on unsupported features below actually
> relate to what you are seeing, with it instead just being a difference
> in what the AMQP JMS Mapping does for passing JMS subscription
> details, versus the approach Service Bus is using/expecting.
I *think* one key difference is that with service bus you have to first
create the subscription (and you can't do that through AMQP?) before you
can consume from it.
> From what you outlined, it appears that ServiceBus uses a
> vendor-specific address format to pass both a topic name and a
> subscription name when attaching a receiving link, whereas the JMS
> client on the other hand attaches to the given topic address and uses
> receiver link naming to pass its subscription details, with this
> difference presumably being why you see a 'not-found' error from Azure
> when you dont include the subscription name in the receiver address.
---------------------------------------------------------------------
To unsubscribe, e-mail: users-unsubscribe@qpid.apache.org
For additional commands, e-mail: users-help@qpid.apache.org
Re: Create durable subscription to Azure Service Bus
Posted by Robbie Gemmell <ro...@gmail.com>.
I dont think any of the points on unsupported features below actually
relate to what you are seeing, with it instead just being a difference
in what the AMQP JMS Mapping does for passing JMS subscription
details, versus the approach Service Bus is using/expecting.
From what you outlined, it appears that ServiceBus uses a
vendor-specific address format to pass both a topic name and a
subscription name when attaching a receiving link, whereas the JMS
client on the other hand attaches to the given topic address and uses
receiver link naming to pass its subscription details, with this
difference presumably being why you see a 'not-found' error from Azure
when you dont include the subscription name in the receiver address.
On 10 August 2017 at 12:01, 4 Integration <4i...@gmail.com> wrote:
> I have found the answer:
> It is not possible to create durable subscriptions dynamically with
> QPid/AMQ v1.0 due to:
> https://docs.microsoft.com/en-us/azure/service-bus-messaging/service-bus-java-how-to-use-jms-api-amqp#unsupported-features-and-restrictions
>
> Unsupported features and restrictions
>
> The following restrictions exist when using JMS over AMQP 1.0 with Service
> Bus, namely:
>
> - Only one MessageProducer or MessageConsumer is allowed per Session. If
> you need to create multiple MessageProducers or MessageConsumers in an
> application, create a dedicated Session for each of them.
> - Volatile topic subscriptions are not currently supported.
> - MessageSelectors are not currently supported.
> - Temporary destinations, i.e., TemporaryQueue, TemporaryTopic are not
> currently supported, along with the QueueRequestor and TopicRequestor APIs
> that use them.
> - Transacted sessions and distributed transactions are not supported.
>
> If required then need to use Azure SB API
> https://github.com/Azure/azure-service-bus-java
>
> Regards
> Joacim
>
>
>
>
>
> On Tue, Aug 8, 2017 at 2:09 PM, 4 Integration <4i...@gmail.com>
> wrote:
>
>> On the topic defined in Azure Service Bus "test.topic" I have a static
>> subscription defined named "sub1".
>>
>> When publishing I use:
>> env.put("topic.TOPIC", "test.topic");
>>
>> When subscribing to "sub1" I have
>> env.put("topic.TOPIC", "test.topic/Subscriptions/sub1");
>>
>> The naming here seems required i.e. <<topic-name>>/Subscriptions/<
>> <subscription-name>>
>>
>> Maybe some other naming required....or something. I will reach out to
>> Azure forum also.
>>
>> I'll be back :)
>>
>> / Joacim
>>
>>
>>
>> On Tue, Aug 8, 2017 at 1:53 PM, Gordon Sim <gs...@redhat.com> wrote:
>>
>>> On 08/08/17 12:37, Gordon Sim wrote:
>>>
>>>> You could try a further experiment with another see if we can rule out
>>>> one or other of these
>>>>
>>>
>>> E.g. if it is easy to get proton python client, you could use the
>>> simple_recv.py example with -a my-namespace.servicebus.window
>>> s.net:5671/test.topic and see what the protocol trace looks like with
>>> that.
>>>
>>>
>>> ---------------------------------------------------------------------
>>> To unsubscribe, e-mail: users-unsubscribe@qpid.apache.org
>>> For additional commands, e-mail: users-help@qpid.apache.org
>>>
>>>
>>
---------------------------------------------------------------------
To unsubscribe, e-mail: users-unsubscribe@qpid.apache.org
For additional commands, e-mail: users-help@qpid.apache.org
Re: Create durable subscription to Azure Service Bus
Posted by 4 Integration <4i...@gmail.com>.
I have found the answer:
It is not possible to create durable subscriptions dynamically with
QPid/AMQ v1.0 due to:
https://docs.microsoft.com/en-us/azure/service-bus-messaging/service-bus-java-how-to-use-jms-api-amqp#unsupported-features-and-restrictions
Unsupported features and restrictions
The following restrictions exist when using JMS over AMQP 1.0 with Service
Bus, namely:
- Only one MessageProducer or MessageConsumer is allowed per Session. If
you need to create multiple MessageProducers or MessageConsumers in an
application, create a dedicated Session for each of them.
- Volatile topic subscriptions are not currently supported.
- MessageSelectors are not currently supported.
- Temporary destinations, i.e., TemporaryQueue, TemporaryTopic are not
currently supported, along with the QueueRequestor and TopicRequestor APIs
that use them.
- Transacted sessions and distributed transactions are not supported.
If required then need to use Azure SB API
https://github.com/Azure/azure-service-bus-java
Regards
Joacim
On Tue, Aug 8, 2017 at 2:09 PM, 4 Integration <4i...@gmail.com>
wrote:
> On the topic defined in Azure Service Bus "test.topic" I have a static
> subscription defined named "sub1".
>
> When publishing I use:
> env.put("topic.TOPIC", "test.topic");
>
> When subscribing to "sub1" I have
> env.put("topic.TOPIC", "test.topic/Subscriptions/sub1");
>
> The naming here seems required i.e. <<topic-name>>/Subscriptions/<
> <subscription-name>>
>
> Maybe some other naming required....or something. I will reach out to
> Azure forum also.
>
> I'll be back :)
>
> / Joacim
>
>
>
> On Tue, Aug 8, 2017 at 1:53 PM, Gordon Sim <gs...@redhat.com> wrote:
>
>> On 08/08/17 12:37, Gordon Sim wrote:
>>
>>> You could try a further experiment with another see if we can rule out
>>> one or other of these
>>>
>>
>> E.g. if it is easy to get proton python client, you could use the
>> simple_recv.py example with -a my-namespace.servicebus.window
>> s.net:5671/test.topic and see what the protocol trace looks like with
>> that.
>>
>>
>> ---------------------------------------------------------------------
>> To unsubscribe, e-mail: users-unsubscribe@qpid.apache.org
>> For additional commands, e-mail: users-help@qpid.apache.org
>>
>>
>
Re: Create durable subscription to Azure Service Bus
Posted by 4 Integration <4i...@gmail.com>.
On the topic defined in Azure Service Bus "test.topic" I have a static
subscription defined named "sub1".
When publishing I use:
env.put("topic.TOPIC", "test.topic");
When subscribing to "sub1" I have
env.put("topic.TOPIC", "test.topic/Subscriptions/sub1");
The naming here seems required i.e.
<<topic-name>>/Subscriptions/<<subscription-name>>
Maybe some other naming required....or something. I will reach out to Azure
forum also.
I'll be back :)
/ Joacim
On Tue, Aug 8, 2017 at 1:53 PM, Gordon Sim <gs...@redhat.com> wrote:
> On 08/08/17 12:37, Gordon Sim wrote:
>
>> You could try a further experiment with another see if we can rule out
>> one or other of these
>>
>
> E.g. if it is easy to get proton python client, you could use the
> simple_recv.py example with -a my-namespace.servicebus.window
> s.net:5671/test.topic and see what the protocol trace looks like with
> that.
>
>
> ---------------------------------------------------------------------
> To unsubscribe, e-mail: users-unsubscribe@qpid.apache.org
> For additional commands, e-mail: users-help@qpid.apache.org
>
>
Re: Create durable subscription to Azure Service Bus
Posted by Gordon Sim <gs...@redhat.com>.
On 08/08/17 12:37, Gordon Sim wrote:
> You could try a further experiment with another see if we can rule out
> one or other of these
E.g. if it is easy to get proton python client, you could use the
simple_recv.py example with -a
my-namespace.servicebus.windows.net:5671/test.topic and see what the
protocol trace looks like with that.
---------------------------------------------------------------------
To unsubscribe, e-mail: users-unsubscribe@qpid.apache.org
For additional commands, e-mail: users-help@qpid.apache.org
Re: Create durable subscription to Azure Service Bus
Posted by Gordon Sim <gs...@redhat.com>.
On 08/08/17 12:27, 4 Integration wrote:
> As suggested by Gordon => Running with env var PN_TRACE_FRM=1 and post the
> protocol trace you see.
>
> Configured a proper logger and got more details:
>
This looks like either there is no source called test.topic configured
on the service bus, or it doesn't like the 'topic' capability. (You
could try a further experiment with another see if we can rule out one
or other of these).
(The ~15 seems to be coming from something on the service bus side.)
> [350616316:1] -> Attach{name='qpid-jms:receiver:ID:5a68cd00-6948-
> 46ff-9599-1b3803aaa73c:1:1:1:test.topic', handle=0, role=RECEIVER,
> sndSettleMode=UNSETTLED, rcvSettleMode=FIRST,
> source=Source{address='test.topic',
> durable=NONE, expiryPolicy=LINK_DETACH, timeout=0, dynamic=false,
> dynamicNodeProperties=null, distributionMode=null, filter=null,
> defaultOutcome=Modified{deliveryFailed=true, undeliverableHere=null,
> messageAnnotations=null}, outcomes=[amqp:accepted:list, amqp:rejected:list,
> amqp:released:list, amqp:modified:list], capabilities=[topic]},
> target=Target{address='null', durable=NONE, expiryPolicy=SESSION_END,
> timeout=0, dynamic=false, dynamicNodeProperties=null, capabilities=null},
> unsettled=null, incompleteUnsettled=false, initialDeliveryCount=null,
> maxMessageSize=null, offeredCapabilities=null, desiredCapabilities=null,
> properties=null}
> 2017-08-08T12:27:32.905 TRACE [org.apache.qpid.jms.provider.amqp.FRAMES] -
> SENT: Attach{name='qpid-jms:receiver:ID:5a68cd00-6948-
> 46ff-9599-1b3803aaa73c:1:1:1:test.topic', handle=0, role=RECEIVER,
> sndSettleMode=UNSETTLED, rcvSettleMode=FIRST,
> source=Source{address='test.topic',
> durable=NONE, expiryPolicy=LINK_DETACH, timeout=0, dynamic=false,
> dynamicNodeProperties=null, distributionMode=null, filter=null,
> defaultOutcome=Modified{deliveryFailed=true, undeliverableHere=null,
> messageAnnotations=null}, outcomes=[amqp:accepted:list, amqp:rejected:list,
> amqp:released:list, amqp:modified:list], capabilities=[topic]},
> target=Target{address='null', durable=NONE, expiryPolicy=SESSION_END,
> timeout=0, dynamic=false, dynamicNodeProperties=null, capabilities=null},
> unsettled=null, incompleteUnsettled=false, initialDeliveryCount=null,
> maxMessageSize=null, offeredCapabilities=null, desiredCapabilities=null,
> properties=null}
> 2017-08-08T12:27:32.906 TRACE
> [org.apache.qpid.jms.transports.netty.NettyTcpTransport]
> - Attempted write of: 234 bytes
> 2017-08-08T12:27:33.395 TRACE
> [org.apache.qpid.jms.transports.netty.NettyTcpTransport]
> - New data read: 180 bytes incoming: PooledUnsafeDirectByteBuf(ridx: 0,
> widx: 180, cap: 245)
> [350616316:1] <- Attach{name='qpid-jms:receiver:ID:5a68cd00-6948-
> 46ff-9599-1b3803aaa73c:1:1:1:test.topic', handle=0, role=SENDER,
> sndSettleMode=UNSETTLED, rcvSettleMode=FIRST, source=null, target=null,
> unsettled=null, incompleteUnsettled=false, initialDeliveryCount=0,
> maxMessageSize=266240, offeredCapabilities=null, desiredCapabilities=null,
> properties={com.microsoft:tracking-id=eddac23358584ea695974b0e0738b5cc_G28}}
> 2017-08-08T12:27:33.396 TRACE [org.apache.qpid.jms.provider.amqp.FRAMES] -
> RECV: Attach{name='qpid-jms:receiver:ID:5a68cd00-6948-
> 46ff-9599-1b3803aaa73c:1:1:1:test.topic', handle=0, role=SENDER,
> sndSettleMode=UNSETTLED, rcvSettleMode=FIRST, source=null, target=null,
> unsettled=null, incompleteUnsettled=false, initialDeliveryCount=0,
> maxMessageSize=266240, offeredCapabilities=null, desiredCapabilities=null,
> properties={com.microsoft:tracking-id=eddac23358584ea695974b0e0738b5cc_G28}}
> 2017-08-08T12:27:33.397 TRACE [org.apache.qpid.jms.provider.amqp.AmqpProvider]
> - New Proton Event: LINK_INIT
> 2017-08-08T12:27:33.397 TRACE [org.apache.qpid.jms.provider.amqp.AmqpProvider]
> - New Proton Event: LINK_LOCAL_OPEN
> 2017-08-08T12:27:33.397 TRACE [org.apache.qpid.jms.provider.amqp.AmqpProvider]
> - New Proton Event: LINK_REMOTE_OPEN
> 2017-08-08T12:27:33.617 TRACE
> [org.apache.qpid.jms.transports.netty.NettyTcpTransport]
> - New data read: 509 bytes incoming: PooledUnsafeDirectByteBuf(ridx: 0,
> widx: 509, cap: 565)
> [350616316:1] <- Detach{handle=0, closed=true,
> error=Error{condition=amqp:not-found,
> description='The messaging entity 'my-namespace:topic:test.
> topic~15|qpid-jms:receiver:ID:5a68cd00-6948-46ff-9599-1b3803aaa73c:1:1:1:test.topic'
> could not be found. TrackingId:12ecc2a3-f8f3-42a3-8bd5-ad5d9823c367_B20,
> SystemTracker:my-namespace:topic:test.topic~15|qpid-jms:
> receiver:ID:5a68cd00-6948-46ff-9599-1b3803aaa73c:1:1:1:test.topic,
> Timestamp:8/8/2017 10:27:32 AM TrackingId:eddac23358584ea695974b0e0738b5cc_G28,
> SystemTracker:gateway6, Timestamp:8/8/2017 10:27:32 AM', info=null}}
> 2017-08-08T12:27:33.618 TRACE [org.apache.qpid.jms.provider.amqp.FRAMES] -
> RECV: Detach{handle=0, closed=true, error=Error{condition=amqp:not-found,
> description='The messaging entity 'my-namespace:topic:test.
> topic~15|qpid-jms:receiver:ID:5a68cd00-6948-46ff-9599-1b3803aaa73c:1:1:1:test.topic'
> could not be found. TrackingId:12ecc2a3-f8f3-42a3-8bd5-ad5d9823c367_B20,
> SystemTracker:my-namespace:topic:test.topic~15|qpid-jms:
> receiver:ID:5a68cd00-6948-46ff-9599-1b3803aaa73c:1:1:1:test.topic,
> Timestamp:8/8/2017 10:27:32 AM TrackingId:eddac23358584ea695974b0e0738b5cc_G28,
> SystemTracker:gateway6, Timestamp:8/8/2017 10:27:32 AM', info=null}}
> 2017-08-08T12:27:33.618 TRACE [org.apache.qpid.jms.provider.amqp.AmqpProvider]
> - New Proton Event: LINK_REMOTE_CLOSE
> 2017-08-08T12:27:33.618 WARN
> [org.apache.qpid.jms.provider.amqp.builders.AmqpResourceBuilder]
> - Open of resource:(JmsConsumerInfo: {
> ID:5a68cd00-6948-46ff-9599-1b3803aaa73c:1:1:1,
> destination = test.topic }) failed: The messaging entity
> 'my-namespace:topic:test.topic~15|qpid-jms:receiver:ID:
> 5a68cd00-6948-46ff-9599-1b3803aaa73c:1:1:1:test.topic' could not be found.
> TrackingId:12ecc2a3-f8f3-42a3-8bd5-ad5d9823c367_B20,
> SystemTracker:my-namespace:topic:test.topic~15|qpid-jms:
> receiver:ID:5a68cd00-6948-46ff-9599-1b3803aaa73c:1:1:1:test.topic,
> Timestamp:8/8/2017 10:27:32 AM TrackingId:eddac23358584ea695974b0e0738b5cc_G28,
> SystemTracker:gateway6, Timestamp:8/8/2017 10:27:32 AM [condition =
> amqp:not-found]
> 2017-08-08T12:27:33.619 TRACE [org.apache.qpid.jms.provider.amqp.AmqpProvider]
> - New Proton Event: LINK_LOCAL_CLOSE
> [350616316:1] -> Detach{handle=0, closed=true, error=null}
> 2017-08-08T12:27:33.619 TRACE [org.apache.qpid.jms.provider.amqp.FRAMES] -
> SENT: Detach{handle=0, closed=true, error=null}
> 2017-08-08T12:27:33.620 TRACE
> [org.apache.qpid.jms.transports.netty.NettyTcpTransport]
> - Attempted write of: 16 bytes
> javax.jms.InvalidDestinationException: The messaging entity
> 'my-namespace:topic:test.topic~15|qpid-jms:receiver:ID:
> 5a68cd00-6948-46ff-9599-1b3803aaa73c:1:1:1:test.topic' could not be found.
> TrackingId:12ecc2a3-f8f3-42a3-8bd5-ad5d9823c367_B20,
> SystemTracker:my-namespace:topic:test.topic~15|qpid-jms:
> receiver:ID:5a68cd00-6948-46ff-9599-1b3803aaa73c:1:1:1:test.topic,
> Timestamp:8/8/2017 10:27:32 AM TrackingId:eddac23358584ea695974b0e0738b5cc_G28,
> SystemTracker:gateway6, Timestamp:8/8/2017 10:27:32 AM [condition =
> amqp:not-found]
> at org.apache.qpid.jms.provider.amqp.AmqpSupport.convertToException(
> AmqpSupport.java:150)
> at org.apache.qpid.jms.provider.amqp.AmqpSupport.convertToException(
> AmqpSupport.java:117)
> at org.apache.qpid.jms.provider.amqp.builders.AmqpResourceBuilder.
> handleClosed(AmqpResourceBuilder.java:185)
> at org.apache.qpid.jms.provider.amqp.builders.AmqpResourceBuilder.
> processRemoteClose(AmqpResourceBuilder.java:129)
> at org.apache.qpid.jms.provider.amqp.AmqpProvider.
> processUpdates(AmqpProvider.java:905)
> at org.apache.qpid.jms.provider.amqp.AmqpProvider.access$1900(
> AmqpProvider.java:93)
> at org.apache.qpid.jms.provider.amqp.AmqpProvider$18.run(
> AmqpProvider.java:791)
> at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
> at java.util.concurrent.FutureTask.run(FutureTask.java:266)
> at java.util.concurrent.ScheduledThreadPoolExecutor$
> ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
> at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(
> ScheduledThreadPoolExecutor.java:293)
> 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:748)
> 2017-08-08T12:28:25.904 TRACE
> [org.apache.qpid.jms.transports.netty.NettyTcpTransport]
> - New data read: 8 bytes incoming: PooledUnsafeDirectByteBuf(ridx: 0, widx:
> 8, cap: 69)
> [350616316:0] <- Empty Frame
> 2017-08-08T12:28:25.905 TRACE [org.apache.qpid.jms.provider.amqp.FRAMES] -
> RECV: Empty Frame
> 2017-08-08T12:28:25.906 TRACE [org.apache.qpid.jms.provider.amqp.AmqpProvider]
> - New Proton Event: LINK_FINAL
>
>
> / Joacim
>
>
>
>
> On Tue, Aug 8, 2017 at 10:58 AM, 4 Integration <4i...@gmail.com>
> wrote:
>
>> Tested to change but the same error.
>>
>> //subscriber = subscriberSession.createDurableSubscriber(topic,
>> "DurableSubscriber1");
>> subscriber = subscriberSession.createConsumer(topic);
>>
>> In the exception - what is "~15" characters?
>>
>>
>> javax.jms.InvalidDestinationException: The messaging entity
>> 'my-namespace:topic:test.topic~15|qpid-jms:receiver:ID:
>> 26eaaacf-965f-4d10-869f-f77b9dca5918:1:1:1:test.topic' could not be
>> found. TrackingId:12ecc2a3-f8f3-42a3-8bd5-ad5d9823c367_B20,
>> SystemTracker:my-namespace:topic:test.topic~15|qpid-jms:
>> receiver:ID:26eaaacf-965f-4d10-869f-f77b9dca5918:1:1:1:test.topic,
>> Timestamp:8/8/2017 8:51:31 AM TrackingId:eddac23358584ea695974b0e0738b5cc_G28,
>> SystemTracker:gateway6, Timestamp:8/8/2017 8:51:31 AM [condition =
>> amqp:not-found]
>> at org.apache.qpid.jms.provider.amqp.AmqpSupport.convertToException(
>> AmqpSupport.java:150)
>> at org.apache.qpid.jms.provider.amqp.AmqpSupport.convertToException(
>> AmqpSupport.java:117)
>> at org.apache.qpid.jms.provider.amqp.builders.AmqpResourceBuilder.
>> handleClosed(AmqpResourceBuilder.java:185)
>> at org.apache.qpid.jms.provider.amqp.builders.AmqpResourceBuilder.
>> processRemoteClose(AmqpResourceBuilder.java:129)
>> at org.apache.qpid.jms.provider.amqp.AmqpProvider.
>> processUpdates(AmqpProvider.java:905)
>> at org.apache.qpid.jms.provider.amqp.AmqpProvider.access$1900(
>> AmqpProvider.java:93)
>> at org.apache.qpid.jms.provider.amqp.AmqpProvider$18.run(
>> AmqpProvider.java:791)
>> at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
>> at java.util.concurrent.FutureTask.run(FutureTask.java:266)
>> at java.util.concurrent.ScheduledThreadPoolExecutor$
>> ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
>> at java.util.concurrent.ScheduledThreadPoolExecutor$
>> ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
>> 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:748)
>>
>>
>> / Joacim
>>
>>
>>
>> On Tue, Aug 8, 2017 at 10:10 AM, Gordon Sim <gs...@redhat.com> wrote:
>>
>>> Does a non-durable subscription work?
>>>
>>>
>>> ---------------------------------------------------------------------
>>> To unsubscribe, e-mail: users-unsubscribe@qpid.apache.org
>>> For additional commands, e-mail: users-help@qpid.apache.org
>>>
>>>
>>
>
---------------------------------------------------------------------
To unsubscribe, e-mail: users-unsubscribe@qpid.apache.org
For additional commands, e-mail: users-help@qpid.apache.org
Re: Create durable subscription to Azure Service Bus
Posted by Gordon Sim <gs...@redhat.com>.
On 08/08/17 12:46, 4 Integration wrote:
> /(Also, service bus appears to be sending the detach *before* echoing
> the attach, which is a protocol error)./
Just for clarification, that part was from a different run where the
detach was before the attach. That is not the case on the latest trace.
---------------------------------------------------------------------
To unsubscribe, e-mail: users-unsubscribe@qpid.apache.org
For additional commands, e-mail: users-help@qpid.apache.org
Re: Create durable subscription to Azure Service Bus
Posted by 4 Integration <4i...@gmail.com>.
Additional input from Gordon: "
*This looks like either there is no source called test.topic configured on
the service bus, or it doesn't like the 'topic' capability. (You could try
a further experiment with another see if we can rule out one or other of
these).The ~15 seems to be coming from something on the service bus side.
(Also, service bus appears to be sending the detach *before* echoing the
attach, which is a protocol error).*"
The topic "test.topic" exist as shown in the below screenshot.
[image: Inline image 1]
Tested with topic "aaaa" but same exception
javax.jms.InvalidDestinationException: The messaging entity
'my-namespace:topic:aaaa~15|qpid ...
On Tue, Aug 8, 2017 at 1:27 PM, 4 Integration <4i...@gmail.com>
wrote:
> As suggested by Gordon => Running with env var PN_TRACE_FRM=1 and post the
> protocol trace you see.
>
> Configured a proper logger and got more details:
>
>
> 2017-08-08T12:27:31.202 TRACE [org.apache.qpid.jms.transports.TransportSupport]
> - Getting SSLContext instance using protocol: TLS
> 2017-08-08T12:27:31.562 TRACE [org.apache.qpid.jms.transports.TransportSupport]
> - Default protocols from the SSLEngine: [SSLv2Hello, TLSv1, TLSv1.1,
> TLSv1.2]
> 2017-08-08T12:27:31.562 TRACE [org.apache.qpid.jms.transports.TransportSupport]
> - Disabled protocols: [SSLv2Hello, SSLv3]
> 2017-08-08T12:27:31.562 TRACE [org.apache.qpid.jms.transports.TransportSupport]
> - Enabled protocols: [TLSv1, TLSv1.1, TLSv1.2]
> 2017-08-08T12:27:31.562 TRACE [org.apache.qpid.jms.transports.TransportSupport]
> - Default cipher suites from the SSLEngine: [TLS_ECDHE_ECDSA_WITH_AES_128_CBC_SHA256,
> TLS_ECDHE_RSA_WITH_AES_128_CBC_SHA256, TLS_RSA_WITH_AES_128_CBC_SHA256,
> TLS_ECDH_ECDSA_WITH_AES_128_CBC_SHA256, TLS_ECDH_RSA_WITH_AES_128_CBC_SHA256,
> TLS_DHE_RSA_WITH_AES_128_CBC_SHA256, TLS_DHE_DSS_WITH_AES_128_CBC_SHA256,
> TLS_ECDHE_ECDSA_WITH_AES_128_CBC_SHA, TLS_ECDHE_RSA_WITH_AES_128_CBC_SHA,
> TLS_RSA_WITH_AES_128_CBC_SHA, TLS_ECDH_ECDSA_WITH_AES_128_CBC_SHA,
> TLS_ECDH_RSA_WITH_AES_128_CBC_SHA, TLS_DHE_RSA_WITH_AES_128_CBC_SHA,
> TLS_DHE_DSS_WITH_AES_128_CBC_SHA, TLS_ECDHE_ECDSA_WITH_AES_128_GCM_SHA256,
> TLS_ECDHE_RSA_WITH_AES_128_GCM_SHA256, TLS_RSA_WITH_AES_128_GCM_SHA256,
> TLS_ECDH_ECDSA_WITH_AES_128_GCM_SHA256, TLS_ECDH_RSA_WITH_AES_128_GCM_SHA256,
> TLS_DHE_RSA_WITH_AES_128_GCM_SHA256, TLS_DHE_DSS_WITH_AES_128_GCM_SHA256,
> TLS_ECDHE_ECDSA_WITH_3DES_EDE_CBC_SHA, TLS_ECDHE_RSA_WITH_3DES_EDE_CBC_SHA,
> SSL_RSA_WITH_3DES_EDE_CBC_SHA, TLS_ECDH_ECDSA_WITH_3DES_EDE_CBC_SHA,
> TLS_ECDH_RSA_WITH_3DES_EDE_CBC_SHA, SSL_DHE_RSA_WITH_3DES_EDE_CBC_SHA,
> SSL_DHE_DSS_WITH_3DES_EDE_CBC_SHA, TLS_EMPTY_RENEGOTIATION_INFO_SCSV]
> 2017-08-08T12:27:31.563 TRACE [org.apache.qpid.jms.transports.TransportSupport]
> - Enabled cipher suites: [TLS_ECDHE_ECDSA_WITH_AES_128_CBC_SHA256,
> TLS_ECDHE_RSA_WITH_AES_128_CBC_SHA256, TLS_RSA_WITH_AES_128_CBC_SHA256,
> TLS_ECDH_ECDSA_WITH_AES_128_CBC_SHA256, TLS_ECDH_RSA_WITH_AES_128_CBC_SHA256,
> TLS_DHE_RSA_WITH_AES_128_CBC_SHA256, TLS_DHE_DSS_WITH_AES_128_CBC_SHA256,
> TLS_ECDHE_ECDSA_WITH_AES_128_CBC_SHA, TLS_ECDHE_RSA_WITH_AES_128_CBC_SHA,
> TLS_RSA_WITH_AES_128_CBC_SHA, TLS_ECDH_ECDSA_WITH_AES_128_CBC_SHA,
> TLS_ECDH_RSA_WITH_AES_128_CBC_SHA, TLS_DHE_RSA_WITH_AES_128_CBC_SHA,
> TLS_DHE_DSS_WITH_AES_128_CBC_SHA, TLS_ECDHE_ECDSA_WITH_AES_128_GCM_SHA256,
> TLS_ECDHE_RSA_WITH_AES_128_GCM_SHA256, TLS_RSA_WITH_AES_128_GCM_SHA256,
> TLS_ECDH_ECDSA_WITH_AES_128_GCM_SHA256, TLS_ECDH_RSA_WITH_AES_128_GCM_SHA256,
> TLS_DHE_RSA_WITH_AES_128_GCM_SHA256, TLS_DHE_DSS_WITH_AES_128_GCM_SHA256,
> TLS_ECDHE_ECDSA_WITH_3DES_EDE_CBC_SHA, TLS_ECDHE_RSA_WITH_3DES_EDE_CBC_SHA,
> SSL_RSA_WITH_3DES_EDE_CBC_SHA, TLS_ECDH_ECDSA_WITH_3DES_EDE_CBC_SHA,
> TLS_ECDH_RSA_WITH_3DES_EDE_CBC_SHA, SSL_DHE_RSA_WITH_3DES_EDE_CBC_SHA,
> SSL_DHE_DSS_WITH_3DES_EDE_CBC_SHA, TLS_EMPTY_RENEGOTIATION_INFO_SCSV]
> 2017-08-08T12:27:31.571 DEBUG [io.netty.util.internal.logging.InternalLoggerFactory]
> - Using SLF4J as the default logging framework
> 2017-08-08T12:27:31.586 DEBUG [io.netty.util.internal.PlatformDependent]
> - -Dio.netty.noUnsafe: false
> 2017-08-08T12:27:31.587 DEBUG [io.netty.util.internal.PlatformDependent0]
> - sun.misc.Unsafe.theUnsafe: available
> 2017-08-08T12:27:31.588 DEBUG [io.netty.util.internal.PlatformDependent0]
> - sun.misc.Unsafe.copyMemory: available
> 2017-08-08T12:27:31.588 DEBUG [io.netty.util.internal.PlatformDependent0]
> - java.nio.Buffer.address: available
> 2017-08-08T12:27:31.588 DEBUG [io.netty.util.internal.PlatformDependent0]
> - direct buffer constructor: available
> 2017-08-08T12:27:31.589 DEBUG [io.netty.util.internal.PlatformDependent0]
> - java.nio.Bits.unaligned: available, true
> 2017-08-08T12:27:31.589 DEBUG [io.netty.util.internal.PlatformDependent0]
> - java.nio.DirectByteBuffer.<init>(long, int): available
> 2017-08-08T12:27:31.589 DEBUG [io.netty.util.internal.Cleaner0] -
> java.nio.ByteBuffer.cleaner(): available
> 2017-08-08T12:27:31.590 DEBUG [io.netty.util.internal.PlatformDependent]
> - Platform: Windows
> 2017-08-08T12:27:31.590 DEBUG [io.netty.util.internal.PlatformDependent]
> - Java version: 8
> 2017-08-08T12:27:31.590 DEBUG [io.netty.util.internal.PlatformDependent]
> - sun.misc.Unsafe: available
> 2017-08-08T12:27:31.590 DEBUG [io.netty.util.internal.PlatformDependent]
> - -Dio.netty.tmpdir: C:\Users\myuser\AppData\Local\Temp (java.io.tmpdir)
> 2017-08-08T12:27:31.590 DEBUG [io.netty.util.internal.PlatformDependent]
> - -Dio.netty.bitMode: 64 (sun.arch.data.model)
> 2017-08-08T12:27:31.591 DEBUG [io.netty.util.internal.PlatformDependent]
> - -Dio.netty.noPreferDirect: false
> 2017-08-08T12:27:31.591 DEBUG [io.netty.util.internal.PlatformDependent]
> - io.netty.maxDirectMemory: 3743416320 bytes
> 2017-08-08T12:27:31.594 TRACE [org.apache.qpid.jms.transports.netty.NettyTcpTransport]
> - Netty Transport using NIO mode
> 2017-08-08T12:27:31.597 DEBUG [io.netty.channel.MultithreadEventLoopGroup]
> - -Dio.netty.eventLoopThreads: 16
> 2017-08-08T12:27:31.607 DEBUG [io.netty.channel.nio.NioEventLoop] -
> -Dio.netty.noKeySetOptimization: false
> 2017-08-08T12:27:31.607 DEBUG [io.netty.channel.nio.NioEventLoop] -
> -Dio.netty.selectorAutoRebuildThreshold: 512
> 2017-08-08T12:27:31.608 DEBUG [io.netty.util.internal.PlatformDependent]
> - org.jctools-core.MpscChunkedArrayQueue: available
> 2017-08-08T12:27:31.620 TRACE [io.netty.channel.nio.NioEventLoop] -
> instrumented a special java.util.Set into: sun.nio.ch.WindowsSelectorImpl
> @830d696
> 2017-08-08T12:27:31.647 DEBUG [io.netty.channel.DefaultChannelId] -
> -Dio.netty.processId: 11272 (auto-detected)
> 2017-08-08T12:27:31.649 DEBUG [io.netty.util.NetUtil] -
> -Djava.net.preferIPv4Stack: false
> 2017-08-08T12:27:31.649 DEBUG [io.netty.util.NetUtil] -
> -Djava.net.preferIPv6Addresses: false
> 2017-08-08T12:27:31.782 DEBUG [io.netty.util.NetUtil] - Loopback
> interface: lo (Software Loopback Interface 1, 127.0.0.1)
> 2017-08-08T12:27:31.782 DEBUG [io.netty.util.NetUtil] -
> \proc\sys\net\core\somaxconn: 200 (non-existent)
> 2017-08-08T12:27:31.942 DEBUG [io.netty.channel.DefaultChannelId] -
> -Dio.netty.machineId: 00:00:00:00:00:00:00:e0 (auto-detected)
> 2017-08-08T12:27:31.950 DEBUG [io.netty.util.ResourceLeakDetector] -
> -Dio.netty.leakDetection.level: simple
> 2017-08-08T12:27:31.950 DEBUG [io.netty.util.ResourceLeakDetector] -
> -Dio.netty.leakDetection.maxRecords: 4
> 2017-08-08T12:27:31.965 DEBUG [io.netty.buffer.PooledByteBufAllocator] -
> -Dio.netty.allocator.numHeapArenas: 16
> 2017-08-08T12:27:31.965 DEBUG [io.netty.buffer.PooledByteBufAllocator] -
> -Dio.netty.allocator.numDirectArenas: 16
> 2017-08-08T12:27:31.965 DEBUG [io.netty.buffer.PooledByteBufAllocator] -
> -Dio.netty.allocator.pageSize: 8192
> 2017-08-08T12:27:31.965 DEBUG [io.netty.buffer.PooledByteBufAllocator] -
> -Dio.netty.allocator.maxOrder: 11
> 2017-08-08T12:27:31.965 DEBUG [io.netty.buffer.PooledByteBufAllocator] -
> -Dio.netty.allocator.chunkSize: 16777216
> 2017-08-08T12:27:31.965 DEBUG [io.netty.buffer.PooledByteBufAllocator] -
> -Dio.netty.allocator.tinyCacheSize: 512
> 2017-08-08T12:27:31.965 DEBUG [io.netty.buffer.PooledByteBufAllocator] -
> -Dio.netty.allocator.smallCacheSize: 256
> 2017-08-08T12:27:31.965 DEBUG [io.netty.buffer.PooledByteBufAllocator] -
> -Dio.netty.allocator.normalCacheSize: 64
> 2017-08-08T12:27:31.965 DEBUG [io.netty.buffer.PooledByteBufAllocator] -
> -Dio.netty.allocator.maxCachedBufferCapacity: 32768
> 2017-08-08T12:27:31.965 DEBUG [io.netty.buffer.PooledByteBufAllocator] -
> -Dio.netty.allocator.cacheTrimInterval: 8192
> 2017-08-08T12:27:31.965 DEBUG [io.netty.buffer.PooledByteBufAllocator] -
> -Dio.netty.allocator.useCacheForAllThreads: true
> 2017-08-08T12:27:31.972 DEBUG [io.netty.buffer.ByteBufUtil] -
> -Dio.netty.allocator.type: pooled
> 2017-08-08T12:27:31.972 DEBUG [io.netty.buffer.ByteBufUtil] -
> -Dio.netty.threadLocalDirectBufferSize: 65536
> 2017-08-08T12:27:31.972 DEBUG [io.netty.buffer.ByteBufUtil] -
> -Dio.netty.maxThreadLocalCharBufferSize: 16384
> 2017-08-08T12:27:32.048 DEBUG [io.netty.util.Recycler] -
> -Dio.netty.recycler.maxCapacityPerThread: 32768
> 2017-08-08T12:27:32.048 DEBUG [io.netty.util.Recycler] -
> -Dio.netty.recycler.maxSharedCapacityFactor: 2
> 2017-08-08T12:27:32.048 DEBUG [io.netty.util.Recycler] -
> -Dio.netty.recycler.linkCapacity: 16
> 2017-08-08T12:27:32.048 DEBUG [io.netty.util.Recycler] -
> -Dio.netty.recycler.ratio: 8
> 2017-08-08T12:27:32.054 DEBUG [io.netty.buffer.AbstractByteBuf] -
> -Dio.netty.buffer.bytebuf.checkAccessible: true
> 2017-08-08T12:27:32.055 DEBUG [io.netty.util.ResourceLeakDetectorFactory]
> - Loaded default ResourceLeakDetector: io.netty.util.ResourceLeakDete
> ctor@4fa0104d
> 2017-08-08T12:27:32.187 TRACE [org.apache.qpid.jms.transports.netty.NettyTcpTransport]
> - SSL Handshake has completed: [id: 0x9d1338b4, L:/10.251.135.241:61550 -
> R:my-namespace.servicebus.windows.net/52.166.127.37:5671]
> 2017-08-08T12:27:32.187 TRACE [org.apache.qpid.jms.transports.netty.NettyTcpTransport]
> - Channel has become active! Channel is [id: 0x9d1338b4, L:/
> 10.251.135.241:61550 - R:my-namespace.servicebus.wind
> ows.net/52.166.127.37:5671]
> 2017-08-08T12:27:32.188 DEBUG [io.netty.handler.ssl.SslHandler] - [id:
> 0x9d1338b4, L:/10.251.135.241:61550 - R:my-namespace.servicebus.wind
> ows.net/52.166.127.37:5671] HANDSHAKEN: TLS_ECDHE_RSA_WITH_AES_128_CBC
> _SHA256
> 2017-08-08T12:27:32.206 TRACE [org.apache.qpid.jms.transports.netty.NettyTcpTransport]
> - Attempted write of: 8 bytes
> 2017-08-08T12:27:32.231 TRACE [org.apache.qpid.jms.transports.netty.NettyTcpTransport]
> - New data read: 8 bytes incoming: PooledUnsafeDirectByteBuf(ridx: 0,
> widx: 8, cap: 69)
> 2017-08-08T12:27:32.232 TRACE [org.apache.qpid.jms.provider.amqp.AmqpProvider]
> - New Proton Event: CONNECTION_INIT
> 2017-08-08T12:27:32.502 TRACE [org.apache.qpid.jms.transports.netty.NettyTcpTransport]
> - New data read: 63 bytes incoming: PooledUnsafeDirectByteBuf(ridx: 0,
> widx: 63, cap: 117)
> 2017-08-08T12:27:32.509 DEBUG [org.apache.qpid.jms.sasl.SaslMechanismFinder]
> - Unknown SASL mechanism: [MSSBCBS]
> 2017-08-08T12:27:32.522 DEBUG [org.apache.qpid.jms.sasl.SaslMechanismFinder]
> - Skipping SASL-EXTERNAL mechanism because the available credentials are
> not sufficient
> 2017-08-08T12:27:32.523 INFO [org.apache.qpid.jms.sasl.SaslMechanismFinder]
> - Best match for SASL auth was: SASL-PLAIN
> 2017-08-08T12:27:32.525 TRACE [org.apache.qpid.jms.transports.netty.NettyTcpTransport]
> - Attempted write of: 119 bytes
> 2017-08-08T12:27:32.549 TRACE [org.apache.qpid.jms.transports.netty.NettyTcpTransport]
> - New data read: 26 bytes incoming: PooledUnsafeDirectByteBuf(ridx: 0,
> widx: 26, cap: 85)
> 2017-08-08T12:27:32.550 TRACE [org.apache.qpid.jms.transports.netty.NettyTcpTransport]
> - Attempted write of: 8 bytes
> 2017-08-08T12:27:32.555 TRACE [org.apache.qpid.jms.util.MetaDataSupport]
> - Problem generating primary version details
> java.lang.NullPointerException
> at java.util.regex.Matcher.getTextLength(Matcher.java:1283)
> at java.util.regex.Matcher.reset(Matcher.java:309)
> at java.util.regex.Matcher.<init>(Matcher.java:229)
> at java.util.regex.Pattern.matcher(Pattern.java:1093)
> at org.apache.qpid.jms.util.MetaDataSupport.<clinit>(MetaDataSu
> pport.java:47)
> at org.apache.qpid.jms.provider.amqp.builders.AmqpConnectionBui
> lder.createEndpoint(AmqpConnectionBuilder.java:113)
> at org.apache.qpid.jms.provider.amqp.builders.AmqpConnectionBui
> lder.createEndpoint(AmqpConnectionBuilder.java:45)
> at org.apache.qpid.jms.provider.amqp.builders.AmqpResourceBuild
> er.buildResource(AmqpResourceBuilder.java:76)
> at org.apache.qpid.jms.provider.amqp.builders.AmqpConnectionBui
> lder.buildResource(AmqpConnectionBuilder.java:55)
> at org.apache.qpid.jms.provider.amqp.AmqpProvider$5$1.processCo
> nnectionInfo(AmqpProvider.java:372)
> at org.apache.qpid.jms.meta.JmsConnectionInfo.visit(JmsConnecti
> onInfo.java:417)
> at org.apache.qpid.jms.provider.amqp.AmqpProvider$5.run(AmqpPro
> vider.java:331)
> at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
> at java.util.concurrent.FutureTask.run(FutureTask.java:266)
> at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFu
> tureTask.access$201(ScheduledThreadPoolExecutor.java:180)
> at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFu
> tureTask.run(ScheduledThreadPoolExecutor.java:293)
> at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPool
> Executor.java:1142)
> at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoo
> lExecutor.java:617)
> at java.lang.Thread.run(Thread.java:748)
> [350616316:0] -> Open{ containerId='TestSubscriber', hostname='
> my-namespace.servicebus.windows.net', maxFrameSize=1048576,
> channelMax=32767, idleTimeOut=60000, outgoingLocales=null,
> incomingLocales=null, offeredCapabilities=null,
> desiredCapabilities=[sole-connection-for-container],
> properties={product=QpidJMS, version=0.23.0, platform=JVM: 1.8.0_131,
> 25.131-b11, Oracle Corporation, OS: Windows 7, 6.1, amd64}}
> 2017-08-08T12:27:32.565 TRACE [org.apache.qpid.jms.provider.amqp.FRAMES]
> - SENT: Open{ containerId='TestSubscriber', hostname='my-namespace.service
> bus.windows.net', maxFrameSize=1048576, channelMax=32767,
> idleTimeOut=60000, outgoingLocales=null, incomingLocales=null,
> offeredCapabilities=null, desiredCapabilities=[sole-connection-for-container],
> properties={product=QpidJMS, version=0.23.0, platform=JVM: 1.8.0_131,
> 25.131-b11, Oracle Corporation, OS: Windows 7, 6.1, amd64}}
> 2017-08-08T12:27:32.566 TRACE [org.apache.qpid.jms.transports.netty.NettyTcpTransport]
> - Attempted write of: 236 bytes
> 2017-08-08T12:27:32.574 TRACE [org.apache.qpid.jms.transports.netty.NettyTcpTransport]
> - New data read: 8 bytes incoming: PooledUnsafeDirectByteBuf(ridx: 0,
> widx: 8, cap: 69)
> 2017-08-08T12:27:32.574 TRACE [org.apache.qpid.jms.provider.amqp.AmqpProvider]
> - New Proton Event: CONNECTION_LOCAL_OPEN
> 2017-08-08T12:27:32.803 TRACE [org.apache.qpid.jms.transports.netty.NettyTcpTransport]
> - New data read: 71 bytes incoming: PooledUnsafeDirectByteBuf(ridx: 0,
> widx: 71, cap: 133)
> [350616316:0] <- Open{ containerId='eddac23358584ea695974b0e0738b5cc_G28',
> hostname='null', maxFrameSize=65536, channelMax=4999, idleTimeOut=240000,
> outgoingLocales=null, incomingLocales=null, offeredCapabilities=null,
> desiredCapabilities=null, properties=null}
> 2017-08-08T12:27:32.804 TRACE [org.apache.qpid.jms.provider.amqp.FRAMES]
> - RECV: Open{ containerId='eddac23358584ea695974b0e0738b5cc_G28',
> hostname='null', maxFrameSize=65536, channelMax=4999, idleTimeOut=240000,
> outgoingLocales=null, incomingLocales=null, offeredCapabilities=null,
> desiredCapabilities=null, properties=null}
> 2017-08-08T12:27:32.805 TRACE [org.apache.qpid.jms.provider.amqp.AmqpProvider]
> - New Proton Event: CONNECTION_REMOTE_OPEN
> 2017-08-08T12:27:32.811 TRACE [org.apache.qpid.jms.provider.amqp.AmqpProvider]
> - New Proton Event: SESSION_INIT
> 2017-08-08T12:27:32.812 TRACE [org.apache.qpid.jms.provider.amqp.AmqpProvider]
> - New Proton Event: SESSION_LOCAL_OPEN
> [350616316:0] -> Begin{remoteChannel=null, nextOutgoingId=1,
> incomingWindow=2047, outgoingWindow=2147483647 <(214)%20748-3647>,
> handleMax=65535, offeredCapabilities=null, desiredCapabilities=null,
> properties=null}
> 2017-08-08T12:27:32.816 TRACE [org.apache.qpid.jms.provider.amqp.FRAMES]
> - SENT: Begin{remoteChannel=null, nextOutgoingId=1, incomingWindow=2047,
> outgoingWindow=2147483647 <(214)%20748-3647>, handleMax=65535,
> offeredCapabilities=null, desiredCapabilities=null, properties=null}
> 2017-08-08T12:27:32.817 TRACE [org.apache.qpid.jms.transports.netty.NettyTcpTransport]
> - Attempted write of: 32 bytes
> 2017-08-08T12:27:32.841 TRACE [org.apache.qpid.jms.transports.netty.NettyTcpTransport]
> - New data read: 34 bytes incoming: PooledUnsafeDirectByteBuf(ridx: 0,
> widx: 34, cap: 101)
> [350616316:0] <- Begin{remoteChannel=0, nextOutgoingId=1,
> incomingWindow=5000, outgoingWindow=2047, handleMax=255,
> offeredCapabilities=null, desiredCapabilities=null, properties=null}
> 2017-08-08T12:27:32.842 TRACE [org.apache.qpid.jms.provider.amqp.FRAMES]
> - RECV: Begin{remoteChannel=0, nextOutgoingId=1, incomingWindow=5000,
> outgoingWindow=2047, handleMax=255, offeredCapabilities=null,
> desiredCapabilities=null, properties=null}
> 2017-08-08T12:27:32.842 TRACE [org.apache.qpid.jms.provider.amqp.AmqpProvider]
> - New Proton Event: SESSION_REMOTE_OPEN
> 2017-08-08T12:27:32.842 DEBUG [org.apache.qpid.jms.provider.
> amqp.builders.AmqpConnectionBuilder] - AmqpConnection {
> ID:5a68cd00-6948-46ff-9599-1b3803aaa73c:1 } is now open:
> 2017-08-08T12:27:32.842 TRACE [org.apache.qpid.jms.provider.amqp.AmqpProvider]
> - IdleTimeoutCheck being initiated, initial delay: 120000
> 2017-08-08T12:27:32.843 INFO [org.apache.qpid.jms.JmsConnection] -
> Connection ID:5a68cd00-6948-46ff-9599-1b3803aaa73c:1 connected to remote
> Broker: amqps://my-namespace.servicebus.windows.net:5671?amqp.
> idleTimeout=120000&amqp.traceFrames=true
> <http://my-namespace.servicebus.windows.net:5671/?amqp.idleTimeout=120000&amqp.traceFrames=true>
> [350616316:1] -> Begin{remoteChannel=null, nextOutgoingId=1,
> incomingWindow=2047, outgoingWindow=2147483647 <(214)%20748-3647>,
> handleMax=65535, offeredCapabilities=null, desiredCapabilities=null,
> properties=null}
> 2017-08-08T12:27:32.859 TRACE [org.apache.qpid.jms.provider.amqp.FRAMES]
> - SENT: Begin{remoteChannel=null, nextOutgoingId=1, incomingWindow=2047,
> outgoingWindow=2147483647 <(214)%20748-3647>, handleMax=65535,
> offeredCapabilities=null, desiredCapabilities=null, properties=null}
> 2017-08-08T12:27:32.859 TRACE [org.apache.qpid.jms.transports.netty.NettyTcpTransport]
> - Attempted write of: 32 bytes
> 2017-08-08T12:27:32.883 TRACE [org.apache.qpid.jms.transports.netty.NettyTcpTransport]
> - New data read: 34 bytes incoming: PooledUnsafeDirectByteBuf(ridx: 0,
> widx: 34, cap: 101)
> [350616316:1] <- Begin{remoteChannel=1, nextOutgoingId=1,
> incomingWindow=5000, outgoingWindow=2047, handleMax=255,
> offeredCapabilities=null, desiredCapabilities=null, properties=null}
> 2017-08-08T12:27:32.883 TRACE [org.apache.qpid.jms.provider.amqp.FRAMES]
> - RECV: Begin{remoteChannel=1, nextOutgoingId=1, incomingWindow=5000,
> outgoingWindow=2047, handleMax=255, offeredCapabilities=null,
> desiredCapabilities=null, properties=null}
> 2017-08-08T12:27:32.884 TRACE [org.apache.qpid.jms.provider.amqp.AmqpProvider]
> - New Proton Event: SESSION_INIT
> 2017-08-08T12:27:32.884 TRACE [org.apache.qpid.jms.provider.amqp.AmqpProvider]
> - New Proton Event: SESSION_LOCAL_OPEN
> 2017-08-08T12:27:32.884 TRACE [org.apache.qpid.jms.provider.amqp.AmqpProvider]
> - New Proton Event: SESSION_REMOTE_OPEN
> [350616316:1] -> Attach{name='qpid-jms:receiver
> :ID:5a68cd00-6948-46ff-9599-1b3803aaa73c:1:1:1:test.topic', handle=0,
> role=RECEIVER, sndSettleMode=UNSETTLED, rcvSettleMode=FIRST,
> source=Source{address='test.topic', durable=NONE,
> expiryPolicy=LINK_DETACH, timeout=0, dynamic=false,
> dynamicNodeProperties=null, distributionMode=null, filter=null,
> defaultOutcome=Modified{deliveryFailed=true, undeliverableHere=null,
> messageAnnotations=null}, outcomes=[amqp:accepted:list, amqp:rejected:list,
> amqp:released:list, amqp:modified:list], capabilities=[topic]},
> target=Target{address='null', durable=NONE, expiryPolicy=SESSION_END,
> timeout=0, dynamic=false, dynamicNodeProperties=null, capabilities=null},
> unsettled=null, incompleteUnsettled=false, initialDeliveryCount=null,
> maxMessageSize=null, offeredCapabilities=null, desiredCapabilities=null,
> properties=null}
> 2017-08-08T12:27:32.905 TRACE [org.apache.qpid.jms.provider.amqp.FRAMES]
> - SENT: Attach{name='qpid-jms:receiver:ID:5a68cd00-6948-46ff-9599-
> 1b3803aaa73c:1:1:1:test.topic', handle=0, role=RECEIVER,
> sndSettleMode=UNSETTLED, rcvSettleMode=FIRST, source=Source{address='
> test.topic', durable=NONE, expiryPolicy=LINK_DETACH, timeout=0,
> dynamic=false, dynamicNodeProperties=null, distributionMode=null,
> filter=null, defaultOutcome=Modified{deliveryFailed=true,
> undeliverableHere=null, messageAnnotations=null},
> outcomes=[amqp:accepted:list, amqp:rejected:list, amqp:released:list,
> amqp:modified:list], capabilities=[topic]}, target=Target{address='null',
> durable=NONE, expiryPolicy=SESSION_END, timeout=0, dynamic=false,
> dynamicNodeProperties=null, capabilities=null}, unsettled=null,
> incompleteUnsettled=false, initialDeliveryCount=null, maxMessageSize=null,
> offeredCapabilities=null, desiredCapabilities=null, properties=null}
> 2017-08-08T12:27:32.906 TRACE [org.apache.qpid.jms.transports.netty.NettyTcpTransport]
> - Attempted write of: 234 bytes
> 2017-08-08T12:27:33.395 TRACE [org.apache.qpid.jms.transports.netty.NettyTcpTransport]
> - New data read: 180 bytes incoming: PooledUnsafeDirectByteBuf(ridx: 0,
> widx: 180, cap: 245)
> [350616316:1] <- Attach{name='qpid-jms:receiver
> :ID:5a68cd00-6948-46ff-9599-1b3803aaa73c:1:1:1:test.topic', handle=0,
> role=SENDER, sndSettleMode=UNSETTLED, rcvSettleMode=FIRST, source=null,
> target=null, unsettled=null, incompleteUnsettled=false,
> initialDeliveryCount=0, maxMessageSize=266240, offeredCapabilities=null,
> desiredCapabilities=null, properties={com.microsoft:trac
> king-id=eddac23358584ea695974b0e0738b5cc_G28}}
> 2017-08-08T12:27:33.396 TRACE [org.apache.qpid.jms.provider.amqp.FRAMES]
> - RECV: Attach{name='qpid-jms:receiver:ID:5a68cd00-6948-46ff-9599-
> 1b3803aaa73c:1:1:1:test.topic', handle=0, role=SENDER,
> sndSettleMode=UNSETTLED, rcvSettleMode=FIRST, source=null, target=null,
> unsettled=null, incompleteUnsettled=false, initialDeliveryCount=0,
> maxMessageSize=266240, offeredCapabilities=null, desiredCapabilities=null,
> properties={com.microsoft:tracking-id=eddac23358584ea695974b
> 0e0738b5cc_G28}}
> 2017-08-08T12:27:33.397 TRACE [org.apache.qpid.jms.provider.amqp.AmqpProvider]
> - New Proton Event: LINK_INIT
> 2017-08-08T12:27:33.397 TRACE [org.apache.qpid.jms.provider.amqp.AmqpProvider]
> - New Proton Event: LINK_LOCAL_OPEN
> 2017-08-08T12:27:33.397 TRACE [org.apache.qpid.jms.provider.amqp.AmqpProvider]
> - New Proton Event: LINK_REMOTE_OPEN
> 2017-08-08T12:27:33.617 TRACE [org.apache.qpid.jms.transports.netty.NettyTcpTransport]
> - New data read: 509 bytes incoming: PooledUnsafeDirectByteBuf(ridx: 0,
> widx: 509, cap: 565)
> [350616316:1] <- Detach{handle=0, closed=true,
> error=Error{condition=amqp:not-found, description='The messaging entity
> 'my-namespace:topic:test.topic~15|qpid-jms:receiver:ID:5a68c
> d00-6948-46ff-9599-1b3803aaa73c:1:1:1:test.topic' could not be found.
> TrackingId:12ecc2a3-f8f3-42a3-8bd5-ad5d9823c367_B20,
> SystemTracker:my-namespace:topic:test.topic~15|qpid-jms:rece
> iver:ID:5a68cd00-6948-46ff-9599-1b3803aaa73c:1:1:1:test.topic,
> Timestamp:8/8/2017 10:27:32 AM TrackingId:eddac23358584ea695974b0e0738b5cc_G28,
> SystemTracker:gateway6, Timestamp:8/8/2017 10:27:32 AM', info=null}}
> 2017-08-08T12:27:33.618 TRACE [org.apache.qpid.jms.provider.amqp.FRAMES]
> - RECV: Detach{handle=0, closed=true, error=Error{condition=amqp:not-found,
> description='The messaging entity 'my-namespace:topic:test.topic
> ~15|qpid-jms:receiver:ID:5a68cd00-6948-46ff-9599-1b3803aaa73c:1:1:1:test.topic'
> could not be found. TrackingId:12ecc2a3-f8f3-42a3-8bd5-ad5d9823c367_B20,
> SystemTracker:my-namespace:topic:test.topic~15|qpid-jms:rece
> iver:ID:5a68cd00-6948-46ff-9599-1b3803aaa73c:1:1:1:test.topic,
> Timestamp:8/8/2017 10:27:32 AM TrackingId:eddac23358584ea695974b0e0738b5cc_G28,
> SystemTracker:gateway6, Timestamp:8/8/2017 10:27:32 AM', info=null}}
> 2017-08-08T12:27:33.618 TRACE [org.apache.qpid.jms.provider.amqp.AmqpProvider]
> - New Proton Event: LINK_REMOTE_CLOSE
> 2017-08-08T12:27:33.618 WARN [org.apache.qpid.jms.provider
> .amqp.builders.AmqpResourceBuilder] - Open of resource:(JmsConsumerInfo:
> { ID:5a68cd00-6948-46ff-9599-1b3803aaa73c:1:1:1, destination = test.topic
> }) failed: The messaging entity 'my-namespace:topic:test.topic
> ~15|qpid-jms:receiver:ID:5a68cd00-6948-46ff-9599-1b3803aaa73c:1:1:1:test.topic'
> could not be found. TrackingId:12ecc2a3-f8f3-42a3-8bd5-ad5d9823c367_B20,
> SystemTracker:my-namespace:topic:test.topic~15|qpid-jms:rece
> iver:ID:5a68cd00-6948-46ff-9599-1b3803aaa73c:1:1:1:test.topic,
> Timestamp:8/8/2017 10:27:32 AM TrackingId:eddac23358584ea695974b0e0738b5cc_G28,
> SystemTracker:gateway6, Timestamp:8/8/2017 10:27:32 AM [condition =
> amqp:not-found]
> 2017-08-08T12:27:33.619 TRACE [org.apache.qpid.jms.provider.amqp.AmqpProvider]
> - New Proton Event: LINK_LOCAL_CLOSE
> [350616316:1] -> Detach{handle=0, closed=true, error=null}
> 2017-08-08T12:27:33.619 TRACE [org.apache.qpid.jms.provider.amqp.FRAMES]
> - SENT: Detach{handle=0, closed=true, error=null}
> 2017-08-08T12:27:33.620 TRACE [org.apache.qpid.jms.transports.netty.NettyTcpTransport]
> - Attempted write of: 16 bytes
> javax.jms.InvalidDestinationException: The messaging entity
> 'my-namespace:topic:test.topic~15|qpid-jms:receiver:ID:5a68c
> d00-6948-46ff-9599-1b3803aaa73c:1:1:1:test.topic' could not be found.
> TrackingId:12ecc2a3-f8f3-42a3-8bd5-ad5d9823c367_B20,
> SystemTracker:my-namespace:topic:test.topic~15|qpid-jms:rece
> iver:ID:5a68cd00-6948-46ff-9599-1b3803aaa73c:1:1:1:test.topic,
> Timestamp:8/8/2017 10:27:32 AM TrackingId:eddac23358584ea695974b0e0738b5cc_G28,
> SystemTracker:gateway6, Timestamp:8/8/2017 10:27:32 AM [condition =
> amqp:not-found]
> at org.apache.qpid.jms.provider.amqp.AmqpSupport.convertToExcep
> tion(AmqpSupport.java:150)
> at org.apache.qpid.jms.provider.amqp.AmqpSupport.convertToExcep
> tion(AmqpSupport.java:117)
> at org.apache.qpid.jms.provider.amqp.builders.AmqpResourceBuild
> er.handleClosed(AmqpResourceBuilder.java:185)
> at org.apache.qpid.jms.provider.amqp.builders.AmqpResourceBuild
> er.processRemoteClose(AmqpResourceBuilder.java:129)
> at org.apache.qpid.jms.provider.amqp.AmqpProvider.processUpdate
> s(AmqpProvider.java:905)
> at org.apache.qpid.jms.provider.amqp.AmqpProvider.access$1900(A
> mqpProvider.java:93)
> at org.apache.qpid.jms.provider.amqp.AmqpProvider$18.run(AmqpPr
> ovider.java:791)
> at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
> at java.util.concurrent.FutureTask.run(FutureTask.java:266)
> at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFu
> tureTask.access$201(ScheduledThreadPoolExecutor.java:180)
> at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFu
> tureTask.run(ScheduledThreadPoolExecutor.java:293)
> at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPool
> Executor.java:1142)
> at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoo
> lExecutor.java:617)
> at java.lang.Thread.run(Thread.java:748)
> 2017-08-08T12:28:25.904 TRACE [org.apache.qpid.jms.transports.netty.NettyTcpTransport]
> - New data read: 8 bytes incoming: PooledUnsafeDirectByteBuf(ridx: 0,
> widx: 8, cap: 69)
> [350616316:0] <- Empty Frame
> 2017-08-08T12:28:25.905 TRACE [org.apache.qpid.jms.provider.amqp.FRAMES]
> - RECV: Empty Frame
> 2017-08-08T12:28:25.906 TRACE [org.apache.qpid.jms.provider.amqp.AmqpProvider]
> - New Proton Event: LINK_FINAL
>
>
> / Joacim
>
>
>
>
> On Tue, Aug 8, 2017 at 10:58 AM, 4 Integration <4i...@gmail.com>
> wrote:
>
>> Tested to change but the same error.
>>
>> //subscriber = subscriberSession.createDurableSubscriber(topic,
>> "DurableSubscriber1");
>> subscriber = subscriberSession.createConsumer(topic);
>>
>> In the exception - what is "~15" characters?
>>
>>
>> javax.jms.InvalidDestinationException: The messaging entity
>> 'my-namespace:topic:test.topic~15|qpid-jms:receiver:ID:26eaa
>> acf-965f-4d10-869f-f77b9dca5918:1:1:1:test.topic' could not be found.
>> TrackingId:12ecc2a3-f8f3-42a3-8bd5-ad5d9823c367_B20,
>> SystemTracker:my-namespace:topic:test.topic~15|qpid-jms:rece
>> iver:ID:26eaaacf-965f-4d10-869f-f77b9dca5918:1:1:1:test.topic,
>> Timestamp:8/8/2017 8:51:31 AM TrackingId:eddac23358584ea695974b0e0738b5cc_G28,
>> SystemTracker:gateway6, Timestamp:8/8/2017 8:51:31 AM [condition =
>> amqp:not-found]
>> at org.apache.qpid.jms.provider.amqp.AmqpSupport.convertToExcep
>> tion(AmqpSupport.java:150)
>> at org.apache.qpid.jms.provider.amqp.AmqpSupport.convertToExcep
>> tion(AmqpSupport.java:117)
>> at org.apache.qpid.jms.provider.amqp.builders.AmqpResourceBuild
>> er.handleClosed(AmqpResourceBuilder.java:185)
>> at org.apache.qpid.jms.provider.amqp.builders.AmqpResourceBuild
>> er.processRemoteClose(AmqpResourceBuilder.java:129)
>> at org.apache.qpid.jms.provider.amqp.AmqpProvider.processUpdate
>> s(AmqpProvider.java:905)
>> at org.apache.qpid.jms.provider.amqp.AmqpProvider.access$1900(A
>> mqpProvider.java:93)
>> at org.apache.qpid.jms.provider.amqp.AmqpProvider$18.run(AmqpPr
>> ovider.java:791)
>> at java.util.concurrent.Executors$RunnableAdapter.call(
>> Executors.java:511)
>> at java.util.concurrent.FutureTask.run(FutureTask.java:266)
>> at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFu
>> tureTask.access$201(ScheduledThreadPoolExecutor.java:180)
>> at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFu
>> tureTask.run(ScheduledThreadPoolExecutor.java:293)
>> at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPool
>> Executor.java:1142)
>> at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoo
>> lExecutor.java:617)
>> at java.lang.Thread.run(Thread.java:748)
>>
>>
>> / Joacim
>>
>>
>>
>> On Tue, Aug 8, 2017 at 10:10 AM, Gordon Sim <gs...@redhat.com> wrote:
>>
>>> Does a non-durable subscription work?
>>>
>>>
>>> ---------------------------------------------------------------------
>>> To unsubscribe, e-mail: users-unsubscribe@qpid.apache.org
>>> For additional commands, e-mail: users-help@qpid.apache.org
>>>
>>>
>>
>
Re: Create durable subscription to Azure Service Bus
Posted by 4 Integration <4i...@gmail.com>.
As suggested by Gordon => Running with env var PN_TRACE_FRM=1 and post the
protocol trace you see.
Configured a proper logger and got more details:
2017-08-08T12:27:31.202 TRACE [org.apache.qpid.jms.transports.TransportSupport]
- Getting SSLContext instance using protocol: TLS
2017-08-08T12:27:31.562 TRACE [org.apache.qpid.jms.transports.TransportSupport]
- Default protocols from the SSLEngine: [SSLv2Hello, TLSv1, TLSv1.1,
TLSv1.2]
2017-08-08T12:27:31.562 TRACE [org.apache.qpid.jms.transports.TransportSupport]
- Disabled protocols: [SSLv2Hello, SSLv3]
2017-08-08T12:27:31.562 TRACE [org.apache.qpid.jms.transports.TransportSupport]
- Enabled protocols: [TLSv1, TLSv1.1, TLSv1.2]
2017-08-08T12:27:31.562 TRACE [org.apache.qpid.jms.transports.TransportSupport]
- Default cipher suites from the SSLEngine:
[TLS_ECDHE_ECDSA_WITH_AES_128_CBC_SHA256,
TLS_ECDHE_RSA_WITH_AES_128_CBC_SHA256, TLS_RSA_WITH_AES_128_CBC_SHA256,
TLS_ECDH_ECDSA_WITH_AES_128_CBC_SHA256, TLS_ECDH_RSA_WITH_AES_128_CBC_SHA256,
TLS_DHE_RSA_WITH_AES_128_CBC_SHA256, TLS_DHE_DSS_WITH_AES_128_CBC_SHA256,
TLS_ECDHE_ECDSA_WITH_AES_128_CBC_SHA, TLS_ECDHE_RSA_WITH_AES_128_CBC_SHA,
TLS_RSA_WITH_AES_128_CBC_SHA, TLS_ECDH_ECDSA_WITH_AES_128_CBC_SHA,
TLS_ECDH_RSA_WITH_AES_128_CBC_SHA, TLS_DHE_RSA_WITH_AES_128_CBC_SHA,
TLS_DHE_DSS_WITH_AES_128_CBC_SHA, TLS_ECDHE_ECDSA_WITH_AES_128_GCM_SHA256,
TLS_ECDHE_RSA_WITH_AES_128_GCM_SHA256, TLS_RSA_WITH_AES_128_GCM_SHA256,
TLS_ECDH_ECDSA_WITH_AES_128_GCM_SHA256, TLS_ECDH_RSA_WITH_AES_128_GCM_SHA256,
TLS_DHE_RSA_WITH_AES_128_GCM_SHA256, TLS_DHE_DSS_WITH_AES_128_GCM_SHA256,
TLS_ECDHE_ECDSA_WITH_3DES_EDE_CBC_SHA, TLS_ECDHE_RSA_WITH_3DES_EDE_CBC_SHA,
SSL_RSA_WITH_3DES_EDE_CBC_SHA, TLS_ECDH_ECDSA_WITH_3DES_EDE_CBC_SHA,
TLS_ECDH_RSA_WITH_3DES_EDE_CBC_SHA, SSL_DHE_RSA_WITH_3DES_EDE_CBC_SHA,
SSL_DHE_DSS_WITH_3DES_EDE_CBC_SHA, TLS_EMPTY_RENEGOTIATION_INFO_SCSV]
2017-08-08T12:27:31.563 TRACE [org.apache.qpid.jms.transports.TransportSupport]
- Enabled cipher suites: [TLS_ECDHE_ECDSA_WITH_AES_128_CBC_SHA256,
TLS_ECDHE_RSA_WITH_AES_128_CBC_SHA256, TLS_RSA_WITH_AES_128_CBC_SHA256,
TLS_ECDH_ECDSA_WITH_AES_128_CBC_SHA256, TLS_ECDH_RSA_WITH_AES_128_CBC_SHA256,
TLS_DHE_RSA_WITH_AES_128_CBC_SHA256, TLS_DHE_DSS_WITH_AES_128_CBC_SHA256,
TLS_ECDHE_ECDSA_WITH_AES_128_CBC_SHA, TLS_ECDHE_RSA_WITH_AES_128_CBC_SHA,
TLS_RSA_WITH_AES_128_CBC_SHA, TLS_ECDH_ECDSA_WITH_AES_128_CBC_SHA,
TLS_ECDH_RSA_WITH_AES_128_CBC_SHA, TLS_DHE_RSA_WITH_AES_128_CBC_SHA,
TLS_DHE_DSS_WITH_AES_128_CBC_SHA, TLS_ECDHE_ECDSA_WITH_AES_128_GCM_SHA256,
TLS_ECDHE_RSA_WITH_AES_128_GCM_SHA256, TLS_RSA_WITH_AES_128_GCM_SHA256,
TLS_ECDH_ECDSA_WITH_AES_128_GCM_SHA256, TLS_ECDH_RSA_WITH_AES_128_GCM_SHA256,
TLS_DHE_RSA_WITH_AES_128_GCM_SHA256, TLS_DHE_DSS_WITH_AES_128_GCM_SHA256,
TLS_ECDHE_ECDSA_WITH_3DES_EDE_CBC_SHA, TLS_ECDHE_RSA_WITH_3DES_EDE_CBC_SHA,
SSL_RSA_WITH_3DES_EDE_CBC_SHA, TLS_ECDH_ECDSA_WITH_3DES_EDE_CBC_SHA,
TLS_ECDH_RSA_WITH_3DES_EDE_CBC_SHA, SSL_DHE_RSA_WITH_3DES_EDE_CBC_SHA,
SSL_DHE_DSS_WITH_3DES_EDE_CBC_SHA, TLS_EMPTY_RENEGOTIATION_INFO_SCSV]
2017-08-08T12:27:31.571 DEBUG
[io.netty.util.internal.logging.InternalLoggerFactory]
- Using SLF4J as the default logging framework
2017-08-08T12:27:31.586 DEBUG [io.netty.util.internal.PlatformDependent] -
-Dio.netty.noUnsafe: false
2017-08-08T12:27:31.587 DEBUG [io.netty.util.internal.PlatformDependent0] -
sun.misc.Unsafe.theUnsafe: available
2017-08-08T12:27:31.588 DEBUG [io.netty.util.internal.PlatformDependent0] -
sun.misc.Unsafe.copyMemory: available
2017-08-08T12:27:31.588 DEBUG [io.netty.util.internal.PlatformDependent0] -
java.nio.Buffer.address: available
2017-08-08T12:27:31.588 DEBUG [io.netty.util.internal.PlatformDependent0] -
direct buffer constructor: available
2017-08-08T12:27:31.589 DEBUG [io.netty.util.internal.PlatformDependent0] -
java.nio.Bits.unaligned: available, true
2017-08-08T12:27:31.589 DEBUG [io.netty.util.internal.PlatformDependent0] -
java.nio.DirectByteBuffer.<init>(long, int): available
2017-08-08T12:27:31.589 DEBUG [io.netty.util.internal.Cleaner0] -
java.nio.ByteBuffer.cleaner(): available
2017-08-08T12:27:31.590 DEBUG [io.netty.util.internal.PlatformDependent] -
Platform: Windows
2017-08-08T12:27:31.590 DEBUG [io.netty.util.internal.PlatformDependent] -
Java version: 8
2017-08-08T12:27:31.590 DEBUG [io.netty.util.internal.PlatformDependent] -
sun.misc.Unsafe: available
2017-08-08T12:27:31.590 DEBUG [io.netty.util.internal.PlatformDependent] -
-Dio.netty.tmpdir: C:\Users\myuser\AppData\Local\Temp (java.io.tmpdir)
2017-08-08T12:27:31.590 DEBUG [io.netty.util.internal.PlatformDependent] -
-Dio.netty.bitMode: 64 (sun.arch.data.model)
2017-08-08T12:27:31.591 DEBUG [io.netty.util.internal.PlatformDependent] -
-Dio.netty.noPreferDirect: false
2017-08-08T12:27:31.591 DEBUG [io.netty.util.internal.PlatformDependent] -
io.netty.maxDirectMemory: 3743416320 bytes
2017-08-08T12:27:31.594 TRACE
[org.apache.qpid.jms.transports.netty.NettyTcpTransport]
- Netty Transport using NIO mode
2017-08-08T12:27:31.597 DEBUG [io.netty.channel.MultithreadEventLoopGroup]
- -Dio.netty.eventLoopThreads: 16
2017-08-08T12:27:31.607 DEBUG [io.netty.channel.nio.NioEventLoop] -
-Dio.netty.noKeySetOptimization: false
2017-08-08T12:27:31.607 DEBUG [io.netty.channel.nio.NioEventLoop] -
-Dio.netty.selectorAutoRebuildThreshold: 512
2017-08-08T12:27:31.608 DEBUG [io.netty.util.internal.PlatformDependent] -
org.jctools-core.MpscChunkedArrayQueue: available
2017-08-08T12:27:31.620 TRACE [io.netty.channel.nio.NioEventLoop] -
instrumented a special java.util.Set into: sun.nio.ch.
WindowsSelectorImpl@830d696
2017-08-08T12:27:31.647 DEBUG [io.netty.channel.DefaultChannelId] -
-Dio.netty.processId: 11272 (auto-detected)
2017-08-08T12:27:31.649 DEBUG [io.netty.util.NetUtil] -
-Djava.net.preferIPv4Stack: false
2017-08-08T12:27:31.649 DEBUG [io.netty.util.NetUtil] -
-Djava.net.preferIPv6Addresses:
false
2017-08-08T12:27:31.782 DEBUG [io.netty.util.NetUtil] - Loopback interface:
lo (Software Loopback Interface 1, 127.0.0.1)
2017-08-08T12:27:31.782 DEBUG [io.netty.util.NetUtil] -
\proc\sys\net\core\somaxconn: 200 (non-existent)
2017-08-08T12:27:31.942 DEBUG [io.netty.channel.DefaultChannelId] -
-Dio.netty.machineId: 00:00:00:00:00:00:00:e0 (auto-detected)
2017-08-08T12:27:31.950 DEBUG [io.netty.util.ResourceLeakDetector] -
-Dio.netty.leakDetection.level: simple
2017-08-08T12:27:31.950 DEBUG [io.netty.util.ResourceLeakDetector] -
-Dio.netty.leakDetection.maxRecords: 4
2017-08-08T12:27:31.965 DEBUG [io.netty.buffer.PooledByteBufAllocator] -
-Dio.netty.allocator.numHeapArenas: 16
2017-08-08T12:27:31.965 DEBUG [io.netty.buffer.PooledByteBufAllocator] -
-Dio.netty.allocator.numDirectArenas: 16
2017-08-08T12:27:31.965 DEBUG [io.netty.buffer.PooledByteBufAllocator] -
-Dio.netty.allocator.pageSize: 8192
2017-08-08T12:27:31.965 DEBUG [io.netty.buffer.PooledByteBufAllocator] -
-Dio.netty.allocator.maxOrder: 11
2017-08-08T12:27:31.965 DEBUG [io.netty.buffer.PooledByteBufAllocator] -
-Dio.netty.allocator.chunkSize: 16777216
2017-08-08T12:27:31.965 DEBUG [io.netty.buffer.PooledByteBufAllocator] -
-Dio.netty.allocator.tinyCacheSize: 512
2017-08-08T12:27:31.965 DEBUG [io.netty.buffer.PooledByteBufAllocator] -
-Dio.netty.allocator.smallCacheSize: 256
2017-08-08T12:27:31.965 DEBUG [io.netty.buffer.PooledByteBufAllocator] -
-Dio.netty.allocator.normalCacheSize: 64
2017-08-08T12:27:31.965 DEBUG [io.netty.buffer.PooledByteBufAllocator] -
-Dio.netty.allocator.maxCachedBufferCapacity: 32768
2017-08-08T12:27:31.965 DEBUG [io.netty.buffer.PooledByteBufAllocator] -
-Dio.netty.allocator.cacheTrimInterval: 8192
2017-08-08T12:27:31.965 DEBUG [io.netty.buffer.PooledByteBufAllocator] -
-Dio.netty.allocator.useCacheForAllThreads: true
2017-08-08T12:27:31.972 DEBUG [io.netty.buffer.ByteBufUtil] -
-Dio.netty.allocator.type: pooled
2017-08-08T12:27:31.972 DEBUG [io.netty.buffer.ByteBufUtil] -
-Dio.netty.threadLocalDirectBufferSize:
65536
2017-08-08T12:27:31.972 DEBUG [io.netty.buffer.ByteBufUtil] -
-Dio.netty.maxThreadLocalCharBufferSize:
16384
2017-08-08T12:27:32.048 DEBUG [io.netty.util.Recycler] -
-Dio.netty.recycler.maxCapacityPerThread: 32768
2017-08-08T12:27:32.048 DEBUG [io.netty.util.Recycler] -
-Dio.netty.recycler.maxSharedCapacityFactor: 2
2017-08-08T12:27:32.048 DEBUG [io.netty.util.Recycler] -
-Dio.netty.recycler.linkCapacity: 16
2017-08-08T12:27:32.048 DEBUG [io.netty.util.Recycler] -
-Dio.netty.recycler.ratio: 8
2017-08-08T12:27:32.054 DEBUG [io.netty.buffer.AbstractByteBuf] -
-Dio.netty.buffer.bytebuf.checkAccessible: true
2017-08-08T12:27:32.055 DEBUG [io.netty.util.ResourceLeakDetectorFactory] -
Loaded default ResourceLeakDetector: io.netty.util.
ResourceLeakDetector@4fa0104d
2017-08-08T12:27:32.187 TRACE
[org.apache.qpid.jms.transports.netty.NettyTcpTransport]
- SSL Handshake has completed: [id: 0x9d1338b4, L:/10.251.135.241:61550 - R:
my-namespace.servicebus.windows.net/52.166.127.37:5671]
2017-08-08T12:27:32.187 TRACE
[org.apache.qpid.jms.transports.netty.NettyTcpTransport]
- Channel has become active! Channel is [id: 0x9d1338b4, L:/
10.251.135.241:61550 - R:my-namespace.servicebus.
windows.net/52.166.127.37:5671]
2017-08-08T12:27:32.188 DEBUG [io.netty.handler.ssl.SslHandler] - [id:
0x9d1338b4, L:/10.251.135.241:61550 - R:my-namespace.servicebus.
windows.net/52.166.127.37:5671] HANDSHAKEN: TLS_ECDHE_RSA_WITH_AES_128_
CBC_SHA256
2017-08-08T12:27:32.206 TRACE
[org.apache.qpid.jms.transports.netty.NettyTcpTransport]
- Attempted write of: 8 bytes
2017-08-08T12:27:32.231 TRACE
[org.apache.qpid.jms.transports.netty.NettyTcpTransport]
- New data read: 8 bytes incoming: PooledUnsafeDirectByteBuf(ridx: 0, widx:
8, cap: 69)
2017-08-08T12:27:32.232 TRACE [org.apache.qpid.jms.provider.amqp.AmqpProvider]
- New Proton Event: CONNECTION_INIT
2017-08-08T12:27:32.502 TRACE
[org.apache.qpid.jms.transports.netty.NettyTcpTransport]
- New data read: 63 bytes incoming: PooledUnsafeDirectByteBuf(ridx: 0,
widx: 63, cap: 117)
2017-08-08T12:27:32.509 DEBUG [org.apache.qpid.jms.sasl.SaslMechanismFinder]
- Unknown SASL mechanism: [MSSBCBS]
2017-08-08T12:27:32.522 DEBUG [org.apache.qpid.jms.sasl.SaslMechanismFinder]
- Skipping SASL-EXTERNAL mechanism because the available credentials are
not sufficient
2017-08-08T12:27:32.523 INFO [org.apache.qpid.jms.sasl.SaslMechanismFinder]
- Best match for SASL auth was: SASL-PLAIN
2017-08-08T12:27:32.525 TRACE
[org.apache.qpid.jms.transports.netty.NettyTcpTransport]
- Attempted write of: 119 bytes
2017-08-08T12:27:32.549 TRACE
[org.apache.qpid.jms.transports.netty.NettyTcpTransport]
- New data read: 26 bytes incoming: PooledUnsafeDirectByteBuf(ridx: 0,
widx: 26, cap: 85)
2017-08-08T12:27:32.550 TRACE
[org.apache.qpid.jms.transports.netty.NettyTcpTransport]
- Attempted write of: 8 bytes
2017-08-08T12:27:32.555 TRACE [org.apache.qpid.jms.util.MetaDataSupport] -
Problem generating primary version details
java.lang.NullPointerException
at java.util.regex.Matcher.getTextLength(Matcher.java:1283)
at java.util.regex.Matcher.reset(Matcher.java:309)
at java.util.regex.Matcher.<init>(Matcher.java:229)
at java.util.regex.Pattern.matcher(Pattern.java:1093)
at org.apache.qpid.jms.util.MetaDataSupport.<clinit>(
MetaDataSupport.java:47)
at org.apache.qpid.jms.provider.amqp.builders.AmqpConnectionBuilder.
createEndpoint(AmqpConnectionBuilder.java:113)
at org.apache.qpid.jms.provider.amqp.builders.AmqpConnectionBuilder.
createEndpoint(AmqpConnectionBuilder.java:45)
at org.apache.qpid.jms.provider.amqp.builders.AmqpResourceBuilder.
buildResource(AmqpResourceBuilder.java:76)
at org.apache.qpid.jms.provider.amqp.builders.AmqpConnectionBuilder.
buildResource(AmqpConnectionBuilder.java:55)
at org.apache.qpid.jms.provider.amqp.AmqpProvider$5$1.processConnectionInfo(
AmqpProvider.java:372)
at org.apache.qpid.jms.meta.JmsConnectionInfo.visit(
JmsConnectionInfo.java:417)
at org.apache.qpid.jms.provider.amqp.AmqpProvider$5.run(
AmqpProvider.java:331)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at java.util.concurrent.ScheduledThreadPoolExecutor$
ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(
ScheduledThreadPoolExecutor.java:293)
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:748)
[350616316:0] -> Open{ containerId='TestSubscriber', hostname='my-namespace.
servicebus.windows.net', maxFrameSize=1048576, channelMax=32767,
idleTimeOut=60000, outgoingLocales=null, incomingLocales=null,
offeredCapabilities=null, desiredCapabilities=[sole-connection-for-container],
properties={product=QpidJMS, version=0.23.0, platform=JVM: 1.8.0_131,
25.131-b11, Oracle Corporation, OS: Windows 7, 6.1, amd64}}
2017-08-08T12:27:32.565 TRACE [org.apache.qpid.jms.provider.amqp.FRAMES] -
SENT: Open{ containerId='TestSubscriber', hostname='my-namespace.
servicebus.windows.net', maxFrameSize=1048576, channelMax=32767,
idleTimeOut=60000, outgoingLocales=null, incomingLocales=null,
offeredCapabilities=null, desiredCapabilities=[sole-connection-for-container],
properties={product=QpidJMS, version=0.23.0, platform=JVM: 1.8.0_131,
25.131-b11, Oracle Corporation, OS: Windows 7, 6.1, amd64}}
2017-08-08T12:27:32.566 TRACE
[org.apache.qpid.jms.transports.netty.NettyTcpTransport]
- Attempted write of: 236 bytes
2017-08-08T12:27:32.574 TRACE
[org.apache.qpid.jms.transports.netty.NettyTcpTransport]
- New data read: 8 bytes incoming: PooledUnsafeDirectByteBuf(ridx: 0, widx:
8, cap: 69)
2017-08-08T12:27:32.574 TRACE [org.apache.qpid.jms.provider.amqp.AmqpProvider]
- New Proton Event: CONNECTION_LOCAL_OPEN
2017-08-08T12:27:32.803 TRACE
[org.apache.qpid.jms.transports.netty.NettyTcpTransport]
- New data read: 71 bytes incoming: PooledUnsafeDirectByteBuf(ridx: 0,
widx: 71, cap: 133)
[350616316:0] <- Open{ containerId='eddac23358584ea695974b0e0738b5cc_G28',
hostname='null', maxFrameSize=65536, channelMax=4999, idleTimeOut=240000,
outgoingLocales=null, incomingLocales=null, offeredCapabilities=null,
desiredCapabilities=null, properties=null}
2017-08-08T12:27:32.804 TRACE [org.apache.qpid.jms.provider.amqp.FRAMES] -
RECV: Open{ containerId='eddac23358584ea695974b0e0738b5cc_G28',
hostname='null', maxFrameSize=65536, channelMax=4999, idleTimeOut=240000,
outgoingLocales=null, incomingLocales=null, offeredCapabilities=null,
desiredCapabilities=null, properties=null}
2017-08-08T12:27:32.805 TRACE [org.apache.qpid.jms.provider.amqp.AmqpProvider]
- New Proton Event: CONNECTION_REMOTE_OPEN
2017-08-08T12:27:32.811 TRACE [org.apache.qpid.jms.provider.amqp.AmqpProvider]
- New Proton Event: SESSION_INIT
2017-08-08T12:27:32.812 TRACE [org.apache.qpid.jms.provider.amqp.AmqpProvider]
- New Proton Event: SESSION_LOCAL_OPEN
[350616316:0] -> Begin{remoteChannel=null, nextOutgoingId=1,
incomingWindow=2047, outgoingWindow=2147483647 <(214)%20748-3647>,
handleMax=65535, offeredCapabilities=null, desiredCapabilities=null,
properties=null}
2017-08-08T12:27:32.816 TRACE [org.apache.qpid.jms.provider.amqp.FRAMES] -
SENT: Begin{remoteChannel=null, nextOutgoingId=1, incomingWindow=2047,
outgoingWindow=2147483647 <(214)%20748-3647>, handleMax=65535,
offeredCapabilities=null, desiredCapabilities=null, properties=null}
2017-08-08T12:27:32.817 TRACE
[org.apache.qpid.jms.transports.netty.NettyTcpTransport]
- Attempted write of: 32 bytes
2017-08-08T12:27:32.841 TRACE
[org.apache.qpid.jms.transports.netty.NettyTcpTransport]
- New data read: 34 bytes incoming: PooledUnsafeDirectByteBuf(ridx: 0,
widx: 34, cap: 101)
[350616316:0] <- Begin{remoteChannel=0, nextOutgoingId=1,
incomingWindow=5000, outgoingWindow=2047, handleMax=255,
offeredCapabilities=null, desiredCapabilities=null, properties=null}
2017-08-08T12:27:32.842 TRACE [org.apache.qpid.jms.provider.amqp.FRAMES] -
RECV: Begin{remoteChannel=0, nextOutgoingId=1, incomingWindow=5000,
outgoingWindow=2047, handleMax=255, offeredCapabilities=null,
desiredCapabilities=null, properties=null}
2017-08-08T12:27:32.842 TRACE [org.apache.qpid.jms.provider.amqp.AmqpProvider]
- New Proton Event: SESSION_REMOTE_OPEN
2017-08-08T12:27:32.842 DEBUG
[org.apache.qpid.jms.provider.amqp.builders.AmqpConnectionBuilder]
- AmqpConnection { ID:5a68cd00-6948-46ff-9599-1b3803aaa73c:1 } is now open:
2017-08-08T12:27:32.842 TRACE [org.apache.qpid.jms.provider.amqp.AmqpProvider]
- IdleTimeoutCheck being initiated, initial delay: 120000
2017-08-08T12:27:32.843 INFO [org.apache.qpid.jms.JmsConnection] -
Connection ID:5a68cd00-6948-46ff-9599-1b3803aaa73c:1 connected to remote
Broker: amqps://my-namespace.servicebus.windows.net:5671?
amqp.idleTimeout=120000&amqp.traceFrames=true
<http://my-namespace.servicebus.windows.net:5671/?amqp.idleTimeout=120000&amqp.traceFrames=true>
[350616316:1] -> Begin{remoteChannel=null, nextOutgoingId=1,
incomingWindow=2047, outgoingWindow=2147483647 <(214)%20748-3647>,
handleMax=65535, offeredCapabilities=null, desiredCapabilities=null,
properties=null}
2017-08-08T12:27:32.859 TRACE [org.apache.qpid.jms.provider.amqp.FRAMES] -
SENT: Begin{remoteChannel=null, nextOutgoingId=1, incomingWindow=2047,
outgoingWindow=2147483647 <(214)%20748-3647>, handleMax=65535,
offeredCapabilities=null, desiredCapabilities=null, properties=null}
2017-08-08T12:27:32.859 TRACE
[org.apache.qpid.jms.transports.netty.NettyTcpTransport]
- Attempted write of: 32 bytes
2017-08-08T12:27:32.883 TRACE
[org.apache.qpid.jms.transports.netty.NettyTcpTransport]
- New data read: 34 bytes incoming: PooledUnsafeDirectByteBuf(ridx: 0,
widx: 34, cap: 101)
[350616316:1] <- Begin{remoteChannel=1, nextOutgoingId=1,
incomingWindow=5000, outgoingWindow=2047, handleMax=255,
offeredCapabilities=null, desiredCapabilities=null, properties=null}
2017-08-08T12:27:32.883 TRACE [org.apache.qpid.jms.provider.amqp.FRAMES] -
RECV: Begin{remoteChannel=1, nextOutgoingId=1, incomingWindow=5000,
outgoingWindow=2047, handleMax=255, offeredCapabilities=null,
desiredCapabilities=null, properties=null}
2017-08-08T12:27:32.884 TRACE [org.apache.qpid.jms.provider.amqp.AmqpProvider]
- New Proton Event: SESSION_INIT
2017-08-08T12:27:32.884 TRACE [org.apache.qpid.jms.provider.amqp.AmqpProvider]
- New Proton Event: SESSION_LOCAL_OPEN
2017-08-08T12:27:32.884 TRACE [org.apache.qpid.jms.provider.amqp.AmqpProvider]
- New Proton Event: SESSION_REMOTE_OPEN
[350616316:1] -> Attach{name='qpid-jms:receiver:ID:5a68cd00-6948-
46ff-9599-1b3803aaa73c:1:1:1:test.topic', handle=0, role=RECEIVER,
sndSettleMode=UNSETTLED, rcvSettleMode=FIRST,
source=Source{address='test.topic',
durable=NONE, expiryPolicy=LINK_DETACH, timeout=0, dynamic=false,
dynamicNodeProperties=null, distributionMode=null, filter=null,
defaultOutcome=Modified{deliveryFailed=true, undeliverableHere=null,
messageAnnotations=null}, outcomes=[amqp:accepted:list, amqp:rejected:list,
amqp:released:list, amqp:modified:list], capabilities=[topic]},
target=Target{address='null', durable=NONE, expiryPolicy=SESSION_END,
timeout=0, dynamic=false, dynamicNodeProperties=null, capabilities=null},
unsettled=null, incompleteUnsettled=false, initialDeliveryCount=null,
maxMessageSize=null, offeredCapabilities=null, desiredCapabilities=null,
properties=null}
2017-08-08T12:27:32.905 TRACE [org.apache.qpid.jms.provider.amqp.FRAMES] -
SENT: Attach{name='qpid-jms:receiver:ID:5a68cd00-6948-
46ff-9599-1b3803aaa73c:1:1:1:test.topic', handle=0, role=RECEIVER,
sndSettleMode=UNSETTLED, rcvSettleMode=FIRST,
source=Source{address='test.topic',
durable=NONE, expiryPolicy=LINK_DETACH, timeout=0, dynamic=false,
dynamicNodeProperties=null, distributionMode=null, filter=null,
defaultOutcome=Modified{deliveryFailed=true, undeliverableHere=null,
messageAnnotations=null}, outcomes=[amqp:accepted:list, amqp:rejected:list,
amqp:released:list, amqp:modified:list], capabilities=[topic]},
target=Target{address='null', durable=NONE, expiryPolicy=SESSION_END,
timeout=0, dynamic=false, dynamicNodeProperties=null, capabilities=null},
unsettled=null, incompleteUnsettled=false, initialDeliveryCount=null,
maxMessageSize=null, offeredCapabilities=null, desiredCapabilities=null,
properties=null}
2017-08-08T12:27:32.906 TRACE
[org.apache.qpid.jms.transports.netty.NettyTcpTransport]
- Attempted write of: 234 bytes
2017-08-08T12:27:33.395 TRACE
[org.apache.qpid.jms.transports.netty.NettyTcpTransport]
- New data read: 180 bytes incoming: PooledUnsafeDirectByteBuf(ridx: 0,
widx: 180, cap: 245)
[350616316:1] <- Attach{name='qpid-jms:receiver:ID:5a68cd00-6948-
46ff-9599-1b3803aaa73c:1:1:1:test.topic', handle=0, role=SENDER,
sndSettleMode=UNSETTLED, rcvSettleMode=FIRST, source=null, target=null,
unsettled=null, incompleteUnsettled=false, initialDeliveryCount=0,
maxMessageSize=266240, offeredCapabilities=null, desiredCapabilities=null,
properties={com.microsoft:tracking-id=eddac23358584ea695974b0e0738b5cc_G28}}
2017-08-08T12:27:33.396 TRACE [org.apache.qpid.jms.provider.amqp.FRAMES] -
RECV: Attach{name='qpid-jms:receiver:ID:5a68cd00-6948-
46ff-9599-1b3803aaa73c:1:1:1:test.topic', handle=0, role=SENDER,
sndSettleMode=UNSETTLED, rcvSettleMode=FIRST, source=null, target=null,
unsettled=null, incompleteUnsettled=false, initialDeliveryCount=0,
maxMessageSize=266240, offeredCapabilities=null, desiredCapabilities=null,
properties={com.microsoft:tracking-id=eddac23358584ea695974b0e0738b5cc_G28}}
2017-08-08T12:27:33.397 TRACE [org.apache.qpid.jms.provider.amqp.AmqpProvider]
- New Proton Event: LINK_INIT
2017-08-08T12:27:33.397 TRACE [org.apache.qpid.jms.provider.amqp.AmqpProvider]
- New Proton Event: LINK_LOCAL_OPEN
2017-08-08T12:27:33.397 TRACE [org.apache.qpid.jms.provider.amqp.AmqpProvider]
- New Proton Event: LINK_REMOTE_OPEN
2017-08-08T12:27:33.617 TRACE
[org.apache.qpid.jms.transports.netty.NettyTcpTransport]
- New data read: 509 bytes incoming: PooledUnsafeDirectByteBuf(ridx: 0,
widx: 509, cap: 565)
[350616316:1] <- Detach{handle=0, closed=true,
error=Error{condition=amqp:not-found,
description='The messaging entity 'my-namespace:topic:test.
topic~15|qpid-jms:receiver:ID:5a68cd00-6948-46ff-9599-1b3803aaa73c:1:1:1:test.topic'
could not be found. TrackingId:12ecc2a3-f8f3-42a3-8bd5-ad5d9823c367_B20,
SystemTracker:my-namespace:topic:test.topic~15|qpid-jms:
receiver:ID:5a68cd00-6948-46ff-9599-1b3803aaa73c:1:1:1:test.topic,
Timestamp:8/8/2017 10:27:32 AM TrackingId:eddac23358584ea695974b0e0738b5cc_G28,
SystemTracker:gateway6, Timestamp:8/8/2017 10:27:32 AM', info=null}}
2017-08-08T12:27:33.618 TRACE [org.apache.qpid.jms.provider.amqp.FRAMES] -
RECV: Detach{handle=0, closed=true, error=Error{condition=amqp:not-found,
description='The messaging entity 'my-namespace:topic:test.
topic~15|qpid-jms:receiver:ID:5a68cd00-6948-46ff-9599-1b3803aaa73c:1:1:1:test.topic'
could not be found. TrackingId:12ecc2a3-f8f3-42a3-8bd5-ad5d9823c367_B20,
SystemTracker:my-namespace:topic:test.topic~15|qpid-jms:
receiver:ID:5a68cd00-6948-46ff-9599-1b3803aaa73c:1:1:1:test.topic,
Timestamp:8/8/2017 10:27:32 AM TrackingId:eddac23358584ea695974b0e0738b5cc_G28,
SystemTracker:gateway6, Timestamp:8/8/2017 10:27:32 AM', info=null}}
2017-08-08T12:27:33.618 TRACE [org.apache.qpid.jms.provider.amqp.AmqpProvider]
- New Proton Event: LINK_REMOTE_CLOSE
2017-08-08T12:27:33.618 WARN
[org.apache.qpid.jms.provider.amqp.builders.AmqpResourceBuilder]
- Open of resource:(JmsConsumerInfo: {
ID:5a68cd00-6948-46ff-9599-1b3803aaa73c:1:1:1,
destination = test.topic }) failed: The messaging entity
'my-namespace:topic:test.topic~15|qpid-jms:receiver:ID:
5a68cd00-6948-46ff-9599-1b3803aaa73c:1:1:1:test.topic' could not be found.
TrackingId:12ecc2a3-f8f3-42a3-8bd5-ad5d9823c367_B20,
SystemTracker:my-namespace:topic:test.topic~15|qpid-jms:
receiver:ID:5a68cd00-6948-46ff-9599-1b3803aaa73c:1:1:1:test.topic,
Timestamp:8/8/2017 10:27:32 AM TrackingId:eddac23358584ea695974b0e0738b5cc_G28,
SystemTracker:gateway6, Timestamp:8/8/2017 10:27:32 AM [condition =
amqp:not-found]
2017-08-08T12:27:33.619 TRACE [org.apache.qpid.jms.provider.amqp.AmqpProvider]
- New Proton Event: LINK_LOCAL_CLOSE
[350616316:1] -> Detach{handle=0, closed=true, error=null}
2017-08-08T12:27:33.619 TRACE [org.apache.qpid.jms.provider.amqp.FRAMES] -
SENT: Detach{handle=0, closed=true, error=null}
2017-08-08T12:27:33.620 TRACE
[org.apache.qpid.jms.transports.netty.NettyTcpTransport]
- Attempted write of: 16 bytes
javax.jms.InvalidDestinationException: The messaging entity
'my-namespace:topic:test.topic~15|qpid-jms:receiver:ID:
5a68cd00-6948-46ff-9599-1b3803aaa73c:1:1:1:test.topic' could not be found.
TrackingId:12ecc2a3-f8f3-42a3-8bd5-ad5d9823c367_B20,
SystemTracker:my-namespace:topic:test.topic~15|qpid-jms:
receiver:ID:5a68cd00-6948-46ff-9599-1b3803aaa73c:1:1:1:test.topic,
Timestamp:8/8/2017 10:27:32 AM TrackingId:eddac23358584ea695974b0e0738b5cc_G28,
SystemTracker:gateway6, Timestamp:8/8/2017 10:27:32 AM [condition =
amqp:not-found]
at org.apache.qpid.jms.provider.amqp.AmqpSupport.convertToException(
AmqpSupport.java:150)
at org.apache.qpid.jms.provider.amqp.AmqpSupport.convertToException(
AmqpSupport.java:117)
at org.apache.qpid.jms.provider.amqp.builders.AmqpResourceBuilder.
handleClosed(AmqpResourceBuilder.java:185)
at org.apache.qpid.jms.provider.amqp.builders.AmqpResourceBuilder.
processRemoteClose(AmqpResourceBuilder.java:129)
at org.apache.qpid.jms.provider.amqp.AmqpProvider.
processUpdates(AmqpProvider.java:905)
at org.apache.qpid.jms.provider.amqp.AmqpProvider.access$1900(
AmqpProvider.java:93)
at org.apache.qpid.jms.provider.amqp.AmqpProvider$18.run(
AmqpProvider.java:791)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at java.util.concurrent.ScheduledThreadPoolExecutor$
ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(
ScheduledThreadPoolExecutor.java:293)
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:748)
2017-08-08T12:28:25.904 TRACE
[org.apache.qpid.jms.transports.netty.NettyTcpTransport]
- New data read: 8 bytes incoming: PooledUnsafeDirectByteBuf(ridx: 0, widx:
8, cap: 69)
[350616316:0] <- Empty Frame
2017-08-08T12:28:25.905 TRACE [org.apache.qpid.jms.provider.amqp.FRAMES] -
RECV: Empty Frame
2017-08-08T12:28:25.906 TRACE [org.apache.qpid.jms.provider.amqp.AmqpProvider]
- New Proton Event: LINK_FINAL
/ Joacim
On Tue, Aug 8, 2017 at 10:58 AM, 4 Integration <4i...@gmail.com>
wrote:
> Tested to change but the same error.
>
> //subscriber = subscriberSession.createDurableSubscriber(topic,
> "DurableSubscriber1");
> subscriber = subscriberSession.createConsumer(topic);
>
> In the exception - what is "~15" characters?
>
>
> javax.jms.InvalidDestinationException: The messaging entity
> 'my-namespace:topic:test.topic~15|qpid-jms:receiver:ID:
> 26eaaacf-965f-4d10-869f-f77b9dca5918:1:1:1:test.topic' could not be
> found. TrackingId:12ecc2a3-f8f3-42a3-8bd5-ad5d9823c367_B20,
> SystemTracker:my-namespace:topic:test.topic~15|qpid-jms:
> receiver:ID:26eaaacf-965f-4d10-869f-f77b9dca5918:1:1:1:test.topic,
> Timestamp:8/8/2017 8:51:31 AM TrackingId:eddac23358584ea695974b0e0738b5cc_G28,
> SystemTracker:gateway6, Timestamp:8/8/2017 8:51:31 AM [condition =
> amqp:not-found]
> at org.apache.qpid.jms.provider.amqp.AmqpSupport.convertToException(
> AmqpSupport.java:150)
> at org.apache.qpid.jms.provider.amqp.AmqpSupport.convertToException(
> AmqpSupport.java:117)
> at org.apache.qpid.jms.provider.amqp.builders.AmqpResourceBuilder.
> handleClosed(AmqpResourceBuilder.java:185)
> at org.apache.qpid.jms.provider.amqp.builders.AmqpResourceBuilder.
> processRemoteClose(AmqpResourceBuilder.java:129)
> at org.apache.qpid.jms.provider.amqp.AmqpProvider.
> processUpdates(AmqpProvider.java:905)
> at org.apache.qpid.jms.provider.amqp.AmqpProvider.access$1900(
> AmqpProvider.java:93)
> at org.apache.qpid.jms.provider.amqp.AmqpProvider$18.run(
> AmqpProvider.java:791)
> at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
> at java.util.concurrent.FutureTask.run(FutureTask.java:266)
> at java.util.concurrent.ScheduledThreadPoolExecutor$
> ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
> at java.util.concurrent.ScheduledThreadPoolExecutor$
> ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
> 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:748)
>
>
> / Joacim
>
>
>
> On Tue, Aug 8, 2017 at 10:10 AM, Gordon Sim <gs...@redhat.com> wrote:
>
>> Does a non-durable subscription work?
>>
>>
>> ---------------------------------------------------------------------
>> To unsubscribe, e-mail: users-unsubscribe@qpid.apache.org
>> For additional commands, e-mail: users-help@qpid.apache.org
>>
>>
>
Re: Create durable subscription to Azure Service Bus
Posted by 4 Integration <4i...@gmail.com>.
Tested to change but the same error.
//subscriber = subscriberSession.createDurableSubscriber(topic,
"DurableSubscriber1");
subscriber = subscriberSession.createConsumer(topic);
In the exception - what is "~15" characters?
javax.jms.InvalidDestinationException: The messaging entity
'my-namespace:topic:test.topic~15|qpid-jms:receiver:ID:26eaaacf-965f-4d10-869f-f77b9dca5918:1:1:1:test.topic'
could not be found. TrackingId:12ecc2a3-f8f3-42a3-8bd5-ad5d9823c367_B20,
SystemTracker:my-namespace:topic:test.topic~15|qpid-jms:receiver:ID:26eaaacf-965f-4d10-869f-f77b9dca5918:1:1:1:test.topic,
Timestamp:8/8/2017 8:51:31 AM
TrackingId:eddac23358584ea695974b0e0738b5cc_G28, SystemTracker:gateway6,
Timestamp:8/8/2017 8:51:31 AM [condition = amqp:not-found]
at
org.apache.qpid.jms.provider.amqp.AmqpSupport.convertToException(AmqpSupport.java:150)
at
org.apache.qpid.jms.provider.amqp.AmqpSupport.convertToException(AmqpSupport.java:117)
at
org.apache.qpid.jms.provider.amqp.builders.AmqpResourceBuilder.handleClosed(AmqpResourceBuilder.java:185)
at
org.apache.qpid.jms.provider.amqp.builders.AmqpResourceBuilder.processRemoteClose(AmqpResourceBuilder.java:129)
at
org.apache.qpid.jms.provider.amqp.AmqpProvider.processUpdates(AmqpProvider.java:905)
at
org.apache.qpid.jms.provider.amqp.AmqpProvider.access$1900(AmqpProvider.java:93)
at
org.apache.qpid.jms.provider.amqp.AmqpProvider$18.run(AmqpProvider.java:791)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
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:748)
/ Joacim
On Tue, Aug 8, 2017 at 10:10 AM, Gordon Sim <gs...@redhat.com> wrote:
> Does a non-durable subscription work?
>
>
> ---------------------------------------------------------------------
> To unsubscribe, e-mail: users-unsubscribe@qpid.apache.org
> For additional commands, e-mail: users-help@qpid.apache.org
>
>
Re: Create durable subscription to Azure Service Bus
Posted by Gordon Sim <gs...@redhat.com>.
Does a non-durable subscription work?
---------------------------------------------------------------------
To unsubscribe, e-mail: users-unsubscribe@qpid.apache.org
For additional commands, e-mail: users-help@qpid.apache.org
Re: Create durable subscription to Azure Service Bus
Posted by 4 Integration <4i...@gmail.com>.
Thanks, I have updated the source but still get the same error.
javax.jms.InvalidDestinationException: The messaging entity
'my-namespace:topic:test.topic~15|test1' could not be found.
TrackingId:12ecc2a3-f8f3-42a3-8bd5-ad5d9823c367_B20,
SystemTracker:my-namespace:topic:test.topic~15|test1, Timestamp:8/8/2017
7:15:35 AM TrackingId:5166f39a3069426ab4ee0ef86f084db6_G31,
SystemTracker:gateway6, Timestamp:8/8/2017 7:15:36 AM [condition =
amqp:not-found]
at
org.apache.qpid.jms.provider.amqp.AmqpSupport.convertToException(AmqpSupport.java:150)
at
org.apache.qpid.jms.provider.amqp.AmqpSupport.convertToException(AmqpSupport.java:117)
at
org.apache.qpid.jms.provider.amqp.builders.AmqpResourceBuilder.handleClosed(AmqpResourceBuilder.java:185)
at
org.apache.qpid.jms.provider.amqp.builders.AmqpResourceBuilder.processRemoteClose(AmqpResourceBuilder.java:129)
at
org.apache.qpid.jms.provider.amqp.AmqpProvider.processUpdates(AmqpProvider.java:905)
at
org.apache.qpid.jms.provider.amqp.AmqpProvider.access$1900(AmqpProvider.java:93)
at
org.apache.qpid.jms.provider.amqp.AmqpProvider$18.run(AmqpProvider.java:791)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
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:748)
Any suggestions?
*Updated source:*
import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.util.Hashtable;
import javax.jms.BytesMessage;
import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageConsumer;
import javax.jms.MessageListener;
import javax.jms.Session;
import javax.jms.Topic;
import javax.naming.Context;
import javax.naming.InitialContext;
public class AmqpJmsSubscriberApp {
private Connection connection;
private Session subscriberSession;
private MessageConsumer subscriber;
public AmqpJmsSubscriberApp() throws Exception {
Hashtable<String, String> env = new Hashtable<String, String>();
env.put(Context.INITIAL_CONTEXT_FACTORY,
"org.apache.qpid.jms.jndi.JmsInitialContextFactory");
//amqp://hostname:port[?option=value[&option2=value...]]
env.put("connectionfactory.SBCF", "amqps://
my-namespace.servicebus.windows.net:5671?jms.clientID=tester&amqp.idleTimeout=120000
");
env.put("topic.TOPIC", "test.topic");
Context context = new InitialContext(env);
ConnectionFactory connectionFactory = (ConnectionFactory)
context.lookup("SBCF");
Topic topic = (Topic) context.lookup("TOPIC");
connection = connectionFactory.createConnection("my-user",
"my-secret-key");
subscriberSession = connection.createSession(false,
Session.CLIENT_ACKNOWLEDGE);
subscriber = subscriberSession.createDurableSubscriber(topic,
"test1");
MessageListener messagelistener = new MessageListener()
{
public void onMessage(Message message)
{
try {
BytesMessage byteMsg = (BytesMessage)message;
byte[] byteArr = new byte[(int)byteMsg.getBodyLength()];
byteMsg.readBytes(byteArr);
String msg = new String(byteArr);
System.out.println("Received message with JMSMessageID =
" + message.getJMSMessageID());
System.out.println("You said " + msg);
message.acknowledge();
} catch (Exception e) {
e.printStackTrace();
}
}
};
subscriber.setMessageListener( messagelistener );
connection.start();
}
public static void main(String[] args) {
try {
AmqpJmsSubscriberApp simpleSubscriber = new AmqpJmsSubscriberApp();
System.out.println("Press [enter] to send a message. Type
'exit' + [enter] to quit.");
BufferedReader commandLine = new java.io.BufferedReader(new
InputStreamReader(System.in));
while (true) {
String s = commandLine.readLine();
if (s.equalsIgnoreCase("exit")) {
simpleSubscriber.close();
System.exit(0);
}
}
} catch (Exception e) {
e.printStackTrace();
}
}
public void close() throws JMSException {
connection.close();
}
}
/ Joacim
On Mon, Aug 7, 2017 at 3:34 PM, Timothy Bish <ta...@gmail.com> wrote:
> On 08/07/2017 09:26 AM, 4 Integration wrote:
>
>> Hi,
>>
>> Testing QPid JMS (AMQP v1.0) with Azure Service Bus (SB).
>>
>> Trying to get durable subscriptions to work.
>> I have created a topic in SB
>>
>> When starting my test app I get:
>>
>> javax.jms.JMSException: The messaging entity
>> 'mynamespace:topic:test.topic~15|test1' could not be found.
>> TrackingId:12ecc2a3-f8f3-42a3-8bd5-ad5d9823c367_B20,
>> SystemTracker:jjarkebo:topic:test.topic~15|test1, Timestamp:8/7/2017
>> 1:23:34 PM TrackingId:b1af76b2b7a44b95ad2bd0e01f406507_G20,
>> SystemTracker:gateway6, Timestamp:8/7/2017 1:23:34 PM
>> at
>> org.apache.qpid.amqp_1_0.jms.impl.TopicSubscriberImpl.create
>> ClientReceiver(TopicSubscriberImpl.java:111)
>> at
>> org.apache.qpid.amqp_1_0.jms.impl.MessageConsumerImpl.<init>
>> (MessageConsumerImpl.java:129)
>> at
>> org.apache.qpid.amqp_1_0.jms.impl.TopicSubscriberImpl.<init>
>> (TopicSubscriberImpl.java:46)
>> at
>> org.apache.qpid.amqp_1_0.jms.impl.SessionImpl.createDurableS
>> ubscriber(SessionImpl.java:544)
>> at
>> org.apache.qpid.amqp_1_0.jms.impl.SessionImpl.createDurableS
>> ubscriber(SessionImpl.java:512)
>> at
>> org.apache.qpid.amqp_1_0.jms.impl.SessionImpl.createDurableS
>> ubscriber(SessionImpl.java:59)
>> at com.vcrs.test.AmqpJmsSubscriberApp.<init>(AmqpJmsSubscriberA
>> pp.java:39)
>> at com.vcrs.test.AmqpJmsSubscriberApp.main(AmqpJmsSubscriberApp.java:67)
>>
>> Any ideas why this happen?
>> Do you have a working example?
>>
>> My test app code below
>>
>> import javax.jms.*;
>> import javax.naming.Context;
>> import javax.naming.InitialContext;
>>
>> import org.apache.qpid.amqp_1_0.jms.Connection;
>> import org.apache.qpid.amqp_1_0.jms.ConnectionFactory;
>> import org.apache.qpid.amqp_1_0.jms.Destination;
>> import org.apache.qpid.amqp_1_0.jms.MessageConsumer;
>> import org.apache.qpid.amqp_1_0.jms.MessageProducer;
>> import org.apache.qpid.amqp_1_0.jms.Session;
>>
>> import java.io.BufferedReader;
>> import java.io.InputStreamReader;
>> import java.util.Hashtable;
>> import java.util.Random;
>>
>> public class AmqpJmsSubscriberApp {
>> private Connection connection;
>> private Session subscriberSession;
>> private MessageConsumer subscriber;
>>
>> public AmqpJmsSubscriberApp() throws Exception {
>> Hashtable<String, String> env = new Hashtable<String, String>();
>> env.put(Context.INITIAL_CONTEXT_FACTORY,
>> "org.apache.qpid.amqp_1_0.jms.jndi.PropertiesFileInitialContextFactory");
>>
>> env.put("connectionfactory.SBCF", "amqps://
>> MyUser:MySecretKey@mynamespace.servicebus.windows.net:5671");
>> env.put("topic.TOPIC", "test.topic");
>>
>> Context context = new InitialContext(env);
>>
>> ConnectionFactory cf = (ConnectionFactory)
>> context.lookup("SBCF");
>> Topic topic = (Topic) context.lookup("TOPIC");
>>
>> connection = cf.createConnection();
>>
>> subscriberSession = connection.createSession(false,
>> Session.CLIENT_ACKNOWLEDGE);
>> subscriber = subscriberSession.createDurableSubscriber(topic,
>> "test1");
>>
>> MessageListener messagelistener = new MessageListener()
>> {
>> public void onMessage(Message message)
>> {
>> try {
>> BytesMessage byteMsg = (BytesMessage)message;
>>
>> byte[] byteArr = new byte[(int)byteMsg.getBodyLength()];
>> byteMsg.readBytes(byteArr);
>> String msg = new String(byteArr);
>>
>> System.out.println("Received message with
>> JMSMessageID =
>> " + message.getJMSMessageID());
>> System.out.println("You said " + msg);
>> message.acknowledge();
>> } catch (Exception e) {
>> e.printStackTrace();
>> }
>> }
>> };
>>
>> subscriber.setMessageListener( messagelistener );
>> connection.start();
>> }
>>
>> public static void main(String[] args) {
>> try {
>> AmqpJmsSubscriberApp simpleSubscriber = new
>> AmqpJmsSubscriberApp();
>> System.out.println("Press [enter] to send a message. Type
>> 'exit' + [enter] to quit.");
>> BufferedReader commandLine = new java.io.BufferedReader(new
>> InputStreamReader(System.in));
>>
>> while (true) {
>> String s = commandLine.readLine();
>> if (s.equalsIgnoreCase("exit")) {
>> simpleSubscriber.close();
>> System.exit(0);
>> }
>> }
>> } catch (Exception e) {
>> e.printStackTrace();
>> }
>> }
>>
>> public void close() throws JMSException {
>> connection.close();
>> }
>> }
>>
>> From the packages you're importing you are not using Qpid JMS but are
> using the legacy AMQP 1.0 JMS client which has not been supported in quite
> some time. You need to use the Qpid JMS client as documented here:
> http://qpid.apache.org/components/jms/index.html
>
> --
> Tim Bish
> twitter: @tabish121
> blog: http://timbish.blogspot.com/
>
>
> ---------------------------------------------------------------------
> To unsubscribe, e-mail: users-unsubscribe@qpid.apache.org
> For additional commands, e-mail: users-help@qpid.apache.org
>
>
Re: Create durable subscription to Azure Service Bus
Posted by Timothy Bish <ta...@gmail.com>.
On 08/07/2017 09:26 AM, 4 Integration wrote:
> Hi,
>
> Testing QPid JMS (AMQP v1.0) with Azure Service Bus (SB).
>
> Trying to get durable subscriptions to work.
> I have created a topic in SB
>
> When starting my test app I get:
>
> javax.jms.JMSException: The messaging entity
> 'mynamespace:topic:test.topic~15|test1' could not be found.
> TrackingId:12ecc2a3-f8f3-42a3-8bd5-ad5d9823c367_B20,
> SystemTracker:jjarkebo:topic:test.topic~15|test1, Timestamp:8/7/2017
> 1:23:34 PM TrackingId:b1af76b2b7a44b95ad2bd0e01f406507_G20,
> SystemTracker:gateway6, Timestamp:8/7/2017 1:23:34 PM
> at
> org.apache.qpid.amqp_1_0.jms.impl.TopicSubscriberImpl.createClientReceiver(TopicSubscriberImpl.java:111)
> at
> org.apache.qpid.amqp_1_0.jms.impl.MessageConsumerImpl.<init>(MessageConsumerImpl.java:129)
> at
> org.apache.qpid.amqp_1_0.jms.impl.TopicSubscriberImpl.<init>(TopicSubscriberImpl.java:46)
> at
> org.apache.qpid.amqp_1_0.jms.impl.SessionImpl.createDurableSubscriber(SessionImpl.java:544)
> at
> org.apache.qpid.amqp_1_0.jms.impl.SessionImpl.createDurableSubscriber(SessionImpl.java:512)
> at
> org.apache.qpid.amqp_1_0.jms.impl.SessionImpl.createDurableSubscriber(SessionImpl.java:59)
> at com.vcrs.test.AmqpJmsSubscriberApp.<init>(AmqpJmsSubscriberApp.java:39)
> at com.vcrs.test.AmqpJmsSubscriberApp.main(AmqpJmsSubscriberApp.java:67)
>
> Any ideas why this happen?
> Do you have a working example?
>
> My test app code below
>
> import javax.jms.*;
> import javax.naming.Context;
> import javax.naming.InitialContext;
>
> import org.apache.qpid.amqp_1_0.jms.Connection;
> import org.apache.qpid.amqp_1_0.jms.ConnectionFactory;
> import org.apache.qpid.amqp_1_0.jms.Destination;
> import org.apache.qpid.amqp_1_0.jms.MessageConsumer;
> import org.apache.qpid.amqp_1_0.jms.MessageProducer;
> import org.apache.qpid.amqp_1_0.jms.Session;
>
> import java.io.BufferedReader;
> import java.io.InputStreamReader;
> import java.util.Hashtable;
> import java.util.Random;
>
> public class AmqpJmsSubscriberApp {
> private Connection connection;
> private Session subscriberSession;
> private MessageConsumer subscriber;
>
> public AmqpJmsSubscriberApp() throws Exception {
> Hashtable<String, String> env = new Hashtable<String, String>();
> env.put(Context.INITIAL_CONTEXT_FACTORY,
> "org.apache.qpid.amqp_1_0.jms.jndi.PropertiesFileInitialContextFactory");
>
> env.put("connectionfactory.SBCF", "amqps://
> MyUser:MySecretKey@mynamespace.servicebus.windows.net:5671");
> env.put("topic.TOPIC", "test.topic");
>
> Context context = new InitialContext(env);
>
> ConnectionFactory cf = (ConnectionFactory) context.lookup("SBCF");
> Topic topic = (Topic) context.lookup("TOPIC");
>
> connection = cf.createConnection();
>
> subscriberSession = connection.createSession(false,
> Session.CLIENT_ACKNOWLEDGE);
> subscriber = subscriberSession.createDurableSubscriber(topic,
> "test1");
>
> MessageListener messagelistener = new MessageListener()
> {
> public void onMessage(Message message)
> {
> try {
> BytesMessage byteMsg = (BytesMessage)message;
>
> byte[] byteArr = new byte[(int)byteMsg.getBodyLength()];
> byteMsg.readBytes(byteArr);
> String msg = new String(byteArr);
>
> System.out.println("Received message with JMSMessageID =
> " + message.getJMSMessageID());
> System.out.println("You said " + msg);
> message.acknowledge();
> } catch (Exception e) {
> e.printStackTrace();
> }
> }
> };
>
> subscriber.setMessageListener( messagelistener );
> connection.start();
> }
>
> public static void main(String[] args) {
> try {
> AmqpJmsSubscriberApp simpleSubscriber = new AmqpJmsSubscriberApp();
> System.out.println("Press [enter] to send a message. Type
> 'exit' + [enter] to quit.");
> BufferedReader commandLine = new java.io.BufferedReader(new
> InputStreamReader(System.in));
>
> while (true) {
> String s = commandLine.readLine();
> if (s.equalsIgnoreCase("exit")) {
> simpleSubscriber.close();
> System.exit(0);
> }
> }
> } catch (Exception e) {
> e.printStackTrace();
> }
> }
>
> public void close() throws JMSException {
> connection.close();
> }
> }
>
From the packages you're importing you are not using Qpid JMS but are
using the legacy AMQP 1.0 JMS client which has not been supported in
quite some time. You need to use the Qpid JMS client as documented
here: http://qpid.apache.org/components/jms/index.html
--
Tim Bish
twitter: @tabish121
blog: http://timbish.blogspot.com/
---------------------------------------------------------------------
To unsubscribe, e-mail: users-unsubscribe@qpid.apache.org
For additional commands, e-mail: users-help@qpid.apache.org