[prev in list] [next in list] [prev in thread] [next in thread] 

List:       activemq-dev
Subject:    [jira] Commented: (AMQNET-181) ISession::CreateDurableConsumer does
From:       "Timothy Bish (JIRA)" <jira+amqnet () apache ! org>
Date:       2009-09-28 20:35:52
Message-ID: 1165420545.1254170152104.JavaMail.jira () brutus
[Download RAW message or body]


    [ https://issues.apache.org/activemq/browse/AMQNET-181?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=54543#action_54543 \
] 

Timothy Bish commented on AMQNET-181:
-------------------------------------

The problem here appears to be that the .NET client is setting the Subscription \
header in the Stomp command to "durable-subscriber-name" when the AMQ broker is \
expecting it to be "activemq.subscriptionName"

> ISession::CreateDurableConsumer does not work
> ---------------------------------------------
> 
> Key: AMQNET-181
> URL: https://issues.apache.org/activemq/browse/AMQNET-181
> Project: ActiveMQ .Net
> Issue Type: Bug
> Components: ActiveMQ
> Affects Versions: 1.1.0
> Environment: ActiveMQ .NET 1.1.0 Release
> Windows XP
> .NET 3.5
> Reporter: Alistair Young
> Assignee: Jim Gomes
> Priority: Minor
> Fix For: 1.2.0
> 
> 
> the following code results in a non durable subscription to the ActiveMQ topic with \
> an ActiveMQ generated consumer ID. Using the normal 61616 port and connection works \
> fine. using Apache.NMS;
> using Apache.NMS.ActiveMQ;
> using Apache.NMS.ActiveMQ.Commands;
> Uri connectURI = new \
> Uri("activemq:tcp://host.com:61613?transport.wireformat=stomp"); ConnectionFactory \
> connectionFactory = new ConnectionFactory(connectURI); IConnection connection = \
> connectionFactory.CreateConnection(); connection.ClientId = "DurableClientId";
> connection.Start();
> connection.ExceptionListener += new ExceptionListener(OnException);
> ISession session = connection.CreateSession(AcknowledgementMode.DupsOkAcknowledge);
> ActiveMQTopic topic = new ActiveMQTopic("test.t");
> IMessageConsumer consumer = session.CreateDurableConsumer(topic, "DurableClientId", \
> "2 > 1", false); consumer.Listener += new MessageListener(OnMessage);
> Console.WriteLine("Press any key to exit...");
> Console.ReadKey();

-- 
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.


[prev in list] [next in list] [prev in thread] [next in thread]