Class ProcessBulkUpdateRequestNotificationAutoConfiguration
java.lang.Object
com.broadleafcommerce.bulk.messaging.autoconfigure.ProcessBulkUpdateRequestNotificationAutoConfiguration
@Configuration
@EnableConfigurationProperties(ProcessBulkUpdateRequestNotificationProperties.class)
@ConditionalOnPropertyOrGroup(name="broadleaf.bulk.process-bulk-update-request.notification.active",
group="broadleaf.basic.messaging.enabled",
matchIfMissing=true)
@EnableBinding(ProcessBulkUpdateRequestProducer.class)
@AutoConfigureAfter(com.broadleafcommerce.common.messaging.autoconfigure.DurableNotificationAutoConfiguration.class)
public class ProcessBulkUpdateRequestNotificationAutoConfiguration
extends Object
Configure the durable notification components for
ProcessBulkUpdateRequestProducer
.- Author:
- Samarth Dhruva (samarthd)
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptioncom.broadleafcommerce.common.messaging.notification.MessageFactory<ProcessBulkUpdateRequest>
processBulkUpdateRequestMessageFactory
(com.broadleafcommerce.data.tracking.core.mapping.DomainMapperManager manager) com.broadleafcommerce.common.messaging.notification.NotificationHandler
processBulkUpdateRequestNotificationHandler
(ProcessBulkUpdateRequestProducer producer, ProcessBulkUpdateRequestNotificationProperties properties, List<com.broadleafcommerce.common.messaging.notification.IgnoredNotificationStateRepository> ignoredRepositories, com.broadleafcommerce.common.messaging.notification.MessageFactory<ProcessBulkUpdateRequest> messageFactory, com.broadleafcommerce.common.messaging.notification.MessageSerializationHelper helper) com.broadleafcommerce.common.messaging.notification.RetryClusterService
processBulkUpdateRequestRetryClusterService
(org.apache.camel.cluster.CamelClusterService camelClusterService, ProcessBulkUpdateRequestNotificationProperties properties, BulkUpdateRepository<?> repository, com.broadleafcommerce.common.messaging.notification.NotificationHandler handler, List<com.broadleafcommerce.common.messaging.notification.IgnoredNotificationStateRepository> ignoredRepositories, com.broadleafcommerce.common.extension.data.DataRouteReference reference)
-
Constructor Details
-
ProcessBulkUpdateRequestNotificationAutoConfiguration
public ProcessBulkUpdateRequestNotificationAutoConfiguration()
-
-
Method Details
-
processBulkUpdateRequestMessageFactory
@Bean @ConditionalOnMissingBean(name="processBulkUpdateRequestMessageFactory") public com.broadleafcommerce.common.messaging.notification.MessageFactory<ProcessBulkUpdateRequest> processBulkUpdateRequestMessageFactory(com.broadleafcommerce.data.tracking.core.mapping.DomainMapperManager manager) -
processBulkUpdateRequestNotificationHandler
@Bean @ConditionalOnMissingBean(name="processBulkUpdateRequestNotificationHandler") public com.broadleafcommerce.common.messaging.notification.NotificationHandler processBulkUpdateRequestNotificationHandler(ProcessBulkUpdateRequestProducer producer, ProcessBulkUpdateRequestNotificationProperties properties, List<com.broadleafcommerce.common.messaging.notification.IgnoredNotificationStateRepository> ignoredRepositories, @Qualifier("processBulkUpdateRequestMessageFactory") com.broadleafcommerce.common.messaging.notification.MessageFactory<ProcessBulkUpdateRequest> messageFactory, com.broadleafcommerce.common.messaging.notification.MessageSerializationHelper helper) -
processBulkUpdateRequestRetryClusterService
@Bean @ConditionalOnMissingBean(name="processBulkUpdateRequestRetryClusterService") public com.broadleafcommerce.common.messaging.notification.RetryClusterService processBulkUpdateRequestRetryClusterService(org.apache.camel.cluster.CamelClusterService camelClusterService, ProcessBulkUpdateRequestNotificationProperties properties, BulkUpdateRepository<?> repository, @Qualifier("processBulkUpdateRequestNotificationHandler") com.broadleafcommerce.common.messaging.notification.NotificationHandler handler, List<com.broadleafcommerce.common.messaging.notification.IgnoredNotificationStateRepository> ignoredRepositories, @Nullable com.broadleafcommerce.common.extension.data.DataRouteReference reference) throws Exception - Throws:
Exception
-