org.jumpmind.symmetric.service.impl

Class ExtensionService

java.lang.Object

org.jumpmind.symmetric.service.impl.AbstractService

org.jumpmind.symmetric.service.impl.ExtensionService

All Implemented Interfaces:

IExtensionService, IService

public class ExtensionService
extends AbstractService
implements IExtensionService

This service registers IExtensionPoints defined both by SymmetricDS and others found in the ApplicationContext. It also reads the sym_extension table for IExtensionPoints defined there.

SymmetricDS reads in any Spring XML file found in the classpath of the application that matches the following pattern: /META-INF/services/symmetric-*-ext.xml

Field Summary

Fields

Modifier and Type	Field and Description
protected ISymmetricEngine	engine
protected java.util.List<ExtensionPointMetaData>	extensionMetaData
protected java.util.Map<java.lang.Class,java.util.Map<java.lang.String,org.jumpmind.extension.IExtensionPoint>>	extensionsByClassByName
protected org.jumpmind.util.SimpleClassCompiler	simpleClassCompiler
protected java.util.Map<java.lang.Class,java.util.Map<java.lang.String,org.jumpmind.extension.IExtensionPoint>>	staticExtensionsByClassByName

Fields inherited from class org.jumpmind.symmetric.service.impl.AbstractService

parameterService, platform, sqlTemplate, sqlTemplateDirty, symmetricDialect, tablePrefix

Constructor Summary

Constructors

Constructor and Description
ExtensionService(ISymmetricEngine engine)

Method Summary

Modifier and Type	Method and Description
void	addExtensionPoint(org.jumpmind.extension.IExtensionPoint extension)
void	addExtensionPoint(java.lang.String name, org.jumpmind.extension.IExtensionPoint extension)
protected void	addExtensionPointMetaData(org.jumpmind.extension.IExtensionPoint extensionPoint, java.lang.String name, java.lang.Class<? extends org.jumpmind.extension.IExtensionPoint> extensionClass, boolean installed)
void	deleteExtension(java.lang.String extensionId)
java.lang.Object	getCompiledClass(java.lang.String javaCode)
protected java.util.List<java.lang.Class>	getExtensionClassList(org.jumpmind.extension.IExtensionPoint ext)
<T extends org.jumpmind.extension.IExtensionPoint> T	getExtensionPoint(java.lang.Class<T> extensionClass)
<T extends org.jumpmind.extension.IExtensionPoint> java.util.List<T>	getExtensionPointList(java.lang.Class<T> extensionClass)
<T extends org.jumpmind.extension.IExtensionPoint> java.util.Map<java.lang.String,T>	getExtensionPointMap(java.lang.Class<T> extensionClass)
java.util.List<ExtensionPointMetaData>	getExtensionPointMetaData()
java.util.List<Extension>	getExtensions()
protected java.util.Map<java.lang.String,org.jumpmind.extension.IExtensionPoint>	getExtensionsByNameMap(java.lang.Class extensionClass)
protected java.util.Map<java.lang.String,org.jumpmind.extension.IExtensionPoint>	getExtensionsByNameMap(java.util.Map<java.lang.Class,java.util.Map<java.lang.String,org.jumpmind.extension.IExtensionPoint>> byClassByNameMap, java.lang.Class extensionClass)
protected java.util.Map<java.lang.String,org.jumpmind.extension.IExtensionPoint>	getStaticExtensionsByNameMap(java.lang.Class extensionClass)
protected boolean	initializeExtension(org.jumpmind.extension.IExtensionPoint ext)
void	refresh()
protected void	registerExtension(Extension extension)
protected boolean	registerExtension(java.lang.String name, org.jumpmind.extension.IExtensionPoint ext)
protected boolean	registerExtension(java.lang.String name, org.jumpmind.extension.IExtensionPoint ext, boolean shouldLog)
void	removeExtensionPoint(org.jumpmind.extension.IExtensionPoint extension)
void	saveExtension(Extension extension)
protected void	unRegisterExtension(java.lang.String name, org.jumpmind.extension.IExtensionPoint ext)

Methods inherited from class org.jumpmind.symmetric.service.impl.AbstractService

assertNotNull, buildBatchWhere, close, createSqlReplacementTokens, createSqlReplacementTokens, getJdbcTemplate, getParameterService, getSql, getSymmetricDialect, getTablePrefix, getTargetDialect, getTargetPlatform, getTargetPlatform, isCalledFromSymmetricAdminTool, isSet, isStreamClosedByClient, isSymmetricTable, logOnce, maxDate, readAcks, sendAck, setSqlMap, synchronize, toNodeIds, toNodeIds

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

