org.apache.activemq.store.kahadb
Class KahaDBTransactionStore.Tx

java.lang.Object
  org.apache.activemq.store.kahadb.KahaDBTransactionStore.Tx

Enclosing class:

KahaDBTransactionStore

public class KahaDBTransactionStore.Tx
extends java.lang.Object

Constructor Summary

KahaDBTransactionStore.Tx()

Method Summary

void	add(KahaDBTransactionStore.AddMessageCommand msg)
void	add(KahaDBTransactionStore.RemoveMessageCommand ack)
java.util.List<java.util.concurrent.Future<java.lang.Object>>	commit()
MessageAck[]	getAcks()
Message[]	getMessages()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

KahaDBTransactionStore.Tx

public KahaDBTransactionStore.Tx()

Method Detail

add

public void add(KahaDBTransactionStore.AddMessageCommand msg)

add

public void add(KahaDBTransactionStore.RemoveMessageCommand ack)

getMessages

public Message[] getMessages()

getAcks

public MessageAck[] getAcks()

commit

public java.util.List<java.util.concurrent.Future<java.lang.Object>> commit()
                                                                     throws java.io.IOException

Returns:

true if something to commit

Throws:

java.io.IOException