Details
Minor Description
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();