Package com.broadleafcommerce.search.index.catalog.messaging

Class InventoryStockChangeMessageListener

java.lang.Object

com.broadleafcommerce.search.index.catalog.messaging.InventoryStockChangeMessageListener

@DataRouteByKey("indexer")
public class InventoryStockChangeMessageListener
extends Object

Component to receive stock change notifications and update the index where necessary.

Author:

Kelly Tisdell (ktisdell)

Constructor Summary

Constructors

Constructor	Description
InventoryStockChangeMessageListener(com.broadleafcommerce.common.messaging.service.IdempotentMessageConsumptionService idempotentConsumptionService, InventoryAvailabilityService inventoryAvailabilityService)

Method Summary

Modifier and Type	Method	Description
protected com.broadleafcommerce.common.messaging.service.IdempotentMessageConsumptionService	getIdempotentConsumptionService()
protected InventoryAvailabilityService	getInventoryAvailabilityService()
protected void	handleException(@NonNull org.springframework.messaging.Message<com.broadleafcommerce.search.catalog.core.domain.ConsolidatedInventoryAvailability> message, Exception e)
void	listen(org.springframework.messaging.Message<com.broadleafcommerce.search.catalog.core.domain.ConsolidatedInventoryAvailability> message)
protected void	processMessage(@NonNull org.springframework.messaging.Message<com.broadleafcommerce.search.catalog.core.domain.ConsolidatedInventoryAvailability> message)

Methods inherited from class java.lang.Object

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

Constructor Detail

InventoryStockChangeMessageListener

public InventoryStockChangeMessageListener(com.broadleafcommerce.common.messaging.service.IdempotentMessageConsumptionService idempotentConsumptionService,
                                           InventoryAvailabilityService inventoryAvailabilityService)

Method Detail

listen

@StreamListener("stockChangeNotificationMessageInput")
public void listen(org.springframework.messaging.Message<com.broadleafcommerce.search.catalog.core.domain.ConsolidatedInventoryAvailability> message)

processMessage

protected void processMessage(@NonNull
                              @NonNull org.springframework.messaging.Message<com.broadleafcommerce.search.catalog.core.domain.ConsolidatedInventoryAvailability> message)

handleException

protected void handleException(@NonNull
                               @NonNull org.springframework.messaging.Message<com.broadleafcommerce.search.catalog.core.domain.ConsolidatedInventoryAvailability> message,
                               Exception e)

getIdempotentConsumptionService

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

getInventoryAvailabilityService

protected InventoryAvailabilityService getInventoryAvailabilityService()