public Tx(RecordLocation location) 
{
            this.location = location;
}

 public  void add(JournalMessageStore store,
    Message msg) 
{
            operations.add(new TxOperation(TxOperation.ADD_OPERATION_TYPE, store, msg));
}

 public  void add(JournalMessageStore store,
    MessageAck ack) 
{
            operations.add(new TxOperation(TxOperation.REMOVE_OPERATION_TYPE, store, ack));
}

 public  void add(JournalTopicMessageStore store,
    JournalTopicAck ack) 
{
            operations.add(new TxOperation(TxOperation.ACK_OPERATION_TYPE, store, ack));
}

 public MessageAck[] getAcks() 
{
            ArrayList< Object > list = new ArrayList< Object >();
            for (Iterator< TxOperation > iter = operations.iterator(); iter.hasNext();) {
                TxOperation op = iter.next();
                if (op.operationType == TxOperation.REMOVE_OPERATION_TYPE) {
                    list.add(op.data);
                }
            }
            MessageAck rc[] = new MessageAck[list.size()];
            list.toArray(rc);
            return rc;
}

 public Message[] getMessages() 
{
            ArrayList< Object > list = new ArrayList< Object >();
            for (Iterator< TxOperation > iter = operations.iterator(); iter.hasNext();) {
                TxOperation op = iter.next();
                if (op.operationType == TxOperation.ADD_OPERATION_TYPE) {
                    list.add(op.data);
                }
            }
            Message rc[] = new Message[list.size()];
            list.toArray(rc);
            return rc;
}

 public ArrayList<TxOperation> getOperations() 
{
            return operations;
}