Class UserUpdateListenerCustomer


  • @DataRouteByKey("customer")
    public class UserUpdateListenerCustomer
    extends Object
    • Constructor Detail

      • UserUpdateListenerCustomer

        public UserUpdateListenerCustomer​(com.broadleafcommerce.common.messaging.service.IdempotentMessageConsumptionService idempotentConsumptionService,
                                          CustomerService<Customer> customerService)
    • Method Detail

      • listen

        @StreamListener("userUpdateCustomerInput")
        public void listen​(org.springframework.messaging.Message<User> userMessage)
      • processMessage

        protected void processMessage​(org.springframework.messaging.Message<User> userMessage)
      • buildContextInfo

        protected com.broadleafcommerce.data.tracking.core.context.ContextInfo buildContextInfo​(User user)
      • getIdempotentConsumptionService

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