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

Class CustomerFullIndexMessageListener

java.lang.Object

com.broadleafcommerce.search.index.core.messaging.AbstractFullIndexMessageListener

com.broadleafcommerce.search.index.customer.messaging.CustomerFullIndexMessageListener

public class CustomerFullIndexMessageListener
extends com.broadleafcommerce.search.index.core.messaging.AbstractFullIndexMessageListener

A message listener that triggers when a full customer index event is received. Responsible for calling the reindex service with applicable properties.

Author:

Elbert Bautista (elbertbautista)

Field Summary

Fields inherited from class com.broadleafcommerce.search.index.core.messaging.AbstractFullIndexMessageListener

AUTHOR_PATH, INDEX_TYPE_PATH, INDEXER_ROUTE_KEY, NAME_KEY_PATH

Constructor Summary

Constructors

Constructor	Description
CustomerFullIndexMessageListener(com.broadleafcommerce.common.messaging.service.IdempotentMessageConsumptionService idempotentConsumptionService, com.fasterxml.jackson.databind.ObjectMapper objectMapper, com.broadleafcommerce.search.index.core.service.ReindexDelegationService reindexDelegationService)

Method Summary

Modifier and Type	Method	Description
protected Map<String,Serializable>	getAdditionalProperties(com.jayway.jsonpath.DocumentContext jsonContext)
protected String	getClassName()
protected com.broadleafcommerce.search.api.type.IndexableType	getIndexableType()
void	handleMessage(org.springframework.messaging.Message<String> message)
protected boolean	validateShouldReindex(com.jayway.jsonpath.DocumentContext jsonContext)

Methods inherited from class com.broadleafcommerce.search.index.core.messaging.AbstractFullIndexMessageListener

getDocumentContext, getIdempotentConsumptionService, getObjectMapper, getPayload, getReindexDelegationService, handleMessageInternal, processMessage

Methods inherited from class java.lang.Object

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

Constructor Detail

CustomerFullIndexMessageListener

public CustomerFullIndexMessageListener(com.broadleafcommerce.common.messaging.service.IdempotentMessageConsumptionService idempotentConsumptionService,
                                        com.fasterxml.jackson.databind.ObjectMapper objectMapper,
                                        com.broadleafcommerce.search.index.core.service.ReindexDelegationService reindexDelegationService)

Method Detail

handleMessage

@StreamListener("fullIndexMessageInputCustomer")
public void handleMessage(org.springframework.messaging.Message<String> message)

getClassName

protected String getClassName()

Specified by:

getClassName in class com.broadleafcommerce.search.index.core.messaging.AbstractFullIndexMessageListener

getIndexableType

protected com.broadleafcommerce.search.api.type.IndexableType getIndexableType()

Specified by:

getIndexableType in class com.broadleafcommerce.search.index.core.messaging.AbstractFullIndexMessageListener

validateShouldReindex

protected boolean validateShouldReindex(com.jayway.jsonpath.DocumentContext jsonContext)

Specified by:

validateShouldReindex in class com.broadleafcommerce.search.index.core.messaging.AbstractFullIndexMessageListener

getAdditionalProperties

protected Map<String,Serializable> getAdditionalProperties(com.jayway.jsonpath.DocumentContext jsonContext)

Specified by:

getAdditionalProperties in class com.broadleafcommerce.search.index.core.messaging.AbstractFullIndexMessageListener