activemq-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Alistair Young (JIRA)" <jira+amq...@apache.org>
Subject [jira] Created: (AMQNET-181) ISession::CreateDurableConsumer does not work
Date Thu, 20 Aug 2009 13:50:35 GMT
ISession::CreateDurableConsumer does not work
---------------------------------------------

                 Key: AMQNET-181
                 URL: https://issues.apache.org/activemq/browse/AMQNET-181
             Project: ActiveMQ .Net
          Issue Type: Bug
          Components: Stomp
    Affects Versions: 1.1.0
         Environment: ActiveMQ .NET 1.1.0 Release
Windows XP
.NET 3.5
            Reporter: Alistair Young
            Assignee: Jim Gomes
             Fix For: 1.1.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.


Mime
View raw message