Class StoreSwiftletImpl

java.lang.Object

com.swiftmq.swiftlet.Swiftlet

com.swiftmq.swiftlet.store.StoreSwiftlet

com.swiftmq.impl.store.standard.StoreSwiftletImpl

public class StoreSwiftletImpl
extends com.swiftmq.swiftlet.store.StoreSwiftlet

Field Summary

Fields inherited from class com.swiftmq.swiftlet.Swiftlet

STATE_ACTIVE, STATE_INACTIVE, STATE_STANDBY

Constructor Summary

Constructors

Constructor	Description
StoreSwiftletImpl()

Method Summary

Modifier and Type	Method	Description
com.swiftmq.swiftlet.store.CompositeStoreTransaction	createCompositeStoreTransaction()
protected DurableSubscriberStoreImpl	createDurableSubscriberStore(StoreContext ctx, String path)
protected LogManagerFactory	createLogManagerFactory()
protected com.swiftmq.swiftlet.store.NonPersistentStore	createNonPersistentStore(StoreContext ctx, String queueName, String swapPath, long swapMaxLength)
protected StableStore	createStableStore(StoreContext ctx, String path, int initialSize)
protected SwapFileFactory	createSwapFileFactory()
LogFile	createTxLogFile(String filename, String mode)
protected void	deleteSwaps()
void	flushCache()
com.swiftmq.swiftlet.store.DurableSubscriberStore	getDurableSubscriberStore()
com.swiftmq.swiftlet.store.NonPersistentStore	getNonPersistentStore(String queueName)
com.swiftmq.swiftlet.store.PersistentStore	getPersistentStore(String queueName)
List	getPrepareLogRecords()
void	removePrepareLogRecord(com.swiftmq.swiftlet.store.PrepareLogRecord record)
protected void	shutdown()	Shutdown the swiftlet.
void	startStore(boolean withRecovery)
protected void	startup(com.swiftmq.mgmt.Configuration config)
void	stopStore()

Methods inherited from class com.swiftmq.swiftlet.Swiftlet

getName, getStartupTime, getState, isSnapshotAvailable, resume, setStartupTime, standby

Methods inherited from class Object

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

Constructor Details

StoreSwiftletImpl

public StoreSwiftletImpl()

Method Details

getPersistentStore

public com.swiftmq.swiftlet.store.PersistentStore getPersistentStore(String queueName)
                                                              throws com.swiftmq.swiftlet.store.StoreException

Specified by:

getPersistentStore in class com.swiftmq.swiftlet.store.StoreSwiftlet

Throws:

com.swiftmq.swiftlet.store.StoreException

getNonPersistentStore

public com.swiftmq.swiftlet.store.NonPersistentStore getNonPersistentStore(String queueName)
                                                                    throws com.swiftmq.swiftlet.store.StoreException

Specified by:

getNonPersistentStore in class com.swiftmq.swiftlet.store.StoreSwiftlet

Throws:

com.swiftmq.swiftlet.store.StoreException

getDurableSubscriberStore

public com.swiftmq.swiftlet.store.DurableSubscriberStore getDurableSubscriberStore()
                                                                            throws com.swiftmq.swiftlet.store.StoreException

Specified by:

getDurableSubscriberStore in class com.swiftmq.swiftlet.store.StoreSwiftlet

Throws:

com.swiftmq.swiftlet.store.StoreException

getPrepareLogRecords

public List getPrepareLogRecords()
                          throws com.swiftmq.swiftlet.store.StoreException

Specified by:

getPrepareLogRecords in class com.swiftmq.swiftlet.store.StoreSwiftlet

Throws:

com.swiftmq.swiftlet.store.StoreException

removePrepareLogRecord

public void removePrepareLogRecord(com.swiftmq.swiftlet.store.PrepareLogRecord record)
                            throws com.swiftmq.swiftlet.store.StoreException

Specified by:

removePrepareLogRecord in class com.swiftmq.swiftlet.store.StoreSwiftlet

Throws:

com.swiftmq.swiftlet.store.StoreException

createCompositeStoreTransaction

public com.swiftmq.swiftlet.store.CompositeStoreTransaction createCompositeStoreTransaction()

Specified by:

createCompositeStoreTransaction in class com.swiftmq.swiftlet.store.StoreSwiftlet

flushCache

public void flushCache()

deleteSwaps

protected void deleteSwaps()

createNonPersistentStore

protected com.swiftmq.swiftlet.store.NonPersistentStore createNonPersistentStore(StoreContext ctx,
 String queueName,
 String swapPath,
 long swapMaxLength)

createStableStore

protected StableStore createStableStore(StoreContext ctx,
 String path,
 int initialSize)
                                 throws Exception

Throws:

Exception

createDurableSubscriberStore

protected DurableSubscriberStoreImpl createDurableSubscriberStore(StoreContext ctx,
 String path)
                                                           throws com.swiftmq.swiftlet.store.StoreException

Throws:

com.swiftmq.swiftlet.store.StoreException

createTxLogFile

public LogFile createTxLogFile(String filename,
 String mode)
                        throws Exception

Throws:

Exception

createSwapFileFactory

protected SwapFileFactory createSwapFileFactory()

createLogManagerFactory

protected LogManagerFactory createLogManagerFactory()

startStore

public void startStore(boolean withRecovery)
                throws Exception

Throws:

Exception

stopStore

public void stopStore()
               throws Exception

Throws:

Exception

startup

protected void startup(com.swiftmq.mgmt.Configuration config)
                throws com.swiftmq.swiftlet.SwiftletException

Specified by:

startup in class com.swiftmq.swiftlet.Swiftlet

Throws:

com.swiftmq.swiftlet.SwiftletException

shutdown

protected void shutdown()
                 throws com.swiftmq.swiftlet.SwiftletException

Shutdown the swiftlet. Check if all shutdown conditions are met. Do shutdown work (i. e. stop working thread, close resources). If any condition prevends from shutdown fire a SwiftletException.

Specified by:

shutdown in class com.swiftmq.swiftlet.Swiftlet

Throws:

com.swiftmq.swiftlet.SwiftletException