|
xmlBlaster 2.2.0 client API | |||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use I_Storage | |
---|---|
org.xmlBlaster.util.queue | |
org.xmlBlaster.util.queue.cache | |
org.xmlBlaster.util.queue.jdbc | |
org.xmlBlaster.util.queue.ram |
Uses of I_Storage in org.xmlBlaster.util.queue |
---|
Subinterfaces of I_Storage in org.xmlBlaster.util.queue | |
---|---|
interface |
I_Queue
The Interface which all queues (persistent queues and cache queues) must implement. |
Methods in org.xmlBlaster.util.queue with parameters of type I_Storage | |
---|---|
void |
I_StorageSizeListener.changed(I_Storage queue,
long numEntries,
long numBytes,
boolean isShutdown)
This event is sent every time a change in entries has occurred in the queue. |
void |
BlockingQueueWrapper.changed(I_Storage storage,
long numEntries,
long numBytes,
boolean isShutdown)
Enforced by I_StorageSizeListener. |
void |
EventHelper.changed(I_Storage storage,
long numEntries,
long numBytes,
boolean isShutdown)
Enforced by I_StorageSizeListener |
void |
QueuePluginManager.cleanup(I_Storage storage)
|
EventHelper |
EventHelper.getCopy(I_Storage storage)
|
I_Entry |
I_EntryFilter.intercept(I_Entry entry,
I_Storage storage)
Invoked by the I_Map or I_Queue implementation when entries are read from the store. |
void |
StorageEventHandler.registerListener(I_Storage storage)
|
void |
StorageEventHandler.removeListener(I_Storage storage)
|
Constructors in org.xmlBlaster.util.queue with parameters of type I_Storage | |
---|---|
StorageSizeListenerHelper(I_Storage storage)
|
Uses of I_Storage in org.xmlBlaster.util.queue.cache |
---|
Classes in org.xmlBlaster.util.queue.cache that implement I_Storage | |
---|---|
class |
CacheQueueInterceptorPlugin
Implements a queue cache. |
Uses of I_Storage in org.xmlBlaster.util.queue.jdbc |
---|
Classes in org.xmlBlaster.util.queue.jdbc that implement I_Storage | |
---|---|
class |
JdbcQueue
Persistence queue implementation on a DB based on JDBC. |
class |
JdbcQueueCommonTablePlugin
Persistence queue implementation on a DB based on JDBC. |
Methods in org.xmlBlaster.util.queue.jdbc with parameters of type I_Storage | |
---|---|
ReturnDataHolder |
XBDatabaseAccessorDelegate.getAndDeleteLowest(XBStore store,
int numOfEntries,
long numOfBytes,
int maxPriority,
long minUniqueId,
boolean leaveOne,
boolean doDelete,
I_Storage storage)
|
ReturnDataHolder |
XBDatabaseAccessor.getAndDeleteLowest(XBStore store,
int numOfEntries,
long numOfBytes,
int maxPriority,
long minUniqueId,
boolean leaveOne,
boolean doDelete,
I_Storage storage)
Under the same transaction it gets and deletes all the entries which fit into the constrains specified in the argument list. |
java.util.List<I_Entry> |
XBDatabaseAccessorDelegate.getEntries(XBStore store,
int numOfEntries,
long numOfBytes,
I_EntryFilter entryFilter,
boolean isRef,
I_Storage storage)
|
java.util.List<I_Entry> |
XBDatabaseAccessor.getEntries(XBStore store,
int numOfEntries,
long numOfBytes,
I_EntryFilter entryFilter,
boolean isRef,
I_Storage storage)
gets the first numOfEntries of the queue. |
java.util.List<I_Entry> |
XBDatabaseAccessorDelegate.getEntriesWithLimit(XBStore store,
I_Entry limitEntry,
I_Storage storage)
|
java.util.List<I_Entry> |
XBDatabaseAccessor.getEntriesWithLimit(XBStore store,
I_Entry limitEntry,
I_Storage storage)
gets the first numOfEntries of the queue until the limitEntry is reached. |
java.util.List<I_Entry> |
XBDatabaseAccessorDelegate.getRefEntries(XBStore store,
int numOfEntries,
long numOfBytes,
I_EntryFilter entryFilter,
I_Storage storage,
I_QueueEntry firstEntryExlusive)
|
java.util.List<I_Entry> |
XBDatabaseAccessor.getRefEntries(XBStore store,
int numOfEntries,
long numOfBytes,
I_EntryFilter entryFilter,
I_Storage storage,
I_QueueEntry firstEntryExlusive)
|
Constructors in org.xmlBlaster.util.queue.jdbc with parameters of type I_Storage | |
---|---|
CommonTableDatabaseAccessor(JdbcConnectionPool pool,
I_EntryFactory factory,
java.lang.String managerName,
I_Storage storage)
|
|
CommonTableDatabaseAccessorDelegate(JdbcConnectionPool pool,
I_EntryFactory factory,
java.lang.String managerName,
I_Storage storage)
|
Uses of I_Storage in org.xmlBlaster.util.queue.ram |
---|
Classes in org.xmlBlaster.util.queue.ram that implement I_Storage | |
---|---|
class |
RamQueuePlugin
Queueing messages in RAM only, sorted after priority and timestamp |
|
xmlBlaster 2.2.0 client API | |||||||||
PREV NEXT | FRAMES NO FRAMES |