org.apache.activemq.store.memory
Class MemoryTransactionStore.Tx

java.lang.Object
  extended by org.apache.activemq.store.memory.MemoryTransactionStore.Tx
Enclosing class:
MemoryTransactionStore

public class MemoryTransactionStore.Tx
extends Object


Field Summary
 ArrayList<MemoryTransactionStore.RemoveMessageCommand> acks
           
 ArrayList<MemoryTransactionStore.AddMessageCommand> messages
           
 
Constructor Summary
MemoryTransactionStore.Tx()
           
 
Method Summary
 void add(MemoryTransactionStore.AddMessageCommand msg)
           
 void add(MemoryTransactionStore.RemoveMessageCommand ack)
           
 void commit()
           
 MessageAck[] getAcks()
           
 Message[] getMessages()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

messages

public ArrayList<MemoryTransactionStore.AddMessageCommand> messages

acks

public final ArrayList<MemoryTransactionStore.RemoveMessageCommand> acks
Constructor Detail

MemoryTransactionStore.Tx

public MemoryTransactionStore.Tx()
Method Detail

add

public void add(MemoryTransactionStore.AddMessageCommand msg)

add

public void add(MemoryTransactionStore.RemoveMessageCommand ack)

getMessages

public Message[] getMessages()

getAcks

public MessageAck[] getAcks()

commit

public void commit()
            throws IOException
Throws:
IOException


Copyright © 2005-2012 The Apache Software Foundation. All Rights Reserved.