|
xmlBlaster 2.2.0 API | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.xmlBlaster.util.plugin.PluginManagerBase org.xmlBlaster.engine.msgstore.StoragePluginManager
public class StoragePluginManager
StoragePluginManager loads the I_Map implementation plugins.
Usage examples:
// xmlBlaster.properties or on command line #------------------------------------------------------------------------------ # Declare existing queue implementation plugins # SEE: http://www.xmlBlaster.org/xmlBlaster/doc/requirements/engine.message.lifecycle.html StoragePlugin[JDBC][1.0]=org.xmlBlaster.util.queue.jdbc.JdbcQueuePlugin StoragePlugin[RAM][1.0]=org.xmlBlaster.engine.msgstore.ram.MapPlugin StoragePlugin[CACHE][1.0]=org.xmlBlaster.engine.msgstore.cache.PersistenceCachePlugin,transientMap=RAM,persistentMap=JDBC # Choose the plugin (each publisher can overwrite this in its publish topic-QoS) persistence/defaultPlugin=CACHE,1.0 persistence/topicStore/defaultPlugin=JDBC,1.0 persistence/msgUnitStore/defaultPlugin=CACHE,1.0 # If you choose CACHE as defaultPlugin configure the CACHE plugin: persistence.cache.persistentQueue=JDBC,1.0 persistence.cache.transientQueue=RAM,1.0 #------------------------------------------------------------------------------
Field Summary | |
---|---|
private static java.lang.String[][] |
defaultPluginNames
|
private java.util.Map |
eventHandlerMap
|
private ServerScope |
glob
|
private static java.util.logging.Logger |
log
|
private java.lang.String |
pluginEnvClass
|
static java.lang.String |
pluginPropertyName
|
private static boolean |
REGISTER
|
private static boolean |
REMOVE
|
private java.util.Map |
storagesMap
|
Fields inherited from class org.xmlBlaster.util.plugin.PluginManagerBase |
---|
NO_PLUGIN_TYPE |
Constructor Summary | |
---|---|
StoragePluginManager(ServerScope glob)
|
Method Summary | |
---|---|
void |
cleanup(I_Storage storage)
|
java.lang.String |
getDefaultPluginName(java.lang.String type,
java.lang.String version)
|
StorageEventHandler |
getEventHandler(java.lang.String key)
|
I_Map |
getPlugin(PluginInfo pluginInfo,
StorageId storageId,
QueuePropertyBase props)
|
I_Map |
getPlugin(java.lang.String typeVersion,
StorageId storageId,
QueuePropertyBase props)
|
I_Map |
getPlugin(java.lang.String type,
java.lang.String version,
StorageId storageId,
QueuePropertyBase props)
Return a new created storage plugin. |
protected java.lang.String |
getPluginPropertyName()
Enforced by PluginManagerBase. |
protected void |
postInstantiate(I_Plugin plugin,
PluginInfo pluginInfo)
Is called after a plugin in instantiated, allows the base class to do specific actions. |
private void |
registerOrRemovePlugin(I_Storage plugin,
boolean register)
Not synchronized since invoked inside the synchronized(this.storagesMap) |
boolean |
setEventHandler(java.lang.String key,
StorageEventHandler handler)
Set an EventHandler singleton |
Methods inherited from class org.xmlBlaster.util.plugin.PluginManagerBase |
---|
createPluginPropertyKey, getDummyPlugin, getFromPluginCache, getGlobal, getName, getPluginObject, getPluginObject, getPluginObject, ignorePlugin, instantiatePlugin, instantiatePlugin, removeFromPluginCache, shutdown |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
private final ServerScope glob
private static java.util.logging.Logger log
private final java.lang.String pluginEnvClass
private static final java.lang.String[][] defaultPluginNames
public static final java.lang.String pluginPropertyName
private java.util.Map storagesMap
private java.util.Map eventHandlerMap
private static final boolean REMOVE
private static final boolean REGISTER
Constructor Detail |
---|
public StoragePluginManager(ServerScope glob)
Method Detail |
---|
public I_Map getPlugin(java.lang.String typeVersion, StorageId storageId, QueuePropertyBase props) throws XmlBlasterException
XmlBlasterException
getPlugin(String, String, StorageId, QueuePropertyBase)
public I_Map getPlugin(java.lang.String type, java.lang.String version, StorageId storageId, QueuePropertyBase props) throws XmlBlasterException
String
- The type of the requested plugin, pass 'undef' to suppress using a storage.String
- The version of the requested plugin.fn
- The file name for persistence or null (will be generated or ignored if RAM based)
XmlBlasterException
private void registerOrRemovePlugin(I_Storage plugin, boolean register) throws XmlBlasterException
plugin
- register
-
XmlBlasterException
public I_Map getPlugin(PluginInfo pluginInfo, StorageId storageId, QueuePropertyBase props) throws XmlBlasterException
XmlBlasterException
protected java.lang.String getPluginPropertyName()
getPluginPropertyName
in class PluginManagerBase
protected void postInstantiate(I_Plugin plugin, PluginInfo pluginInfo)
PluginManagerBase
postInstantiate
in class PluginManagerBase
public java.lang.String getDefaultPluginName(java.lang.String type, java.lang.String version)
getDefaultPluginName
in interface I_PluginManager
getDefaultPluginName
in class PluginManagerBase
type
- can be nullversion
- can be null
public boolean setEventHandler(java.lang.String key, StorageEventHandler handler) throws XmlBlasterException
handler
- null resets an existing handler
XmlBlasterException
public StorageEventHandler getEventHandler(java.lang.String key)
public void cleanup(I_Storage storage)
|
xmlBlaster 2.2.0 API | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |