public class RecordStoreDocumentSubmitter extends atg.endeca.index.RecordSubmitterImpl implements DocumentSubmitter
Created: November 04 2011
EndecaIndexingOutputConfig
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
CLASS_VERSION
Class version string
|
SERVICE_INFO_KEY
INDEXING_MODE_FULL, INDEXING_MODE_INCREMENTAL
DEFAULT_LOG_TRACE_STATUS
DEFAULT_LOG_DEBUG_STATUS, DEFAULT_LOG_ERROR_STATUS, DEFAULT_LOG_INFO_STATUS, DEFAULT_LOG_WARNING_STATUS
Constructor and Description |
---|
RecordStoreDocumentSubmitter() |
Modifier and Type | Method and Description |
---|---|
protected atg.endeca.index.AbstractRecordStoreAggregateSession |
createSession(java.lang.String pIndexingMode)
Create an instance of RecordStoreAggregateSessionImpl.
|
void |
doStartService()
This is called after a Service has been created, placed into the
naming hierarchy, and initialized with its configured property
values.
|
int |
getBatchSize()
Returns property batchSize.
|
java.lang.String |
getCASHostName()
Return the hostname of our CAS service.
|
int |
getCASPort()
Return out CAS port.
|
java.lang.String |
getDefaultLanguageForRecordStores() |
java.util.Locale |
getDefaultLocale()
Get the default locale for the RecordSubmitter.
|
java.lang.String |
getDefaultRecordStoreName()
The "default" record store name.
|
java.lang.String |
getEndecaDataStoreType()
Returns property endecaDataStoreType.
|
java.util.Map<java.lang.String,java.lang.String> |
getEveryRecordPropertyValues()
Returns property everyRecordPropertyValues.
|
java.lang.String |
getIdPropertyName()
Returns property idPropertyName.
|
atg.endeca.index.configuration.IndexingApplicationConfiguration |
getIndexingApplicationConfiguration()
Returns property indexingApplicationConfiguration.
|
protected java.lang.String |
getLanguageNameForLocale(java.util.Locale pLocale)
Returns the language code of given locale
|
java.io.File |
getPersistVariantSuffixesDir()
Returns property persistVariantSuffixesDir.
|
java.util.Map<java.lang.String,java.lang.String> |
getPropertyNameReplacementMap()
Returns property propertyNameReplacementMap.
|
atg.endeca.index.RecordIdSetProvider |
getRecordIdSetProvider()
Returns property RecordIdSetProvider.
|
java.lang.String |
getRecordStoreName(java.util.Locale pLocale,
java.lang.Object pObject)
Build up the record store name from endecaBaseApplicationName + "_" +
the language of the passed in locale + endecaDataStoreType.
|
protected void |
initSession(atg.endeca.index.AbstractRecordStoreAggregateSession pSession,
java.lang.String pIndexingMode) |
boolean |
isEnabled()
Returns property enabled.
|
boolean |
isFlushAfterEveryRecord()
Returns property flushAfterEveryRecord.
|
boolean |
isForceIndexingCancellationOnException()
Returns property forceIndexingCancellationOnException.
|
boolean |
isPersistVariantsPerRepositoryId()
Returns property persistVariantsPerRepositoryId.
|
boolean |
isPortSsl()
Returns property portSsl.
|
boolean |
isResetActive() |
boolean |
isSynchronizeAroundGetService()
Returns property synchronizeAroundGetService.
|
void |
setBatchSize(int pBatchSize)
Sets property batchSize.
|
void |
setDefaultLanguageForRecordStores(java.lang.String pDefaultLanguageForRecordStores) |
void |
setDefaultLocale(java.util.Locale pDefaultLocale) |
void |
setEnabled(boolean pEnabled)
Sets property enabled.
|
void |
setEndecaDataStoreType(java.lang.String pEndecaDataStoreType)
Sets property endecaDataStoreType.
|
void |
setEveryRecordPropertyValues(java.util.Map<java.lang.String,java.lang.String> pEveryRecordPropertyValues)
Sets property everyRecordPropertyValues.
|
void |
setFlushAfterEveryRecord(boolean pFlushAfterEveryRecord)
Sets property flushAfterEveryRecord.
|
void |
setForceIndexingCancellationOnException(boolean pForceIndexingCancellationOnException)
Sets property forceIndexingCancellationOnException.
|
void |
setIdPropertyName(java.lang.String pIdPropertyName)
Sets property idPropertyName.
|
void |
setIndexingApplicationConfiguration(atg.endeca.index.configuration.IndexingApplicationConfiguration pIndexingApplicationConfiguration)
Sets property indexingApplicationConfiguration.
|
void |
setPersistVariantsPerRepositoryId(boolean pPersistVariantsPerRepositoryId)
Sets property persistVariantsPerRepositoryId.
|
void |
setPersistVariantSuffixesDir(java.io.File pPersistVariantSuffixesDir)
Sets property persistVariantSuffixesDir.
|
void |
setPortSsl(boolean pPortSsl)
Sets property portSsl.
|
void |
setPropertyNameReplacementMap(java.util.Map<java.lang.String,java.lang.String> pPropertyNameReplacementMap)
Sets property propertyNameReplacementMap.
|
void |
setRecordIdSetProvider(atg.endeca.index.RecordIdSetProvider pRecordIdSetProvider)
Sets property RecordIdSetProvider.
|
void |
setResetActive(boolean pResetActive) |
void |
setSynchronizeAroundGetService(boolean pSynchronizeAroundGetService)
Sets property synchronizeAroundGetService.
|
beginSession, cancelSession, endSession, getPersistKeysDir, getPersistKeyToRecordStoreName, setPersistKeysDir, setPersistKeyToRecordStoreName, shouldIgnoreSessionEnd
addLogListener, createAdminServlet, doStopService, getAbsoluteName, getAdminServlet, getAdminServletOutputStreamEncoding, getLoggingForVlogging, getLogListenerCount, getLogListeners, getName, getNameContext, getNucleus, getRoot, getServiceConfiguration, getServiceInfo, isAdminServletUseServletOutputStream, isLoggingDebug, isLoggingError, isLoggingInfo, isLoggingTrace, isLoggingWarning, isRunning, logDebug, logDebug, logDebug, logError, logError, logError, logInfo, logInfo, logInfo, logTrace, logTrace, logTrace, logWarning, logWarning, logWarning, nameContextElementBound, nameContextElementUnbound, removeLogListener, reResolveThis, resolveName, resolveName, resolveName, resolveName, sendLogEvent, setAdminServletOutputStreamEncoding, setAdminServletUseServletOutputStream, setLoggingDebug, setLoggingError, setLoggingInfo, setLoggingTrace, setLoggingWarning, setNucleus, setServiceInfo, startService, stopService
vlogDebug, vlogDebug, vlogDebug, vlogDebug, vlogDebugTrace, vlogError, vlogError, vlogError, vlogError, vlogInfo, vlogInfo, vlogInfo, vlogInfo, vlogTrace, vlogTrace, vlogTrace, vlogTrace, vlogWarning, vlogWarning, vlogWarning, vlogWarning
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
beginSession, cancelSession, endSession
public java.lang.String getCASHostName()
public int getCASPort()
public void setDefaultLocale(java.util.Locale pDefaultLocale)
setDefaultLocale
in class atg.endeca.index.RecordSubmitterImpl
public java.util.Locale getDefaultLocale()
RecordSubmitter
getDefaultLocale
in interface RecordSubmitter
getDefaultLocale
in class atg.endeca.index.RecordSubmitterImpl
public void setDefaultLanguageForRecordStores(java.lang.String pDefaultLanguageForRecordStores)
setDefaultLanguageForRecordStores
in class atg.endeca.index.RecordSubmitterImpl
public java.lang.String getDefaultLanguageForRecordStores()
getDefaultLanguageForRecordStores
in class atg.endeca.index.RecordSubmitterImpl
public void setEndecaDataStoreType(java.lang.String pEndecaDataStoreType)
public java.lang.String getEndecaDataStoreType()
public void setIdPropertyName(java.lang.String pIdPropertyName)
public java.lang.String getIdPropertyName()
public void setFlushAfterEveryRecord(boolean pFlushAfterEveryRecord)
public boolean isFlushAfterEveryRecord()
public boolean isResetActive()
public void setResetActive(boolean pResetActive)
protected java.lang.String getLanguageNameForLocale(java.util.Locale pLocale)
pLocale
- - localepublic java.lang.String getRecordStoreName(java.util.Locale pLocale, java.lang.Object pObject)
pLocale
- the locale to use for the language name. If null,
the property defaultLocale will be used instead.public java.lang.String getDefaultRecordStoreName()
public void setBatchSize(int pBatchSize)
public int getBatchSize()
public void setEnabled(boolean pEnabled)
public boolean isEnabled()
public void setPortSsl(boolean pPortSsl)
pPortSsl
- portSslpublic boolean isPortSsl()
public void setPersistVariantSuffixesDir(java.io.File pPersistVariantSuffixesDir)
public java.io.File getPersistVariantSuffixesDir()
public void setSynchronizeAroundGetService(boolean pSynchronizeAroundGetService)
public boolean isSynchronizeAroundGetService()
public void setPersistVariantsPerRepositoryId(boolean pPersistVariantsPerRepositoryId)
public boolean isPersistVariantsPerRepositoryId()
public void setIndexingApplicationConfiguration(atg.endeca.index.configuration.IndexingApplicationConfiguration pIndexingApplicationConfiguration)
public atg.endeca.index.configuration.IndexingApplicationConfiguration getIndexingApplicationConfiguration()
public void setPropertyNameReplacementMap(java.util.Map<java.lang.String,java.lang.String> pPropertyNameReplacementMap)
public java.util.Map<java.lang.String,java.lang.String> getPropertyNameReplacementMap()
public void setEveryRecordPropertyValues(java.util.Map<java.lang.String,java.lang.String> pEveryRecordPropertyValues)
public java.util.Map<java.lang.String,java.lang.String> getEveryRecordPropertyValues()
public void setForceIndexingCancellationOnException(boolean pForceIndexingCancellationOnException)
public boolean isForceIndexingCancellationOnException()
public void setRecordIdSetProvider(atg.endeca.index.RecordIdSetProvider pRecordIdSetProvider)
public atg.endeca.index.RecordIdSetProvider getRecordIdSetProvider()
public void doStartService() throws ServiceException
doStartService
in class GenericService
ServiceException
- if the Service had a problem starting up
hidden: trueprotected atg.endeca.index.AbstractRecordStoreAggregateSession createSession(java.lang.String pIndexingMode) throws IndexingException
createSession
in class atg.endeca.index.RecordSubmitterImpl
pIndexingMode
- the indexing mode to use for the sessionIndexingException
protected void initSession(atg.endeca.index.AbstractRecordStoreAggregateSession pSession, java.lang.String pIndexingMode)
initSession
in class atg.endeca.index.RecordSubmitterImpl