[
https://issues.apache.org/jira/browse/QPID-5219?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Keith Wall updated QPID-5219:
-----------------------------
Description:
If I use the following in my JNDI properties
{code}
destination.mytopic= BURL:topic://amq.topic// # a destination with empty
topic subscription
{code}
I can successfully publish messages to the topic, but if I try and consume, the
#receive() call appears to hang. Turning on logging for o.a.q on the client
shows that the dispatcher thread has suffered an exception and has died whilst
it tried to create the JMS message.
"Topic Subscription" is as defined
https://cwiki.apache.org/confluence/display/qpid/BindingURLFormat#BindingURLFormat-Topics
{noformat}
2013-10-09 12:10:26,369 ERROR [Dispatcher-1-Conn-1] [BasicMessageConsumer]
Caught exception (dump follows) - ignoring...
java.lang.IllegalArgumentException: routing/binding key must not be null
at org.apache.qpid.client.AMQDestination.<init>(AMQDestination.java:338)
at org.apache.qpid.client.AMQDestination.<init>(AMQDestination.java:328)
at org.apache.qpid.client.AMQDestination.<init>(AMQDestination.java:322)
at org.apache.qpid.client.AMQTopic.<init>(AMQTopic.java:63)
at
org.apache.qpid.client.AMQSession_0_8$TopicDestinationCache.newDestination(AMQSession_0_8.java:876)
at
org.apache.qpid.client.AMQSession_0_8$TopicDestinationCache.newDestination(AMQSession_0_8.java:1)
at
org.apache.qpid.client.AMQSession_0_8$DestinationCache.getDestination(AMQSession_0_8.java:863)
at
org.apache.qpid.client.message.AMQMessageDelegate_0_8.<init>(AMQMessageDelegate_0_8.java:117)
at
org.apache.qpid.client.message.AbstractJMSMessageFactory.create08MessageWithBody(AbstractJMSMessageFactory.java:103)
at
org.apache.qpid.client.message.AbstractJMSMessageFactory.createMessage(AbstractJMSMessageFactory.java:160)
at
org.apache.qpid.client.message.MessageFactoryRegistry.createMessage(MessageFactoryRegistry.java:127)
at
org.apache.qpid.client.BasicMessageConsumer_0_8.createJMSMessageFromUnprocessedMessage(BasicMessageConsumer_0_8.java:118)
at
org.apache.qpid.client.BasicMessageConsumer_0_8.createJMSMessageFromUnprocessedMessage(BasicMessageConsumer_0_8.java:1)
at
org.apache.qpid.client.BasicMessageConsumer.notifyMessage(BasicMessageConsumer.java:712)
at
org.apache.qpid.client.AMQSession$Dispatcher.notifyConsumer(AMQSession.java:3388)
at
org.apache.qpid.client.AMQSession$Dispatcher.dispatchMessage(AMQSession.java:3327)
at
org.apache.qpid.client.AMQSession$Dispatcher.access$1(AMQSession.java:3290)
at org.apache.qpid.client.AMQSession.dispatch(AMQSession.java:3107)
at
org.apache.qpid.client.message.UnprocessedMessage.dispatch(UnprocessedMessage.java:54)
at
org.apache.qpid.client.AMQSession$Dispatcher.run(AMQSession.java:3250)
at java.lang.Thread.run(Thread.java:662)
{noformat}
was:
If I use the following in my JNDI properties
{code}
destination.mytopic= BURL:topic://amq.topic// # a destination with topic
subscription part empty
{code}
I can successfully publish messages to the topic, but if I try and consume, the
#receive() call appears to hang. Turning on logging for o.a.q on the client
shows that the dispatcher thread has suffered an exception and has died whilst
it tried to create the JMS message.
"Topic Subscription" is as defined
https://cwiki.apache.org/confluence/display/qpid/BindingURLFormat#BindingURLFormat-Topics
{noformat}
2013-10-09 12:10:26,369 ERROR [Dispatcher-1-Conn-1] [BasicMessageConsumer]
Caught exception (dump follows) - ignoring...
java.lang.IllegalArgumentException: routing/binding key must not be null
at org.apache.qpid.client.AMQDestination.<init>(AMQDestination.java:338)
at org.apache.qpid.client.AMQDestination.<init>(AMQDestination.java:328)
at org.apache.qpid.client.AMQDestination.<init>(AMQDestination.java:322)
at org.apache.qpid.client.AMQTopic.<init>(AMQTopic.java:63)
at
org.apache.qpid.client.AMQSession_0_8$TopicDestinationCache.newDestination(AMQSession_0_8.java:876)
at
org.apache.qpid.client.AMQSession_0_8$TopicDestinationCache.newDestination(AMQSession_0_8.java:1)
at
org.apache.qpid.client.AMQSession_0_8$DestinationCache.getDestination(AMQSession_0_8.java:863)
at
org.apache.qpid.client.message.AMQMessageDelegate_0_8.<init>(AMQMessageDelegate_0_8.java:117)
at
org.apache.qpid.client.message.AbstractJMSMessageFactory.create08MessageWithBody(AbstractJMSMessageFactory.java:103)
at
org.apache.qpid.client.message.AbstractJMSMessageFactory.createMessage(AbstractJMSMessageFactory.java:160)
at
org.apache.qpid.client.message.MessageFactoryRegistry.createMessage(MessageFactoryRegistry.java:127)
at
org.apache.qpid.client.BasicMessageConsumer_0_8.createJMSMessageFromUnprocessedMessage(BasicMessageConsumer_0_8.java:118)
at
org.apache.qpid.client.BasicMessageConsumer_0_8.createJMSMessageFromUnprocessedMessage(BasicMessageConsumer_0_8.java:1)
at
org.apache.qpid.client.BasicMessageConsumer.notifyMessage(BasicMessageConsumer.java:712)
at
org.apache.qpid.client.AMQSession$Dispatcher.notifyConsumer(AMQSession.java:3388)
at
org.apache.qpid.client.AMQSession$Dispatcher.dispatchMessage(AMQSession.java:3327)
at
org.apache.qpid.client.AMQSession$Dispatcher.access$1(AMQSession.java:3290)
at org.apache.qpid.client.AMQSession.dispatch(AMQSession.java:3107)
at
org.apache.qpid.client.message.UnprocessedMessage.dispatch(UnprocessedMessage.java:54)
at
org.apache.qpid.client.AMQSession$Dispatcher.run(AMQSession.java:3250)
at java.lang.Thread.run(Thread.java:662)
{noformat}
> Receiving message sent to topic specified with a binding url with empty topic
> subscription kills dispatcher
> -----------------------------------------------------------------------------------------------------------
>
> Key: QPID-5219
> URL: https://issues.apache.org/jira/browse/QPID-5219
> Project: Qpid
> Issue Type: Bug
> Components: Java Broker, Java Client
> Affects Versions: 0.25
> Reporter: Keith Wall
>
> If I use the following in my JNDI properties
> {code}
> destination.mytopic= BURL:topic://amq.topic// # a destination with empty
> topic subscription
> {code}
> I can successfully publish messages to the topic, but if I try and consume,
> the #receive() call appears to hang. Turning on logging for o.a.q on the
> client shows that the dispatcher thread has suffered an exception and has
> died whilst it tried to create the JMS message.
> "Topic Subscription" is as defined
> https://cwiki.apache.org/confluence/display/qpid/BindingURLFormat#BindingURLFormat-Topics
> {noformat}
> 2013-10-09 12:10:26,369 ERROR [Dispatcher-1-Conn-1] [BasicMessageConsumer]
> Caught exception (dump follows) - ignoring...
> java.lang.IllegalArgumentException: routing/binding key must not be null
> at org.apache.qpid.client.AMQDestination.<init>(AMQDestination.java:338)
> at org.apache.qpid.client.AMQDestination.<init>(AMQDestination.java:328)
> at org.apache.qpid.client.AMQDestination.<init>(AMQDestination.java:322)
> at org.apache.qpid.client.AMQTopic.<init>(AMQTopic.java:63)
> at
> org.apache.qpid.client.AMQSession_0_8$TopicDestinationCache.newDestination(AMQSession_0_8.java:876)
> at
> org.apache.qpid.client.AMQSession_0_8$TopicDestinationCache.newDestination(AMQSession_0_8.java:1)
> at
> org.apache.qpid.client.AMQSession_0_8$DestinationCache.getDestination(AMQSession_0_8.java:863)
> at
> org.apache.qpid.client.message.AMQMessageDelegate_0_8.<init>(AMQMessageDelegate_0_8.java:117)
> at
> org.apache.qpid.client.message.AbstractJMSMessageFactory.create08MessageWithBody(AbstractJMSMessageFactory.java:103)
> at
> org.apache.qpid.client.message.AbstractJMSMessageFactory.createMessage(AbstractJMSMessageFactory.java:160)
> at
> org.apache.qpid.client.message.MessageFactoryRegistry.createMessage(MessageFactoryRegistry.java:127)
> at
> org.apache.qpid.client.BasicMessageConsumer_0_8.createJMSMessageFromUnprocessedMessage(BasicMessageConsumer_0_8.java:118)
> at
> org.apache.qpid.client.BasicMessageConsumer_0_8.createJMSMessageFromUnprocessedMessage(BasicMessageConsumer_0_8.java:1)
> at
> org.apache.qpid.client.BasicMessageConsumer.notifyMessage(BasicMessageConsumer.java:712)
> at
> org.apache.qpid.client.AMQSession$Dispatcher.notifyConsumer(AMQSession.java:3388)
> at
> org.apache.qpid.client.AMQSession$Dispatcher.dispatchMessage(AMQSession.java:3327)
> at
> org.apache.qpid.client.AMQSession$Dispatcher.access$1(AMQSession.java:3290)
> at org.apache.qpid.client.AMQSession.dispatch(AMQSession.java:3107)
> at
> org.apache.qpid.client.message.UnprocessedMessage.dispatch(UnprocessedMessage.java:54)
> at
> org.apache.qpid.client.AMQSession$Dispatcher.run(AMQSession.java:3250)
> at java.lang.Thread.run(Thread.java:662)
> {noformat}
--
This message was sent by Atlassian JIRA
(v6.1#6144)
---------------------------------------------------------------------
To unsubscribe, e-mail: dev-unsubscr...@qpid.apache.org
For additional commands, e-mail: dev-h...@qpid.apache.org
