Package com.broadleafcommerce.common.messaging.autoconfigure

Class PersistenceNotificationAutoConfiguration

java.lang.Object

com.broadleafcommerce.common.messaging.autoconfigure.PersistenceNotificationAutoConfiguration

@EnableConfigurationProperties(PersistenceNotificationProperties.class)
@EnableBinding(PersistenceProducer.class)
@ConditionalOnPropertyOrGroup(name="broadleaf.persistence.notification.active",
                              group="broadleaf.basic.messaging.enabled",
                              matchIfMissing=true)
@AutoConfigureAfter(DurableNotificationAutoConfiguration.class)
@Configuration
public class PersistenceNotificationAutoConfiguration
extends Object

Configure the durable notification components related to PersistenceProducer

Author:

Jeff Fischer

Constructor Summary

Constructors

Constructor	Description
PersistenceNotificationAutoConfiguration()

Method Summary

Modifier and Type	Method	Description
MessageFactory<PersistenceMessage<Object>>	persistenceMessageFactory()
NotificationHandler	persistenceNotificationHandler(PersistenceProducer persistenceProducer, PersistenceNotificationProperties properties, List<IgnoredNotificationStateRepository> ignoredRepositories, MessageFactory<PersistenceMessage<Object>> messageFactory, MessageSerializationHelper helper, List<PersistenceMessageAckedHandler> persistenceMessageAckedHandlers, com.broadleafcommerce.common.extension.data.DataRouteReference reference)
RetryClusterService	persistenceRetryClusterService(org.apache.camel.cluster.CamelClusterService camelClusterService, PersistenceNotificationProperties properties, List<NotificationStateRepository> repositories, NotificationHandler handler, List<IgnoredNotificationStateRepository> ignoredRepositories, com.broadleafcommerce.common.extension.data.DataRouteReference reference)
org.springframework.context.SmartLifecycle	retryClusterServiceLifecycleManager(List<RetryClusterService> clusterServices)

Methods inherited from class java.lang.Object

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

Constructor Details

PersistenceNotificationAutoConfiguration

public PersistenceNotificationAutoConfiguration()

Method Details

persistenceMessageFactory

@Bean
@ConditionalOnMissingBean(name="persistenceMessageFactory")
public MessageFactory<PersistenceMessage<Object>> persistenceMessageFactory()

persistenceNotificationHandler

@Bean
@ConditionalOnMissingBean(name="persistenceNotificationHandler")
public NotificationHandler persistenceNotificationHandler(PersistenceProducer persistenceProducer,
 PersistenceNotificationProperties properties,
 List<IgnoredNotificationStateRepository> ignoredRepositories,
 @Qualifier("persistenceMessageFactory")
 MessageFactory<PersistenceMessage<Object>> messageFactory,
 MessageSerializationHelper helper,
 @Nullable
 List<PersistenceMessageAckedHandler> persistenceMessageAckedHandlers,
 @Nullable
 com.broadleafcommerce.common.extension.data.DataRouteReference reference)

persistenceRetryClusterService

@Bean
@ConditionalOnMissingBean(name="persistenceRetryClusterService")
public RetryClusterService persistenceRetryClusterService(org.apache.camel.cluster.CamelClusterService camelClusterService,
 PersistenceNotificationProperties properties,
 @Nullable
 List<NotificationStateRepository> repositories,
 @Qualifier("persistenceNotificationHandler")
 NotificationHandler handler,
 List<IgnoredNotificationStateRepository> ignoredRepositories,
 @Nullable
 com.broadleafcommerce.common.extension.data.DataRouteReference reference)
                                                   throws Exception

Throws:

Exception

retryClusterServiceLifecycleManager

@Bean
@ConditionalOnMissingBean(name="retryClusterServiceLifecycleManager")
public org.springframework.context.SmartLifecycle retryClusterServiceLifecycleManager(List<RetryClusterService> clusterServices)