TTL set to 30 seconds, but messages are not getting expired.
I tried to test for TTL. But it is not working fine. I check messages @ "http://localhost:8161/admin";. Messages are not getting expired after specified time. public void SendMessage(IBusMessage busMessage) { if (!this.isDisposed) { IBytesMessage bytesMessage = this.session.CreateBytesMessage(); byte[] byteArray = HelperUtils.GetByteArrayWithObject(busMessage.GetSerializableMessage()); bytesMessage.Content = byteArray; bytesMessage.NMSTimeToLive = new TimeSpan(0, 0, 30); bytesMessage.NMSPersistent = true; this.producer.Send(bytesMessage); } } Please let me know if there is any other changes to be made. -- View this message in context: http://www.nabble.com/TTL-set-to-30-seconds%2C-but-messages-are-not-getting-expired.-tp25041966p25041966.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Re: TTL set to 30 seconds, but messages are not getting expired.
Thanks for replying. I tried with this line of code. but still messages are not getting expired. TimeSpan timeSpan = new TimeSpan(0, 0, 30); this.producer.Send(bytesMessage, true, 1, timeSpan); pshar...@sapient.com wrote: > > I tried to test for TTL. But it is not working fine. > I check messages @ "http://localhost:8161/admin";. Messages are not getting > expired after specified time. > > public void SendMessage(IBusMessage busMessage) > { > if (!this.isDisposed) > { > IBytesMessage bytesMessage = > this.session.CreateBytesMessage(); > byte[] byteArray = > HelperUtils.GetByteArrayWithObject(busMessage.GetSerializableMessage()); > bytesMessage.Content = byteArray; > bytesMessage.NMSTimeToLive = new TimeSpan(0, 0, 30); > bytesMessage.NMSPersistent = true; > this.producer.Send(bytesMessage); > } > } > > Please let me know if there is any other changes to be made. > -- View this message in context: http://www.nabble.com/TTL-set-to-30-seconds%2C-but-messages-are-not-getting-expired.-tp25041966p25043705.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.
initialRedeliveryDelay and maximumRedeliveries not working in "\progress\fuse-message-broker-5.3.0.4\conf\activemq.xml"
Hi, I have made below changes at "\progress\fuse-message-broker-5.3.0.4\conf\activemq.xml". 1. When it comes to redelivery of a message. It does not wait for 30 seconds. 2. And even maximumRedeliveries are not just 4. It is getting delivered unlimited. In code, I am using the session.commint and session.rollback. if (mapMessage.IsMessageDelivered) { this.session.Commit(); } else { Console.WriteLine("Error - returning message to topic.\r\n"); this.session.Rollback(); } Please let me know how can it start working. -- View this message in context: http://old.nabble.com/initialRedeliveryDelay-and-maximumRedeliveries-not-working-in-%22%5Cprogress%5Cfuse-message-broker-5.3.0.4%5Cconf%5Cactivemq.xml%22-tp27452192p27452192.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.
NMS client libraries Apache.NMS.ActiveMQ.dll and Apache.NMS.dll - Version 1.2.0
Hi, We are in the process of using Apache NMS dll's for implementing Transactional handling. In version 1.2.0, there is support of RedeliveryPolicy class. But as mentioned on website 'http://activemq.apache.org' - The NMS 1.2.0 Client Releases are still in progress. Can anyone please confirm on the release date for NMS 1.2.0 Client Releases. thanks, Praveen Sharma -- View this message in context: http://old.nabble.com/NMS-client-libraries-Apache.NMS.ActiveMQ.dll-and-Apache.NMS.dll---Version-1.2.0-tp27501076p27501076.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.