Package com.broadleafcommerce.recommendationengine.service.messaging

Class CustomerEventListener

java.lang.Object

com.broadleafcommerce.recommendationengine.service.messaging.CustomerEventListener

@DataRouteByKey("recommendationEngine")
public class CustomerEventListener
extends Object

Constructor Summary

Constructors

Constructor	Description
CustomerEventListener(com.broadleafcommerce.common.messaging.service.IdempotentMessageConsumptionService idempotentMessageService, CustomerService<Customer> customerService, com.broadleafcommerce.common.extension.TypeFactory typeFactory)

Method Summary

Modifier and Type	Method	Description
protected com.broadleafcommerce.data.tracking.core.context.ContextInfo	buildContextInfo(@NonNull CustomerModifiedEvent event, @NonNull List<Customer> customers)	Builds a ContextInfo for the persistence event related to the entity.
protected CustomerService<Customer>	getCustomerService()
protected com.broadleafcommerce.common.messaging.service.IdempotentMessageConsumptionService	getIdempotentMessageService()
protected com.broadleafcommerce.common.extension.TypeFactory	getTypeFactory()
void	listen(org.springframework.messaging.Message<CustomerModifiedEvent> message)
protected void	logBulkResponseFailures(com.broadleafcommerce.data.tracking.core.service.BulkPersistenceResponse<Customer> bulkResponse, boolean isCreate, @NotNull com.broadleafcommerce.data.tracking.core.context.ContextInfo contextInfo)
protected void	processCustomerModification(@NonNull List<Customer> customers, @NonNull String operationType, @NonNull com.broadleafcommerce.data.tracking.core.context.ContextInfo contextInfo)
protected void	processCustomerUpdates(@NotNull List<Customer> customers, @NotNull com.broadleafcommerce.data.tracking.core.context.ContextInfo contextInfo)
void	processEvent(@NonNull org.springframework.messaging.Message<CustomerModifiedEvent> message)

Methods inherited from class java.lang.Object

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

Constructor Details

CustomerEventListener

public CustomerEventListener(com.broadleafcommerce.common.messaging.service.IdempotentMessageConsumptionService idempotentMessageService,
 CustomerService<Customer> customerService,
 com.broadleafcommerce.common.extension.TypeFactory typeFactory)

Method Details

listen

@StreamListener("recommendationEngineCustomerEventInput")
public void listen(org.springframework.messaging.Message<CustomerModifiedEvent> message)

processEvent

public void processEvent(@NonNull
 @NonNull org.springframework.messaging.Message<CustomerModifiedEvent> message)

processCustomerModification

protected void processCustomerModification(@NonNull
 @NonNull List<Customer> customers,
 @NonNull
 @NonNull String operationType,
 @NonNull
 @NonNull com.broadleafcommerce.data.tracking.core.context.ContextInfo contextInfo)

processCustomerUpdates

protected void processCustomerUpdates(@NotNull
 @NotNull List<Customer> customers,
 @NotNull
 @NotNull com.broadleafcommerce.data.tracking.core.context.ContextInfo contextInfo)

logBulkResponseFailures

protected void logBulkResponseFailures(com.broadleafcommerce.data.tracking.core.service.BulkPersistenceResponse<Customer> bulkResponse,
 boolean isCreate,
 @NotNull
 @NotNull com.broadleafcommerce.data.tracking.core.context.ContextInfo contextInfo)

buildContextInfo

protected com.broadleafcommerce.data.tracking.core.context.ContextInfo buildContextInfo(@NonNull
 @NonNull CustomerModifiedEvent event,
 @NonNull
 @NonNull List<Customer> customers)

Builds a ContextInfo for the persistence event related to the entity. Uses the one on the event if present.

Parameters:

event - The deserialized event.

Returns:

A ContextInfo for the persistence event related to the entity.

getIdempotentMessageService

protected com.broadleafcommerce.common.messaging.service.IdempotentMessageConsumptionService getIdempotentMessageService()

getCustomerService

protected CustomerService<Customer> getCustomerService()

getTypeFactory

protected com.broadleafcommerce.common.extension.TypeFactory getTypeFactory()