Package com.swiftmq.impl.store.standard

Class StoreSwiftletImpl

java.lang.Object

StoreSwiftlet

com.swiftmq.impl.store.standard.StoreSwiftletImpl

public class StoreSwiftletImpl
extends StoreSwiftlet

Constructor Summary

Constructors

Constructor	Description
StoreSwiftletImpl()

Method Summary

Modifier and Type	Method	Description
CompositeStoreTransaction	createCompositeStoreTransaction()
protected DurableSubscriberStoreImpl	createDurableSubscriberStore(StoreContext ctx, String path)
protected LogManagerFactory	createLogManagerFactory()
protected 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()
DurableSubscriberStore	getDurableSubscriberStore()
NonPersistentStore	getNonPersistentStore(String queueName)
PersistentStore	getPersistentStore(String queueName)
List	getPrepareLogRecords()
void	removePrepareLogRecord(PrepareLogRecord record)
protected void	shutdown()	Shutdown the swiftlet.
void	startStore(boolean withRecovery)
protected void	startup(Configuration config)
void	stopStore()

Methods inherited from class java.lang.Object

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

Constructor Details

StoreSwiftletImpl

public StoreSwiftletImpl()

Method Details

getPersistentStore

public PersistentStore getPersistentStore(String queueName)
                                   throws StoreException

Throws:

StoreException

getNonPersistentStore

public NonPersistentStore getNonPersistentStore(String queueName)
                                         throws StoreException

Throws:

StoreException

getDurableSubscriberStore

public DurableSubscriberStore getDurableSubscriberStore()
                                                 throws StoreException

Throws:

StoreException

getPrepareLogRecords

public List getPrepareLogRecords()
                          throws StoreException

Throws:

StoreException

removePrepareLogRecord

public void removePrepareLogRecord(PrepareLogRecord record)
                            throws StoreException

Throws:

StoreException

createCompositeStoreTransaction

public CompositeStoreTransaction createCompositeStoreTransaction()

flushCache

public void flushCache()

deleteSwaps

protected void deleteSwaps()

createNonPersistentStore

protected 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 StoreException

Throws:

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(Configuration config)
                throws SwiftletException

Throws:

SwiftletException

shutdown

protected void shutdown()
                 throws 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.

Throws:

com.swiftmq.swiftlet.SwiftletException

SwiftletException