public class ManifoldCF extends ManifoldCF
ManifoldCF.CachePoll, ManifoldCF.DatabaseConnectionReleaseThread, ManifoldCF.DatabaseShutdown, ManifoldCF.FileTrack, ManifoldCF.OverrideableManifoldCFConfiguration, ManifoldCF.ShutdownThread
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
_rcsid |
static java.lang.String |
agentShutdownSignal |
protected static boolean |
agentsInitialized |
protected static java.lang.String |
API_ERRORNODE |
protected static java.lang.String |
API_SERVICEINTERRUPTIONNODE |
alreadyClosed, alreadyShutdown, applicationName, ATTRIBUTE_PATH, authImplementation, cleanupHooks, configSignalCommandProperty, databaseConnectionTrackingProperty, databaseHandleMaxcountProperty, databaseHandleTimeoutProperty, databaseImplementation, databaseQueryMaxTimeProperty, dbShutdown, fileResourcesProperty, initializeFlagLock, initializeLevel, IV_LENGTH, lcfConfigFileProperty, localConfiguration, lockManagerImplementation, logConfigFileProperty, maintenanceFileSignalProperty, masterDatabaseName, masterDatabaseNameProperty, masterDatabasePassword, masterDatabasePasswordProperty, masterDatabaseUsername, masterDatabaseUsernameProperty, mcfVersion, NODE_LIBDIR, pollingHooks, processID, processIDProperty, propertyFilelastMod, propertyFilePath, resourceLoader, saltProperty, shutdownThread, tracker, versionProperty, workingDirectory
Constructor and Description |
---|
ManifoldCF() |
Modifier and Type | Method and Description |
---|---|
static void |
cleanUpEnvironment(IThreadContext threadContext)
Clean up environment.
|
static void |
createErrorNode(Configuration output,
ManifoldCFException e)
Handle an exception, by converting it to an error node.
|
static void |
createErrorNode(Configuration output,
java.lang.String errorMessage)
Create an error node with a general error message.
|
static void |
createServiceInterruptionNode(Configuration output,
ServiceInterruption e)
Handle a service interruption, by converting it to a serviceinterruption node.
|
static void |
deinstallTables(IThreadContext threadcontext)
Uninstall all the crawler system tables.
|
static ConfigurationNode |
findConfigurationNode(Configuration input,
java.lang.String argumentName)
Find a configuration node given a name
|
static java.lang.String |
getRootArgument(Configuration input,
java.lang.String argumentName)
Find a configuration value given a name
|
static void |
initializeEnvironment(IThreadContext threadContext)
Initialize environment.
|
static void |
installTables(IThreadContext threadcontext)
Install the agent tables.
|
static void |
localCleanup(IThreadContext threadContext) |
static void |
localInitialize(IThreadContext threadContext) |
static java.lang.String |
qualifyOutputActivityName(java.lang.String outputActivityName,
java.lang.String outputConnectionName)
Qualify output activity name.
|
static java.lang.String |
qualifyTransformationActivityName(java.lang.String transformationActivityName,
java.lang.String transformationConnectionName)
Qualify transformation activity name.
|
static void |
resetEnvironment(IThreadContext threadContext)
Reset the environment.
|
static void |
signalOutputConnectionRedo(IThreadContext threadContext,
java.lang.String connectionName)
Signal output connection needs redoing.
|
static void |
signalOutputConnectionRemoved(IThreadContext threadContext,
java.lang.String connectionName)
Signal output connection has been deleted.
|
addFile, addPollingHook, addShutdownHook, addToHash, checkMaintenanceUnderway, checkProperties, cleanUpEnvironment, createResourceLoader, createSystemDatabase, createTempDir, decrypt, deleteFile, deleteFolder, deobfuscate, dropSystemDatabase, encrypt, ensureFolder, findClass, getBooleanProperty, getChildDatabaseName, getCipher, getCipher, getConfiguration, getDoubleProperty, getFileProperty, getHashValue, getIntProperty, getLongProperty, getMasterDatabaseName, getMasterDatabasePassword, getMasterDatabaseUsername, getMcfVersion, getProcessID, getProperty, getSaltValue, getSecureRandom, getStringProperty, hash, initializeEnvironment, isFolder, noteConfigurationChange, obfuscate, pollAll, readByte, readByteArray, readBytes, readDword, readfloat, readLong, readNibble, readSdword, readString, readWord, recursiveDelete, registerConnectorServices, resetEnvironment, resolvePath, safeFileName, sleep, startHash, systemExit, writeByte, writeByteArray, writeBytes, writeDword, writefloat, writeLong, writeNibble, writeSdword, writeString, writeWord
public static final java.lang.String _rcsid
public static final java.lang.String agentShutdownSignal
protected static boolean agentsInitialized
protected static final java.lang.String API_ERRORNODE
protected static final java.lang.String API_SERVICEINTERRUPTIONNODE
public static void initializeEnvironment(IThreadContext threadContext) throws ManifoldCFException
ManifoldCFException
public static void cleanUpEnvironment(IThreadContext threadContext)
public static void localInitialize(IThreadContext threadContext) throws ManifoldCFException
ManifoldCFException
public static void localCleanup(IThreadContext threadContext)
public static void resetEnvironment(IThreadContext threadContext)
public static void installTables(IThreadContext threadcontext) throws ManifoldCFException
threadcontext
- is the thread context.ManifoldCFException
public static void deinstallTables(IThreadContext threadcontext) throws ManifoldCFException
threadcontext
- is the thread context.ManifoldCFException
public static void signalOutputConnectionRedo(IThreadContext threadContext, java.lang.String connectionName) throws ManifoldCFException
threadContext
- is the thread context.connectionName
- is the connection name.ManifoldCFException
public static void signalOutputConnectionRemoved(IThreadContext threadContext, java.lang.String connectionName) throws ManifoldCFException
threadContext
- is the thread context.connectionName
- is the connection name.ManifoldCFException
public static java.lang.String qualifyOutputActivityName(java.lang.String outputActivityName, java.lang.String outputConnectionName)
outputActivityName
- is the name of the output activity.outputConnectionName
- is the corresponding name of the output connection.public static java.lang.String qualifyTransformationActivityName(java.lang.String transformationActivityName, java.lang.String transformationConnectionName)
transformationActivityName
- is the name of the output activity.transformationConnectionName
- is the corresponding name of the transformation connection.public static ConfigurationNode findConfigurationNode(Configuration input, java.lang.String argumentName)
public static java.lang.String getRootArgument(Configuration input, java.lang.String argumentName)
public static void createErrorNode(Configuration output, java.lang.String errorMessage) throws ManifoldCFException
ManifoldCFException
public static void createErrorNode(Configuration output, ManifoldCFException e) throws ManifoldCFException
ManifoldCFException
public static void createServiceInterruptionNode(Configuration output, ServiceInterruption e)