Overview  Package   Class  Use  Deprecated  Index
Home >> All >> org >> activemq >> store >> [ journal overview ]	PREV CLASS  NEXT CLASS
SUMMARY:  JAVADOC |  SOURCE |  DOWNLOAD | NESTED | FIELD | CONSTR | METHOD	DETAIL: FIELD | CONSTR | METHOD

---

org.activemq.store.journal
Class JournalTransactionStore  

java.lang.Object
  org.activemq.store.journal.JournalTransactionStore

All Implemented Interfaces:

org.activemq.service.Service, org.activemq.store.TransactionStore

---

public class JournalTransactionStore

extends java.lang.Object

implements org.activemq.store.TransactionStore

---

Nested Class Summary
static interface	JournalTransactionStore.AddMessageCommand
static interface	JournalTransactionStore.RemoveMessageCommand
static class	JournalTransactionStore.Tx           Operations
static class	JournalTransactionStore.TxOperation

 

Nested classes inherited from class org.activemq.store.TransactionStore

org.activemq.store.TransactionStore.RecoveryListener

 

Field Summary
(package private)  ConcurrentHashMap	inflightTransactions
private  JournalPersistenceAdapter	peristenceAdapter
(package private)  ConcurrentHashMap	preparedTransactions

 

Constructor Summary

JournalTransactionStore(JournalPersistenceAdapter adapter)

 

Method Summary
void	acknowledge(JournalTopicMessageStore store, JournalAck ack, RecordLocation location)
(package private)  void	addMessage(JournalMessageStore store, org.activemq.message.ActiveMQMessage message, RecordLocation location)
RecordLocation	checkpoint()
void	commit(java.lang.Object txid, boolean wasPrepared)
JournalTransactionStore.Tx	getTx(java.lang.Object txid, RecordLocation location)
void	prepare(java.lang.Object txid)
void	recover(org.activemq.store.TransactionStore.RecoveryListener listener)
void	removeMessage(JournalMessageStore store, org.activemq.message.MessageAck ack, RecordLocation location)
JournalTransactionStore.Tx	replayCommit(java.lang.Object txid, boolean wasPrepared)
void	replayPrepare(java.lang.Object txid)
void	replayRollback(java.lang.Object txid)
void	rollback(java.lang.Object txid)
void	start()           Called to start the service
void	stop()           Called to shutdown the service

 

Methods inherited from class java.lang.Object

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

 

Field Detail

peristenceAdapter

private final JournalPersistenceAdapter peristenceAdapter

---

inflightTransactions

ConcurrentHashMap inflightTransactions

---

preparedTransactions

ConcurrentHashMap preparedTransactions

Constructor Detail

JournalTransactionStore

public JournalTransactionStore(JournalPersistenceAdapter adapter)

Method Detail

prepare

public void prepare(java.lang.Object txid)
             throws javax.transaction.xa.XAException

Specified by:

prepare in interface org.activemq.store.TransactionStore

---

replayPrepare

public void replayPrepare(java.lang.Object txid)
                   throws java.io.IOException

---

getTx

public JournalTransactionStore.Tx getTx(java.lang.Object txid,
                                        RecordLocation location)

---

commit

public void commit(java.lang.Object txid,
                   boolean wasPrepared)
            throws javax.transaction.xa.XAException

Specified by:

commit in interface org.activemq.store.TransactionStore

---

replayCommit

public JournalTransactionStore.Tx replayCommit(java.lang.Object txid,
                                               boolean wasPrepared)
                                        throws java.io.IOException

---

rollback

public void rollback(java.lang.Object txid)
              throws javax.transaction.xa.XAException

Specified by:

rollback in interface org.activemq.store.TransactionStore

---

replayRollback

public void replayRollback(java.lang.Object txid)
                    throws java.io.IOException

---

recover

public void recover(org.activemq.store.TransactionStore.RecoveryListener listener)
             throws javax.transaction.xa.XAException

Specified by:

recover in interface org.activemq.store.TransactionStore

---

addMessage

void addMessage(JournalMessageStore store,
                org.activemq.message.ActiveMQMessage message,
                RecordLocation location)

---

removeMessage

public void removeMessage(JournalMessageStore store,
                          org.activemq.message.MessageAck ack,
                          RecordLocation location)

---

acknowledge

public void acknowledge(JournalTopicMessageStore store,
                        JournalAck ack,
                        RecordLocation location)

---

checkpoint

public RecordLocation checkpoint()
                          throws java.io.IOException

---

start

public void start()
           throws javax.jms.JMSException

Description copied from interface: org.activemq.service.Service

Called to start the service

Specified by:

start in interface org.activemq.service.Service

---

stop

public void stop()
          throws javax.jms.JMSException

Description copied from interface: org.activemq.service.Service

Called to shutdown the service

Specified by:

stop in interface org.activemq.service.Service

---

Overview  Package   Class  Use  Deprecated  Index
Home >> All >> org >> activemq >> store >> [ journal overview ]	PREV CLASS  NEXT CLASS
SUMMARY:  JAVADOC |  SOURCE |  DOWNLOAD | NESTED | FIELD | CONSTR | METHOD	DETAIL: FIELD | CONSTR | METHOD

---