TTL set to 30 seconds, but messages are not getting expired.

2009-08-19 Thread pshar...@sapient.com

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.

2009-08-19 Thread pshar...@sapient.com

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"

2010-02-04 Thread pshar...@sapient.com

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

2010-02-08 Thread pshar...@sapient.com

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.