|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.codehaus.activemq.service.impl.PersistenceAdapterSupport
org.codehaus.activemq.store.journal.JournalPersistenceAdapter
An implementation of PersistenceAdapter
designed for
use with a Journal
and then checkpointing asynchronously
on a timeout with some other long term persistent storage.
Field Summary | |
(package private) ClockDaemon |
clockDaemon
|
Constructor Summary | |
JournalPersistenceAdapter()
|
|
JournalPersistenceAdapter(File directory,
PersistenceAdapter longTermPersistence,
DefaultWireFormat wireFormat)
|
Method Summary | |
void |
beginTransaction()
This method starts a transaction on the persistent storage - which is nothing to do with JMS or XA transactions - its purely a mechanism to perform multiple writes to a persistent store in 1 transaction as a performance optimisation. |
void |
commitTransaction()
Commit a persistence transaction |
PreparedTransactionStore |
createPreparedTransactionStore()
Factory method to create a new persistent prepared transaction store for XA recovery |
MessageStore |
createQueueMessageStore(String destinationName)
Factory method to create a new queue message store with the given destination name |
protected JMSException |
createRecoveryFailedException(Exception e)
|
TopicMessageStore |
createTopicMessageStore(String destinationName)
Factory method to create a new topic message store with the given destination name |
protected JMSException |
createWriteException(Packet packet,
Exception e)
|
protected JMSException |
createWriteException(String command,
Exception e)
|
ClockDaemon |
getClockDaemon()
|
File |
getDirectory()
|
Map |
getInitialDestinations()
Returns a map, indexed by String name, of all the Destination
objects active on startup. |
PersistenceAdapter |
getLongTermPersistence()
|
WireFormat |
getWireFormat()
|
boolean |
isSync()
|
static JournalPersistenceAdapter |
newInstance(File directory)
Factory method to create an instance using the defaults |
void |
overflowNotification(RecordLocation safeLocation)
The Journal give us a call back so that we can move old data out of the journal. |
Packet |
readPacket(RecordLocation location)
|
void |
rollbackTransaction()
Rollback a persistence transaction |
void |
setClockDaemon(ClockDaemon clockDaemon)
|
void |
setDirectory(File directory)
|
void |
setLongTermPersistence(PersistenceAdapter longTermPersistence)
|
void |
setSync(boolean sync)
|
void |
setWireFormat(WireFormat wireFormat)
|
void |
start()
Called to start the service |
void |
stop()
Called to shutdown the service |
RecordLocation |
writeCommand(String command,
boolean sync)
|
RecordLocation |
writePacket(String destination,
Packet packet,
boolean sync)
|
Methods inherited from class org.codehaus.activemq.service.impl.PersistenceAdapterSupport |
createQueueMessageContainer, createTopicMessageContainer |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
ClockDaemon clockDaemon
Constructor Detail |
public JournalPersistenceAdapter()
public JournalPersistenceAdapter(File directory, PersistenceAdapter longTermPersistence, DefaultWireFormat wireFormat) throws IOException
Method Detail |
public static JournalPersistenceAdapter newInstance(File directory) throws IOException, JMSException
directory
- the directory in which to store the persistent files
JMSException
IOException
public Map getInitialDestinations()
PersistenceAdapter
Destination
objects active on startup.
getInitialDestinations
in interface PersistenceAdapter
public MessageStore createQueueMessageStore(String destinationName) throws JMSException
PersistenceAdapter
createQueueMessageStore
in interface PersistenceAdapter
JMSException
public TopicMessageStore createTopicMessageStore(String destinationName) throws JMSException
PersistenceAdapter
createTopicMessageStore
in interface PersistenceAdapter
JMSException
public PreparedTransactionStore createPreparedTransactionStore() throws JMSException
PersistenceAdapter
createPreparedTransactionStore
in interface PersistenceAdapter
JMSException
public void beginTransaction() throws JMSException
PersistenceAdapter
beginTransaction
in interface PersistenceAdapter
JMSException
public void commitTransaction() throws JMSException
PersistenceAdapter
commitTransaction
in interface PersistenceAdapter
JMSException
PersistenceAdapter.beginTransaction()
public void rollbackTransaction()
PersistenceAdapter
rollbackTransaction
in interface PersistenceAdapter
PersistenceAdapter.beginTransaction()
public void start() throws JMSException
Service
start
in interface Service
JMSException
public void stop() throws JMSException
Service
stop
in interface Service
JMSException
public PersistenceAdapter getLongTermPersistence()
public void setLongTermPersistence(PersistenceAdapter longTermPersistence)
public File getDirectory()
public void setDirectory(File directory)
directory
- The directory to set.public boolean isSync()
public void setSync(boolean sync)
sync
- The sync to set.public WireFormat getWireFormat()
public void setWireFormat(WireFormat wireFormat)
wireFormat
- The wireFormat to set.public void overflowNotification(RecordLocation safeLocation)
overflowNotification
in interface JournalEventListener
safeLocation
- the oldest location that the journal recomends the mark to be set.JournalEventListener.overflowNotification(org.codehaus.activemq.journal.RecordLocation)
public RecordLocation writePacket(String destination, Packet packet, boolean sync) throws JMSException
sync
-
JMSException
public RecordLocation writeCommand(String command, boolean sync) throws JMSException
sync
-
JMSException
public Packet readPacket(RecordLocation location) throws JMSException
location
-
JMSException
protected JMSException createWriteException(Packet packet, Exception e)
protected JMSException createWriteException(String command, Exception e)
protected JMSException createRecoveryFailedException(Exception e)
public ClockDaemon getClockDaemon()
public void setClockDaemon(ClockDaemon clockDaemon)
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |