Package com.hybris.merchandising.indexer.listeners

Class DefaultMerchCatalogListener

java.lang.Object

com.hybris.merchandising.indexer.listeners.DefaultMerchCatalogListener

All Implemented Interfaces:

IndexerBatchListener, IndexerListener

public class DefaultMerchCatalogListener
extends Object
implements IndexerBatchListener, IndexerListener

DefaultMerchCatalogListener is a listener which listens to Solr indexing and handles synchronising MerchProductDirectoryConfigModel definitions to CDS.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static class	DefaultMerchCatalogListener.MerchSyncInfo
protected static interface	DefaultMerchCatalogListener.Method

Field Summary

Fields

Modifier and Type	Field	Description
protected static final String	CATALOG_VERSION
protected static final com.google.common.cache.LoadingCache<String,DefaultMerchCatalogListener.MerchSyncInfo>	merchSyncInfoCache

Constructor Summary

Constructors

Constructor	Description
DefaultMerchCatalogListener()

Method Summary

Modifier and Type	Method	Description
void	afterBatch(IndexerBatchContext indexerBatchContext)	Handles a notification that the processing for a particular IndexerBatchContext has just been completed.
void	afterBatchError(IndexerBatchContext indexerBatchContext)	Handles a notification that the processing for a particular IndexerBatchContext failed.
protected void	afterBatchInternal(IndexerBatchContext indexerBatchContext)
void	afterIndex(IndexerContext indexerContext)	Handles a notification that the indexing for a particular IndexerContext has just been completed.
void	afterIndexError(IndexerContext indexerContext)	Handles a notification that the indexing for a particular IndexerContext failed.
protected void	afterIndexErrorInternal(IndexerContext indexerContext)
protected void	afterIndexInternal(IndexerContext indexerContext)
void	beforeBatch(IndexerBatchContext indexerBatchContext)	Handles a notification that the processing for a particular IndexerBatchContext is about to begin.
void	beforeIndex(IndexerContext context)	Handles a notification that the indexing for a particular IndexerContext is about to begin.
protected void	beforeIndexInternal(IndexerContext context)
protected void	cleanLogContextOperationId()
protected void	completeSyncProcess(IndexerContext context)
protected void	createMerchSync(MerchProductDirectoryConfigModel config, IndexerContext context)
protected void	executeWithExceptionHandling(String operationId, String step, DefaultMerchCatalogListener.Method method)
protected MerchSyncService	getMerchSyncService()
protected Long	getNumberOfProducts(String operationId)
protected String	getOperationId(IndexerContext indexerContext)
protected Optional<MerchProductDirectoryConfigModel>	getProductDirectoryConfig(String indexedTypeId)
protected boolean	isMerchSyncFailed(String indexOperationId)
protected void	saveBatchInfo(IndexerBatchContext indexerBatchContext, int productNumber)
protected void	saveErrorInfo(String operationId, String step, Exception e)
void	setBaseSiteService(BaseSiteService baseSiteService)
protected void	setLogContextOperationId(String operationId)
void	setMerchCatalogService(MerchCatalogService merchCatalogService)
void	setMerchCatalogServiceProductDirectoryClient(MerchCatalogServiceProductDirectoryClient merchCatalogServiceProductDirectoryClient)
void	setMerchCategoryExporter(MerchCategoryExporter merchCategoryExporter)
void	setMerchProductDirectoryConfigService(MerchProductDirectoryConfigService merchProductDirectoryConfigService)
void	setMerchSyncService(MerchSyncService merchSyncService)
void	setProductDirectoryProcessor(ProductDirectoryProcessor productDirectoryProcessor)

Methods inherited from class java.lang.Object

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

Field Details

CATALOG_VERSION

protected static final String CATALOG_VERSION

See Also:

• Constant Field Values

merchSyncInfoCache

protected static final com.google.common.cache.LoadingCache<String,DefaultMerchCatalogListener.MerchSyncInfo> merchSyncInfoCache

Constructor Details

DefaultMerchCatalogListener

public DefaultMerchCatalogListener()

Method Details

beforeBatch

