qpid-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Robbie Gemmell (JIRA)" <j...@apache.org>
Subject [jira] [Moved] (QPID-5742) MessageConsumerImpl construction error when SessionImpl.createConsumer
Date Fri, 02 May 2014 15:10:14 GMT

     [ 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


Mime
View raw message