You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@qpid.apache.org by "Robbie Gemmell (JIRA)" <ji...@apache.org> on 2014/05/02 17:10:14 UTC
[jira] [Moved] (QPID-5742) MessageConsumerImpl construction error
when SessionImpl.createConsumer
[ https://issues.apache.org/jira/browse/QPID-5742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Robbie Gemmell moved QPIDJMS-17 to QPID-5742:
---------------------------------------------
Workflow: QPid Workflow (was: classic default workflow)
Key: QPID-5742 (was: QPIDJMS-17)
Project: Qpid (was: Qpid JMS)
> MessageConsumerImpl construction error when SessionImpl.createConsumer
> ----------------------------------------------------------------------
>
> Key: QPID-5742
> URL: https://issues.apache.org/jira/browse/QPID-5742
> Project: Qpid
> 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-unsubscribe@qpid.apache.org
For additional commands, e-mail: dev-help@qpid.apache.org