Ethan C.-F. Chen created QPIDJMS-17:
---------------------------------------
Summary: MessageConsumerImpl construction error when
SessionImpl.createConsumer
Key: QPIDJMS-17
URL: https://issues.apache.org/jira/browse/QPIDJMS-17
Project: Qpid JMS
Issue Type: Bug
Environment: Windows 7 x64
Windows Azure Service Bus
javax.jms-api-2.0
qpid-amqp-1-0-client-0.26
qpid-amqp-1-0-client-jms-0.26
qpid-amqp-1-0-common-0.26
Reporter: Ethan C.-F. Chen
The definition is below
{code}
topic.atmosphere=atmosphere
{code}
but when create MessageConsumerImpl, in line #99-#109
the _isQueueConsumer will always true.
Client code:
{code}
Context context = new InitialContext(getJmsEnvironment());
ConnectionFactory connectionFactory =
(ConnectionFactory) context.lookup("azureServiceBusConnectionFactory");
Topic topic = (Topic) context.lookup("atmosphere");
Connection connection = connectionFactory.createConnection();
Session publisherSession = connection.createSession(
false, Session.AUTO_ACKNOWLEDGE);
Session consumerSession = connection.createSession(
false, Session.AUTO_ACKNOWLEDGE);
MessageProducer publisher =
publisherSession.createProducer(topic);
MessageConsumer consumer =
consumerSession.createConsumer(topic);
{code}
I guest it was cause by the DestinationImpl,
because the class declaration is
{code}
DestinationImpl implements Destination, Queue, Topic
{code}
so in the constructor of MessageConsumerImpl
{code}
if(destination instanceof javax.jms.Queue)
{code}
will always gets true
--
This message was sent by Atlassian JIRA
(v6.2#6252)
---------------------------------------------------------------------
To unsubscribe, e-mail: dev-unsubscr...@qpid.apache.org
For additional commands, e-mail: dev-h...@qpid.apache.org
