Package com.broadleafcommerce.search.index.customer.messaging.handler

Class CustomerBatchIndexRequestHandler

java.lang.Object

com.broadleafcommerce.search.index.common.messaging.handler.AbstractBatchIndexRequestHandler

com.broadleafcommerce.search.index.customer.messaging.handler.CustomerBatchIndexRequestHandler

public class CustomerBatchIndexRequestHandler
extends com.broadleafcommerce.search.index.common.messaging.handler.AbstractBatchIndexRequestHandler

Listens for a BatchIndexRequest message and launches a reindex. Leverages simple processing via the ReindexDelegationService.reindex(List) api.

Author:

Jeff Fischer

Field Summary

Fields

Modifier and Type	Field	Description
protected static final String[]	supportedSimpleTypeNames

Constructor Summary

Constructors

Constructor	Description
CustomerBatchIndexRequestHandler(com.fasterxml.jackson.databind.ObjectMapper objectMapper, com.broadleafcommerce.search.index.core.service.ReindexDelegationService reindexDelegationService, com.broadleafcommerce.search.index.core.service.ReindexService reindexService, CustomerService customerService, int chunkSize)

Method Summary

Modifier and Type	Method	Description
protected int	getChunkSize()
protected CustomerService	getCustomerService()
protected com.broadleafcommerce.search.index.core.service.ReindexDelegationService	getReindexDelegationService()
protected com.broadleafcommerce.search.index.core.service.ReindexService	getReindexService()
String[]	getSupportedSimpleTypeNames()
void	hook(String batchIndexRequest)
void	processBatchIndexRequest(com.fasterxml.jackson.databind.JsonNode batchIndexRequest)

Methods inherited from class com.broadleafcommerce.search.index.common.messaging.handler.AbstractBatchIndexRequestHandler

addNotFoundIndexables, getObjectMapper, getTypeFactory, handle, isValidType, setTypeFactory

Methods inherited from class java.lang.Object

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

Field Details

supportedSimpleTypeNames

protected static final String[] supportedSimpleTypeNames

Constructor Details

CustomerBatchIndexRequestHandler

public CustomerBatchIndexRequestHandler(com.fasterxml.jackson.databind.ObjectMapper objectMapper,
 com.broadleafcommerce.search.index.core.service.ReindexDelegationService reindexDelegationService,
 com.broadleafcommerce.search.index.core.service.ReindexService reindexService,
 CustomerService customerService,
 int chunkSize)

Method Details

hook

@StreamListener("batchIndexRequestInputCustomer")
public void hook(String batchIndexRequest)

Specified by:

hook in class com.broadleafcommerce.search.index.common.messaging.handler.AbstractBatchIndexRequestHandler

processBatchIndexRequest

public void processBatchIndexRequest(com.fasterxml.jackson.databind.JsonNode batchIndexRequest)

Specified by:

processBatchIndexRequest in class com.broadleafcommerce.search.index.common.messaging.handler.AbstractBatchIndexRequestHandler

getSupportedSimpleTypeNames

public String[] getSupportedSimpleTypeNames()

Specified by:

getSupportedSimpleTypeNames in class com.broadleafcommerce.search.index.common.messaging.handler.AbstractBatchIndexRequestHandler

getReindexDelegationService

protected com.broadleafcommerce.search.index.core.service.ReindexDelegationService getReindexDelegationService()

getReindexService

protected com.broadleafcommerce.search.index.core.service.ReindexService getReindexService()

getCustomerService

protected CustomerService getCustomerService()

getChunkSize

protected int getChunkSize()