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)

Methods inherited from class java.lang.Object

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

Constructor Detail

PersistenceNotificationAutoConfiguration

public PersistenceNotificationAutoConfiguration()

Method Detail

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