Class PurgeLoginTableJobListener


  • public class PurgeLoginTableJobListener
    extends Object
    • Method Detail

      • listen

        @StreamListener("triggeredJobEventInputPurgeLoginTable")
        public void listen​(org.springframework.messaging.Message<com.broadleafcommerce.common.messaging.domain.ScheduledJobRef> message)
      • process

        protected void process​(com.broadleafcommerce.common.messaging.domain.ScheduledJobRef msg)
      • getAuthServerId

        @Nullable
        protected String getAuthServerId​(com.broadleafcommerce.common.messaging.domain.ScheduledJobRef msg)
      • getPurgeOlderThanDuration

        @NonNull
        protected Duration getPurgeOlderThanDuration​(com.broadleafcommerce.common.messaging.domain.ScheduledJobRef scheduledJobRef)
      • getRefByName

        @Nullable
        protected com.broadleafcommerce.common.messaging.domain.ScheduledJobDetailRef getRefByName​(@NonNull
                                                                                                   com.broadleafcommerce.common.messaging.domain.ScheduledJobRef scheduledJobRef,
                                                                                                   @NonNull
                                                                                                   String refName)
      • getIdempotentService

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