Package com.broadleafcommerce.scheduledjob.messaging.autoconfigure

Class ScheduledJobNotificationAutoConfiguration

  • @EnableConfigurationProperties(ScheduledJobTriggerNotificationProperties.class)
@EnableBinding(TriggeredJobEventProducer.class)
@ConditionalOnProperty(value="broadleaf.scheduledjob.notification.active",
                       matchIfMissing=true)
@AutoConfigureAfter(com.broadleafcommerce.common.messaging.autoconfigure.DurableNotificationAutoConfiguration.class)
@AutoConfigureBefore(com.broadleafcommerce.data.tracking.core.messaging.autoconfigure.TransitionRequestCompletionNotificationAutoConfiguration.class)
@Configuration
public class ScheduledJobNotificationAutoConfiguration
extends Object
    Configure the durable notification components related to job config completion and job triggering
    Author:
    Jeff Fischer

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      com.broadleafcommerce.common.messaging.notification.IgnoredNotificationStateRepository scheduledJobIgnoreChangeNotification()  
      com.broadleafcommerce.common.messaging.notification.MessageFactory<com.broadleafcommerce.common.messaging.domain.ScheduledJobRef> scheduledJobMessageFactory​(com.broadleafcommerce.data.tracking.core.mapping.DomainMapperManager mapperManager)  
      com.broadleafcommerce.common.messaging.notification.MessageFactory<com.broadleafcommerce.data.tracking.core.transition.WorkflowRequestCompletion> transitionRequestCompletionMessageFactory​(com.broadleafcommerce.data.tracking.core.mapping.DomainMapperManager mapperManager)  
      com.broadleafcommerce.common.messaging.notification.NotificationHandler transitionRequestCompletionNotificationHandler​(com.broadleafcommerce.data.tracking.core.messaging.WorkflowRequestCompletionProducer producer, com.broadleafcommerce.data.tracking.core.messaging.TransitionRequestCompletionNotificationProperties properties, List<com.broadleafcommerce.common.messaging.notification.IgnoredNotificationStateRepository> ignoredRepositories, com.broadleafcommerce.common.messaging.notification.MessageFactory<com.broadleafcommerce.data.tracking.core.transition.WorkflowRequestCompletion> messageFactory, com.broadleafcommerce.common.messaging.notification.MessageSerializationHelper helper)  
      com.broadleafcommerce.common.messaging.notification.NotificationHandler triggerJobNotificationHandler​(TriggeredJobEventProducer producer, ScheduledJobTriggerNotificationProperties properties, List<com.broadleafcommerce.common.messaging.notification.IgnoredNotificationStateRepository> ignoredRepositories, com.broadleafcommerce.common.messaging.notification.MessageFactory<com.broadleafcommerce.common.messaging.domain.ScheduledJobRef> messageFactory, com.broadleafcommerce.common.messaging.notification.MessageSerializationHelper helper)  
      com.broadleafcommerce.common.messaging.notification.RetryClusterService triggerJobRetryClusterService​(org.apache.camel.cluster.CamelClusterService camelClusterService, ScheduledJobTriggerNotificationProperties properties, ScheduledJobRepository<?> repository, com.broadleafcommerce.common.messaging.notification.NotificationHandler handler, List<com.broadleafcommerce.common.messaging.notification.IgnoredNotificationStateRepository> ignoredRepositories, com.broadleafcommerce.common.extension.data.DataRouteReference reference)  

    • Constructor Detail

      • ScheduledJobNotificationAutoConfiguration

        public ScheduledJobNotificationAutoConfiguration()

    • Method Detail

      • scheduledJobIgnoreChangeNotification

        @Bean
@ConditionalOnMissingBean(name="scheduledJobIgnoreChangeNotification")
public com.broadleafcommerce.common.messaging.notification.IgnoredNotificationStateRepository scheduledJobIgnoreChangeNotification()

      • transitionRequestCompletionMessageFactory

        @Bean
@ConditionalOnMissingBean(name="transitionRequestCompletionMessageFactory")
public com.broadleafcommerce.common.messaging.notification.MessageFactory<com.broadleafcommerce.data.tracking.core.transition.WorkflowRequestCompletion> transitionRequestCompletionMessageFactory​(com.broadleafcommerce.data.tracking.core.mapping.DomainMapperManager mapperManager)

      • transitionRequestCompletionNotificationHandler

        @Bean
@ConditionalOnMissingBean(name="transitionRequestCompletionNotificationHandler")
public com.broadleafcommerce.common.messaging.notification.NotificationHandler transitionRequestCompletionNotificationHandler​(com.broadleafcommerce.data.tracking.core.messaging.WorkflowRequestCompletionProducer producer,
                                                                                                                              com.broadleafcommerce.data.tracking.core.messaging.TransitionRequestCompletionNotificationProperties properties,
                                                                                                                              List<com.broadleafcommerce.common.messaging.notification.IgnoredNotificationStateRepository> ignoredRepositories,
                                                                                                                              @Qualifier("transitionRequestCompletionMessageFactory")
                                                                                                                              com.broadleafcommerce.common.messaging.notification.MessageFactory<com.broadleafcommerce.data.tracking.core.transition.WorkflowRequestCompletion> messageFactory,
                                                                                                                              com.broadleafcommerce.common.messaging.notification.MessageSerializationHelper helper)

      • scheduledJobMessageFactory

        @Bean
@ConditionalOnMissingBean(name="scheduledJobMessageFactory")
public com.broadleafcommerce.common.messaging.notification.MessageFactory<com.broadleafcommerce.common.messaging.domain.ScheduledJobRef> scheduledJobMessageFactory​(com.broadleafcommerce.data.tracking.core.mapping.DomainMapperManager mapperManager)

      • triggerJobNotificationHandler

        @Bean
@ConditionalOnMissingBean(name="triggerJobNotificationHandler")
public com.broadleafcommerce.common.messaging.notification.NotificationHandler triggerJobNotificationHandler​(TriggeredJobEventProducer producer,
                                                                                                             ScheduledJobTriggerNotificationProperties properties,
                                                                                                             List<com.broadleafcommerce.common.messaging.notification.IgnoredNotificationStateRepository> ignoredRepositories,
                                                                                                             @Qualifier("scheduledJobMessageFactory")
                                                                                                             com.broadleafcommerce.common.messaging.notification.MessageFactory<com.broadleafcommerce.common.messaging.domain.ScheduledJobRef> messageFactory,
                                                                                                             com.broadleafcommerce.common.messaging.notification.MessageSerializationHelper helper)

      • triggerJobRetryClusterService

        @Bean
@ConditionalOnMissingBean(name="triggerJobRetryClusterService")
public com.broadleafcommerce.common.messaging.notification.RetryClusterService triggerJobRetryClusterService​(org.apache.camel.cluster.CamelClusterService camelClusterService,
                                                                                                             ScheduledJobTriggerNotificationProperties properties,
                                                                                                             ScheduledJobRepository<?> repository,
                                                                                                             @Qualifier("triggerJobNotificationHandler")
                                                                                                             com.broadleafcommerce.common.messaging.notification.NotificationHandler handler,
                                                                                                             List<com.broadleafcommerce.common.messaging.notification.IgnoredNotificationStateRepository> ignoredRepositories,
                                                                                                             com.broadleafcommerce.common.extension.data.DataRouteReference reference)
                                                                                                      throws Exception
        Throws:
        Exception