Package org.apache.activemq.store.memory
Class MemoryTransactionStore.Tx
- java.lang.Object
-
- org.apache.activemq.store.memory.MemoryTransactionStore.Tx
-
- Enclosing class:
- MemoryTransactionStore
public class MemoryTransactionStore.Tx extends Object
-
-
Field Summary
Fields Modifier and Type Field Description List<MemoryTransactionStore.RemoveMessageCommand>
acks
List<MemoryTransactionStore.AddMessageCommand>
messages
-
Constructor Summary
Constructors Constructor Description Tx()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
add(MemoryTransactionStore.AddMessageCommand msg)
void
add(MemoryTransactionStore.RemoveMessageCommand ack)
void
commit()
MessageAck[]
getAcks()
Message[]
getMessages()
-
-
-
Field Detail
-
messages
public List<MemoryTransactionStore.AddMessageCommand> messages
-
acks
public final List<MemoryTransactionStore.RemoveMessageCommand> acks
-
-
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
-
-