Class DurableSubscriberStoreImpl

java.lang.Object

com.swiftmq.impl.store.standard.DurableSubscriberStoreImpl

All Implemented Interfaces:

com.swiftmq.swiftlet.store.DurableSubscriberStore, Iterator<com.swiftmq.swiftlet.store.DurableStoreEntry>

public class DurableSubscriberStoreImpl
extends Object
implements com.swiftmq.swiftlet.store.DurableSubscriberStore, Iterator<com.swiftmq.swiftlet.store.DurableStoreEntry>

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	DurableSubscriberStoreImpl(StoreContext ctx, String path)

Method Summary

Modifier and Type	Method	Description
void	close()
void	copy(String newPath)
void	deleteDurableStoreEntry(String clientId, String durableName)
static String	getDurableFilename(String clientId, String durableName)
com.swiftmq.swiftlet.store.DurableStoreEntry	getDurableStoreEntry(String clientId, String durableName)
boolean	hasNext()
void	insertDurableStoreEntry(com.swiftmq.swiftlet.store.DurableStoreEntry durableStoreEntry)
Iterator<com.swiftmq.swiftlet.store.DurableStoreEntry>	iterator()
DurableSubscriberStoreImpl	newInstance()
com.swiftmq.swiftlet.store.DurableStoreEntry	next()
void	remove()
String	toString()

Methods inherited from class Object

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

Methods inherited from interface Iterator

forEachRemaining

Constructor Details

DurableSubscriberStoreImpl

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

Throws:

com.swiftmq.swiftlet.store.StoreException

Method Details

getDurableFilename

public static String getDurableFilename(String clientId,
 String durableName)

newInstance

public DurableSubscriberStoreImpl newInstance()
                                       throws com.swiftmq.swiftlet.store.StoreException

Throws:

com.swiftmq.swiftlet.store.StoreException

iterator

public Iterator<com.swiftmq.swiftlet.store.DurableStoreEntry> iterator()

Specified by:

iterator in interface com.swiftmq.swiftlet.store.DurableSubscriberStore

hasNext

public boolean hasNext()

Specified by:

hasNext in interface Iterator<com.swiftmq.swiftlet.store.DurableStoreEntry>

next

public com.swiftmq.swiftlet.store.DurableStoreEntry next()

Specified by:

next in interface Iterator<com.swiftmq.swiftlet.store.DurableStoreEntry>

remove

public void remove()

Specified by:

remove in interface Iterator<com.swiftmq.swiftlet.store.DurableStoreEntry>

getDurableStoreEntry

public com.swiftmq.swiftlet.store.DurableStoreEntry getDurableStoreEntry(String clientId,
 String durableName)
                                                                  throws com.swiftmq.swiftlet.store.StoreException

Specified by:

getDurableStoreEntry in interface com.swiftmq.swiftlet.store.DurableSubscriberStore

Throws:

com.swiftmq.swiftlet.store.StoreException

insertDurableStoreEntry

public void insertDurableStoreEntry(com.swiftmq.swiftlet.store.DurableStoreEntry durableStoreEntry)
                             throws com.swiftmq.swiftlet.store.StoreException

Specified by:

insertDurableStoreEntry in interface com.swiftmq.swiftlet.store.DurableSubscriberStore

Throws:

com.swiftmq.swiftlet.store.StoreException

deleteDurableStoreEntry

public void deleteDurableStoreEntry(String clientId,
 String durableName)
                             throws com.swiftmq.swiftlet.store.StoreException

Specified by:

deleteDurableStoreEntry in interface com.swiftmq.swiftlet.store.DurableSubscriberStore

Throws:

com.swiftmq.swiftlet.store.StoreException

copy

public void copy(String newPath)
          throws Exception

Throws:

Exception

close

public void close()
           throws com.swiftmq.swiftlet.store.StoreException

Specified by:

close in interface com.swiftmq.swiftlet.store.DurableSubscriberStore

Throws:

com.swiftmq.swiftlet.store.StoreException

toString

public String toString()

Overrides:

toString in class Object