public class RecordStoreDocumentSubmitter extends RecordSubmitterImpl implements DocumentSubmitter
Created: November 04 2011
EndecaIndexingOutputConfig
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
CLASS_VERSION
Class version string
|
INDEXING_MODE_FULL, INDEXING_MODE_INCREMENTAL
Constructor and Description |
---|
RecordStoreDocumentSubmitter() |
Modifier and Type | Method and Description |
---|---|
protected 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.
|
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() |
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.
|
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.
|
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(AbstractRecordStoreAggregateSession pSession,
java.lang.String pIndexingMode) |
boolean |
isDisableCxfLogging()
Returns property disableCxfLogging.
|
boolean |
isEnabled()
Returns property enabled.
|
boolean |
isFlushAfterEveryRecord()
Returns property flushAfterEveryRecord.
|
boolean |
isPersistVariantsPerRepositoryId()
Returns property persistVariantsPerRepositoryId.
|
boolean |
isResetActive() |
boolean |
isSynchronizeAroundGetService()
Returns property synchronizeAroundGetService.
|
void |
setCxfLoggingLevel()
Set CXF logging level, if needed.
|
void |
setDefaultLanguageForRecordStores(java.lang.String pDefaultLanguageForRecordStores) |
void |
setDefaultLocale(java.util.Locale pDefaultLocale) |
void |
setDisableCxfLogging(boolean pDisableCxfLogging)
Sets property disableCxfLogging.
|
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 |
setIdPropertyName(java.lang.String pIdPropertyName)
Sets property idPropertyName.
|
void |
setIndexingApplicationConfiguration(IndexingApplicationConfiguration pIndexingApplicationConfiguration)
Sets property indexingApplicationConfiguration.
|
void |
setPersistVariantsPerRepositoryId(boolean pPersistVariantsPerRepositoryId)
Sets property persistVariantsPerRepositoryId.
|
void |
setPersistVariantSuffixesDir(java.io.File pPersistVariantSuffixesDir)
Sets property persistVariantSuffixesDir.
|
void |
setPropertyNameReplacementMap(java.util.Map<java.lang.String,java.lang.String> pPropertyNameReplacementMap)
Sets property propertyNameReplacementMap.
|
void |
setResetActive(boolean pResetActive) |
void |
setSynchronizeAroundGetService(boolean pSynchronizeAroundGetService)
Sets property synchronizeAroundGetService.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
beginSession, cancelSession, endSession
public void setDisableCxfLogging(boolean pDisableCxfLogging)
public boolean isDisableCxfLogging()
public java.lang.String getCASHostName()
public int getCASPort()
public void setDefaultLocale(java.util.Locale pDefaultLocale)
public java.util.Locale getDefaultLocale()
public void setDefaultLanguageForRecordStores(java.lang.String pDefaultLanguageForRecordStores)
public java.lang.String getDefaultLanguageForRecordStores()
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 setEnabled(boolean pEnabled)
public boolean isEnabled()
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(IndexingApplicationConfiguration pIndexingApplicationConfiguration)
public 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 doStartService() throws ServiceException
ServiceException
- if the Service had a problem starting up
hidden: trueprotected AbstractRecordStoreAggregateSession createSession(java.lang.String pIndexingMode) throws IndexingException
pIndexingMode
- the indexing mode to use for the sessionIndexingException
protected void initSession(AbstractRecordStoreAggregateSession pSession, java.lang.String pIndexingMode)
public void setCxfLoggingLevel()