Uses of Interface
org.xmlBlaster.util.queue.I_Storage

Packages that use I_Storage

org.xmlBlaster.authentication
org.xmlBlaster.engine.msgstore
org.xmlBlaster.engine.msgstore.cache
org.xmlBlaster.engine.msgstore.ram
org.xmlBlaster.engine.query.plugins
org.xmlBlaster.test.classtest.queue
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.authentication

Methods in org.xmlBlaster.authentication with parameters of type I_Storage

void	SessionInfo.changed(I_Storage storage, long numEntries, long numBytes, boolean isShutdown) We register for queue size changes and notify the subject queue if we are willing to accept messages again.

Uses of I_Storage in org.xmlBlaster.engine.msgstore

Subinterfaces of I_Storage in org.xmlBlaster.engine.msgstore

interface

I_Map The Interface which our persistent map and cache map must implement.

Methods in org.xmlBlaster.engine.msgstore with parameters of type I_Storage

void	StoragePluginManager.cleanup(I_Storage storage)
private void	StoragePluginManager.registerOrRemovePlugin(I_Storage plugin, boolean register) Not synchronized since invoked inside the synchronized(this.storagesMap)

Uses of I_Storage in org.xmlBlaster.engine.msgstore.cache

Classes in org.xmlBlaster.engine.msgstore.cache that implement I_Storage

class

PersistenceCachePlugin Implements a random access message storage.

Uses of I_Storage in org.xmlBlaster.engine.msgstore.ram

Classes in org.xmlBlaster.engine.msgstore.ram that implement I_Storage

class

MapPlugin Mapping messages in RAM only.

Uses of I_Storage in org.xmlBlaster.engine.query.plugins

Methods in org.xmlBlaster.engine.query.plugins with parameters of type I_Storage

void	QueueQueryPlugin.changed(I_Storage storage, long numEntries, long numBytes, boolean isShutdown) We register for queue size changes and our blocking thread returns if we are done.

Uses of I_Storage in org.xmlBlaster.test.classtest.queue

Methods in org.xmlBlaster.test.classtest.queue with parameters of type I_Storage

void	I_QueueTest.QueueSizeListener.changed(I_Storage storage, long numEntries, long numBytes, boolean isShutdown)

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.

Fields in org.xmlBlaster.util.queue declared as I_Storage

private I_Storage

StorageSizeListenerHelper.storage

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)
private EventHelper	StorageEventHandler.getMatchingEvent(EventHelper helper, I_Storage storage) Check if the given storageId matches any of the wanted events.
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)
private void	QueuePluginManager.registerOrRemovePlugin(I_Storage plugin, boolean register)
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.

Fields in org.xmlBlaster.util.queue.jdbc declared as I_Storage

private I_Storage

CommonTableDatabaseAccessor.storage

Methods in org.xmlBlaster.util.queue.jdbc with parameters of type I_Storage

private java.util.List<I_Entry>	XBDatabaseAccessor.createEntries(XBStore store, java.util.List<XBMeat> meatList, java.util.List<XBRef> refList, I_EntryFilter filter, I_Storage 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