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:14:17 UTC

[jira] [Commented] (QPID-5742) MessageConsumerImpl construction error when SessionImpl.createConsumer

    [ 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