public static class JournalTransactionStore.Tx extends Object
Constructor and Description |
---|
JournalTransactionStore.Tx(org.apache.activeio.journal.RecordLocation location) |
Modifier and Type | Method and Description |
---|---|
void |
add(JournalMessageStore store,
org.apache.activemq.command.Message msg) |
void |
add(JournalMessageStore store,
org.apache.activemq.command.MessageAck ack) |
void |
add(JournalTopicMessageStore store,
org.apache.activemq.command.JournalTopicAck ack) |
org.apache.activemq.command.MessageAck[] |
getAcks() |
org.apache.activemq.command.Message[] |
getMessages() |
ArrayList<JournalTransactionStore.TxOperation> |
getOperations() |
public JournalTransactionStore.Tx(org.apache.activeio.journal.RecordLocation location)
public void add(JournalMessageStore store, org.apache.activemq.command.Message msg)
public void add(JournalMessageStore store, org.apache.activemq.command.MessageAck ack)
public void add(JournalTopicMessageStore store, org.apache.activemq.command.JournalTopicAck ack)
public org.apache.activemq.command.Message[] getMessages()
public org.apache.activemq.command.MessageAck[] getAcks()
public ArrayList<JournalTransactionStore.TxOperation> getOperations()
Copyright © 2005–2020 FuseSource, Corp.. All rights reserved.