Package com.broadleafcommerce.dataimport.messaging.autoconfigure

Class BatchRequestNotificationAutoConfiguration

java.lang.Object

com.broadleafcommerce.dataimport.messaging.autoconfigure.BatchRequestNotificationAutoConfiguration

@Configuration
@EnableConfigurationProperties(BatchRequestNotificationProperties.class)
@ConditionalOnPropertyOrGroup(name="broadleaf.import.import-batch.notification.active",
                              group="broadleaf.basic.messaging.enabled",
                              matchIfMissing=true)
@EnableBinding(BatchRequestProducer.class)
public class BatchRequestNotificationAutoConfiguration
extends Object

Configure the durable notification components for BatchRequestProducer.

Author:

Phillip Verheyden (phillipuniverse)

Constructor Summary

Constructors

Constructor	Description
BatchRequestNotificationAutoConfiguration()

Method Summary

Modifier and Type	Method	Description
BatchRequestProducerErrorHandler	batchRequestErrorHandler(BatchCompletionService completionService, com.fasterxml.jackson.databind.ObjectMapper mapper)
BatchRequestMessageFactory	batchRequestMessageFactory(com.broadleafcommerce.data.tracking.core.mapping.DomainMapperManager manager)
com.broadleafcommerce.common.messaging.notification.NotificationHandler	batchRequestNotificationHandler(BatchRequestProducer producer, BatchRequestNotificationProperties properties, List<com.broadleafcommerce.common.messaging.notification.IgnoredNotificationStateRepository> ignoredRepositories, BatchRequestMessageFactory messageFactory, com.broadleafcommerce.common.messaging.notification.MessageSerializationHelper helper)
com.broadleafcommerce.common.messaging.notification.RetryClusterService	batchRequestRetryClusterService(org.apache.camel.cluster.CamelClusterService camelClusterService, BatchRequestNotificationProperties properties, ImportBatchRepository<?> repository, com.broadleafcommerce.common.messaging.notification.NotificationHandler handler, List<com.broadleafcommerce.common.messaging.notification.IgnoredNotificationStateRepository> ignoredRepositories, com.broadleafcommerce.common.extension.data.DataRouteReference reference)

Methods inherited from class java.lang.Object

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

Constructor Details

BatchRequestNotificationAutoConfiguration

public BatchRequestNotificationAutoConfiguration()

Method Details

batchRequestMessageFactory

@Bean
@ConditionalOnMissingBean
public BatchRequestMessageFactory batchRequestMessageFactory(com.broadleafcommerce.data.tracking.core.mapping.DomainMapperManager manager)

batchRequestNotificationHandler

@Bean
@ConditionalOnMissingBean(name="batchRequestNotificationHandler")
public com.broadleafcommerce.common.messaging.notification.NotificationHandler batchRequestNotificationHandler(BatchRequestProducer producer,
 BatchRequestNotificationProperties properties,
 List<com.broadleafcommerce.common.messaging.notification.IgnoredNotificationStateRepository> ignoredRepositories,
 BatchRequestMessageFactory messageFactory,
 com.broadleafcommerce.common.messaging.notification.MessageSerializationHelper helper)

batchRequestRetryClusterService

@Bean
@ConditionalOnMissingBean(name="batchRequestRetryClusterService")
public com.broadleafcommerce.common.messaging.notification.RetryClusterService batchRequestRetryClusterService(org.apache.camel.cluster.CamelClusterService camelClusterService,
 BatchRequestNotificationProperties properties,
 ImportBatchRepository<?> repository,
 @Qualifier("batchRequestNotificationHandler")
 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

batchRequestErrorHandler

@Bean
@ConditionalOnMissingBean
public BatchRequestProducerErrorHandler batchRequestErrorHandler(BatchCompletionService completionService,
 com.fasterxml.jackson.databind.ObjectMapper mapper)