public class MemoryTransactionStore.Tx
extends java.lang.Object
| Modifier and Type | Field and Description |
|---|---|
java.util.ArrayList<MemoryTransactionStore.RemoveMessageCommand> |
acks |
java.util.ArrayList<MemoryTransactionStore.AddMessageCommand> |
messages |
| Constructor and Description |
|---|
MemoryTransactionStore.Tx() |
| Modifier and Type | Method and Description |
|---|---|
void |
add(MemoryTransactionStore.AddMessageCommand msg) |
void |
add(MemoryTransactionStore.RemoveMessageCommand ack) |
void |
commit() |
MessageAck[] |
getAcks() |
Message[] |
getMessages() |
public java.util.ArrayList<MemoryTransactionStore.AddMessageCommand> messages
public final java.util.ArrayList<MemoryTransactionStore.RemoveMessageCommand> acks
public void add(MemoryTransactionStore.AddMessageCommand msg)
public void add(MemoryTransactionStore.RemoveMessageCommand ack)
public Message[] getMessages()
public MessageAck[] getAcks()
public void commit()
throws java.io.IOException
java.io.IOExceptionCopyright © 2005-2013 Red Hat, Inc.. All Rights Reserved.