Hi all,

To make queues durable,

queueSession.createQueue(queueName + ";{create:always, node:{durable:
True}}");

And small fix needed at Qpid as follows.

In class org.apache.qpid.client.messaging.address.AddressHelper class

 private boolean getDurability(Map map) {
        if (map != null && map.get(DURABLE) != null) {
//            return Boolean.parseBoolean((String)map.get(DURABLE));
          return (Boolean) map.get(DURABLE);
        } else {
            return false;
        }
    }

This way, SQS queues are durable now.

Thank you.

-- 
Manjula Rathnayaka
Software Engineer
WSO2, Inc.
Mobile:+94 77 743 1987
_______________________________________________
Carbon-dev mailing list
[email protected]
http://mail.wso2.org/cgi-bin/mailman/listinfo/carbon-dev

Reply via email to