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

Modifier and Type	Method	Description
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 List<MemoryTransactionStore.AddMessageCommand> messages

acks

public final List<MemoryTransactionStore.RemoveMessageCommand> acks

Constructor Detail

Tx

public 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