engine

protected ISymmetricEngine engine

simpleClassCompiler

protected org.jumpmind.util.SimpleClassCompiler simpleClassCompiler

staticExtensionsByClassByName

protected java.util.Map<java.lang.Class,java.util.Map<java.lang.String,org.jumpmind.extension.IExtensionPoint>> staticExtensionsByClassByName

extensionsByClassByName

protected java.util.Map<java.lang.Class,java.util.Map<java.lang.String,org.jumpmind.extension.IExtensionPoint>> extensionsByClassByName

extensionMetaData

protected java.util.List<ExtensionPointMetaData> extensionMetaData

Constructor Detail

ExtensionService

public ExtensionService(ISymmetricEngine engine)

Method Detail

refresh

public void refresh()

Specified by:

refresh in interface IExtensionService

registerExtension

protected void registerExtension(Extension extension)

registerExtension

protected boolean registerExtension(java.lang.String name,
                                    org.jumpmind.extension.IExtensionPoint ext)

registerExtension

protected boolean registerExtension(java.lang.String name,
                                    org.jumpmind.extension.IExtensionPoint ext,
                                    boolean shouldLog)

unRegisterExtension

protected void unRegisterExtension(java.lang.String name,
                                   org.jumpmind.extension.IExtensionPoint ext)

initializeExtension

protected boolean initializeExtension(org.jumpmind.extension.IExtensionPoint ext)

getExtensionClassList

protected java.util.List<java.lang.Class> getExtensionClassList(org.jumpmind.extension.IExtensionPoint ext)

getExtensionPointMetaData

public java.util.List<ExtensionPointMetaData> getExtensionPointMetaData()

Specified by:

getExtensionPointMetaData in interface IExtensionService

addExtensionPointMetaData

protected void addExtensionPointMetaData(org.jumpmind.extension.IExtensionPoint extensionPoint,
                                         java.lang.String name,
                                         java.lang.Class<? extends org.jumpmind.extension.IExtensionPoint> extensionClass,
                                         boolean installed)

getExtensionPoint

public <T extends org.jumpmind.extension.IExtensionPoint> T getExtensionPoint(java.lang.Class<T> extensionClass)

Specified by:

getExtensionPoint in interface IExtensionService

getExtensionPointList

public <T extends org.jumpmind.extension.IExtensionPoint> java.util.List<T> getExtensionPointList(java.lang.Class<T> extensionClass)

Specified by:

getExtensionPointList in interface IExtensionService

getExtensionPointMap

public <T extends org.jumpmind.extension.IExtensionPoint> java.util.Map<java.lang.String,T> getExtensionPointMap(java.lang.Class<T> extensionClass)

Specified by:

getExtensionPointMap in interface IExtensionService

addExtensionPoint

public void addExtensionPoint(org.jumpmind.extension.IExtensionPoint extension)

Specified by:

addExtensionPoint in interface IExtensionService

addExtensionPoint

public void addExtensionPoint(java.lang.String name,
                              org.jumpmind.extension.IExtensionPoint extension)

Specified by:

addExtensionPoint in interface IExtensionService

removeExtensionPoint

public void removeExtensionPoint(org.jumpmind.extension.IExtensionPoint extension)

Specified by:

removeExtensionPoint in interface IExtensionService

getStaticExtensionsByNameMap

protected java.util.Map<java.lang.String,org.jumpmind.extension.IExtensionPoint> getStaticExtensionsByNameMap(java.lang.Class extensionClass)

getExtensionsByNameMap

protected java.util.Map<java.lang.String,org.jumpmind.extension.IExtensionPoint> getExtensionsByNameMap(java.lang.Class extensionClass)

getExtensionsByNameMap

protected java.util.Map<java.lang.String,org.jumpmind.extension.IExtensionPoint> getExtensionsByNameMap(java.util.Map<java.lang.Class,java.util.Map<java.lang.String,org.jumpmind.extension.IExtensionPoint>> byClassByNameMap,
                                                                                                        java.lang.Class extensionClass)

getExtensions

public java.util.List<Extension> getExtensions()

Specified by:

getExtensions in interface IExtensionService

saveExtension

public void saveExtension(Extension extension)

Specified by:

saveExtension in interface IExtensionService

deleteExtension

public void deleteExtension(java.lang.String extensionId)

Specified by:

deleteExtension in interface IExtensionService

getCompiledClass

public java.lang.Object getCompiledClass(java.lang.String javaCode)
                                  throws java.lang.Exception

Specified by:

getCompiledClass in interface IExtensionService

Throws:

java.lang.Exception