[
https://issues.apache.org/jira/browse/QPID-5219?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Keith Wall updated QPID-5219:
-----------------------------
Summary: Receiving message sent to topic specified with a binding url with
empty topic subscription kills dispatcher (was: Recieving message sent to
topic specified with a binding url with empty topic subscription kills
dispatcher)
> 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 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.
> {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
