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

java.lang.Object
  extended by org.apache.activemq.store.kahadb.KahaDBTransactionStore.Tx
Enclosing class:
KahaDBTransactionStore

public class KahaDBTransactionStore.Tx
extends Object


Constructor Summary
KahaDBTransactionStore.Tx()
           
 
Method Summary
 void add(KahaDBTransactionStore.AddMessageCommand msg)
           
 void add(KahaDBTransactionStore.RemoveMessageCommand ack)
           
 List<Future<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 List<Future<Object>> commit()
                            throws IOException
Returns:
true if something to commit
Throws:
IOException


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