Package com.swiftmq.impl.store.standard
Class DurableSubscriberStoreImpl
java.lang.Object
com.swiftmq.impl.store.standard.DurableSubscriberStoreImpl
- All Implemented Interfaces:
Iterator<DurableStoreEntry>
-
Constructor Summary
ModifierConstructorDescriptionprotected
DurableSubscriberStoreImpl
(StoreContext ctx, String path) -
Method Summary
Modifier and TypeMethodDescriptionvoid
close()
void
void
deleteDurableStoreEntry
(String clientId, String durableName) static String
getDurableFilename
(String clientId, String durableName) DurableStoreEntry
getDurableStoreEntry
(String clientId, String durableName) boolean
hasNext()
void
insertDurableStoreEntry
(DurableStoreEntry durableStoreEntry) Iterator<DurableStoreEntry>
iterator()
DurableStoreEntry
next()
void
remove()
toString()
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
Methods 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
-