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

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

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

private void	QueuePluginManager.registerOrRemovePlugin(I_Storage plugin, boolean register)
void	QueuePluginManager.cleanup(I_Storage storage)
void	StorageEventHandler.registerListener(I_Storage storage)
void	StorageEventHandler.removeListener(I_Storage storage)
private EventHelper	StorageEventHandler.getMatchingEvent(EventHelper helper, I_Storage storage) Check if the given storageId matches any of the wanted events.
void	BlockingQueueWrapper.changed(I_Storage storage, long numEntries, long numBytes, boolean isShutdown) Enforced by I_StorageSizeListener.
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.
EventHelper	EventHelper.getCopy(I_Storage storage)
void	EventHelper.changed(I_Storage storage, long numEntries, long numBytes, boolean isShutdown) Enforced by I_StorageSizeListener
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.

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

JdbcQueueCommonTablePlugin Persistence queue implementation on a DB based on JDBC.

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

private I_Storage

JdbcManagerCommonTable.storage

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

JdbcManagerCommonTable(JdbcConnectionPool pool, I_EntryFactory factory, java.lang.String managerName, I_Storage storage)

JdbcManagerCommonTableDelegate(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