MessageMetaData mmd = msg.headersReceived();
msg.setStoredMessage(_messageStore.addMessage(mmd));
if(msg.allContentReceived())
{
ServerTransaction txn = new AutoCommitTransaction(_messageStore);
txn.enqueue(_queue, msg, new ServerTransaction.Action() {
public void postCommit()
{
try
{
_queue.enqueue(new AMQMessage(msg.getStoredMessage()));