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] [Commented] (QPID-5742) MessageConsumerImpl construction error when SessionImpl.createConsumer
Date Fri, 02 May 2014 15:14:17 GMT

    [ https://issues.apache.org/jira/browse/QPID-5742?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13987775#comment-13987775
] 

Robbie Gemmell commented on QPID-5742:
--------------------------------------

Hi Ethan,

The JIRA project you reported this under is actually for a distinct client still under initial
development, I have moved this to the main QPID JIRA project which is used for the client
you are running.

Have you tried to reproduce your issue with the current trunk source, or 0.28 release candidate
(https://dist.apache.org/repos/dist/dev/qpid/0.28-rc1) ? I seem to recall something changing
in this area since 0.26 was released.

Regards,
Robbie

> 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