Package com.swiftmq.impl.store.standard
Class DurableSubscriberStoreImpl
java.lang.Object
com.swiftmq.impl.store.standard.DurableSubscriberStoreImpl
- All Implemented Interfaces:
Iterator<DurableStoreEntry>
-
Constructor Summary
ConstructorsModifierConstructorDescriptionprotectedDurableSubscriberStoreImpl(StoreContext ctx, String path) -
Method Summary
Modifier and TypeMethodDescriptionvoidclose()voidvoiddeleteDurableStoreEntry(String clientId, String durableName) static StringgetDurableFilename(String clientId, String durableName) DurableStoreEntrygetDurableStoreEntry(String clientId, String durableName) booleanhasNext()voidinsertDurableStoreEntry(DurableStoreEntry durableStoreEntry) Iterator<DurableStoreEntry>iterator()DurableStoreEntrynext()voidremove()toString()Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitMethods inherited from interface java.util.Iterator
forEachRemaining
-
Constructor Details
-
DurableSubscriberStoreImpl
- Throws:
StoreException
-
-
Method Details
-
getDurableFilename
-
newInstance
- Throws:
StoreException
-
iterator
-
hasNext
public boolean hasNext() -
next
public DurableStoreEntry next() -
remove
public void remove() -
getDurableStoreEntry
public DurableStoreEntry getDurableStoreEntry(String clientId, String durableName) throws StoreException - Throws:
StoreException
-
insertDurableStoreEntry
public void insertDurableStoreEntry(DurableStoreEntry durableStoreEntry) throws StoreException - Throws:
StoreException
-
deleteDurableStoreEntry
- Throws:
StoreException
-
copy
- Throws:
Exception
-
close
public void close() throws StoreException- Throws:
StoreException
-
toString
-