activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Alistair Young <alistair.yo...@uhi.ac.uk>
Subject NMS durable consumer not durable
Date Thu, 20 Aug 2009 09:24:30 GMT
I know the topic has persistent messages as the ActiveMQCPP stuff  
works ok, picking up messages it's missed. The NMS one doesn't though:

Uri connectURI = new Uri("activemq:tcp://host.com:61613? 
transport.wireformat=stomp");
IConnectionFactory factory = new ConnectionFactory(connectURI, "test- 
client-id");
IConnection connection = factory.CreateConnection();
connection.Start();
ISession session =  
connection.CreateSession(AcknowledgementMode.AutoAcknowledge);
ActiveMQTopic topic = new ActiveMQTopic("test.t");
IMessageConsumer consumer = session.CreateDurableConsumer(topic, "test- 
client-id", null, true);

it only picks up messages while it's connected. It doesn't pick up  
ones that it missed while it was offline.

Alistair



-- 
mov eax,1
mov ebx,0
int 80h





Mime
View raw message