AcknowledgedMessagesSessionExtension extension = new AcknowledgedMessagesSessionExtension(session);
// Make sure that adding the extension and importing the queue is atomic.
synchronized (session.getLock())
{
session.addExtension(extension);
extension.importMessages(session);
}
}
Map<String, Object> sndExt = message.getExt(true);