public void beforeBatch(IndexerBatchContext indexerBatchContext)

Handles a notification that the processing for a particular IndexerBatchContext is about to begin.

Specified by:

beforeBatch in interface IndexerBatchListener

Parameters:

indexerBatchContext - - the IndexerBatchContext

afterBatch

public void afterBatch(IndexerBatchContext indexerBatchContext)

Handles a notification that the processing for a particular IndexerBatchContext has just been completed.

Specified by:

afterBatch in interface IndexerBatchListener

Parameters:

indexerBatchContext - - the IndexerBatchContext

afterBatchInternal

protected void afterBatchInternal(IndexerBatchContext indexerBatchContext)
                           throws IndexerException

Throws:

IndexerException

afterBatchError

public void afterBatchError(IndexerBatchContext indexerBatchContext)

Handles a notification that the processing for a particular IndexerBatchContext failed.

Specified by:

afterBatchError in interface IndexerBatchListener

Parameters:

indexerBatchContext - - the IndexerBatchContext

afterIndex

public void afterIndex(IndexerContext indexerContext)

Handles a notification that the indexing for a particular IndexerContext has just been completed.

Specified by:

afterIndex in interface IndexerListener

Parameters:

indexerContext - - the IndexerContext

afterIndexInternal

protected void afterIndexInternal(IndexerContext indexerContext)

beforeIndex

public void beforeIndex(IndexerContext context)

Description copied from interface: IndexerListener

Handles a notification that the indexing for a particular IndexerContext is about to begin.

Specified by:

beforeIndex in interface IndexerListener

Parameters:

context - - the IndexerContext

beforeIndexInternal

protected void beforeIndexInternal(IndexerContext context)

afterIndexError

public void afterIndexError(IndexerContext indexerContext)

Handles a notification that the indexing for a particular IndexerContext failed.

Specified by:

afterIndexError in interface IndexerListener

Parameters:

indexerContext - - the IndexerContext

afterIndexErrorInternal

protected void afterIndexErrorInternal(IndexerContext indexerContext)

getOperationId

protected String getOperationId(IndexerContext indexerContext)

getProductDirectoryConfig

protected Optional<MerchProductDirectoryConfigModel> getProductDirectoryConfig(String indexedTypeId)

executeWithExceptionHandling

protected void executeWithExceptionHandling(String operationId,
 String step,
 DefaultMerchCatalogListener.Method method)

createMerchSync

protected void createMerchSync(MerchProductDirectoryConfigModel config,
 IndexerContext context)

isMerchSyncFailed

protected boolean isMerchSyncFailed(String indexOperationId)

completeSyncProcess

protected void completeSyncProcess(IndexerContext context)

saveBatchInfo

protected void saveBatchInfo(IndexerBatchContext indexerBatchContext,
 int productNumber)

getNumberOfProducts

protected Long getNumberOfProducts(String operationId)

saveErrorInfo

protected void saveErrorInfo(String operationId,
 String step,
 Exception e)

setLogContextOperationId

protected void setLogContextOperationId(String operationId)

cleanLogContextOperationId

protected void cleanLogContextOperationId()

setMerchProductDirectoryConfigService

public void setMerchProductDirectoryConfigService(MerchProductDirectoryConfigService merchProductDirectoryConfigService)

setMerchCatalogService

public void setMerchCatalogService(MerchCatalogService merchCatalogService)

setMerchCatalogServiceProductDirectoryClient

public void setMerchCatalogServiceProductDirectoryClient(MerchCatalogServiceProductDirectoryClient merchCatalogServiceProductDirectoryClient)

setMerchCategoryExporter

public void setMerchCategoryExporter(MerchCategoryExporter merchCategoryExporter)

setBaseSiteService

public void setBaseSiteService(BaseSiteService baseSiteService)

setProductDirectoryProcessor

public void setProductDirectoryProcessor(ProductDirectoryProcessor productDirectoryProcessor)

getMerchSyncService

protected MerchSyncService getMerchSyncService()

setMerchSyncService

public void setMerchSyncService(MerchSyncService merchSyncService)