Class RetryServiceFactory
java.lang.Object
com.broadleafcommerce.common.messaging.notification.RetryServiceFactory
Factory for constructing new
RetryClusterService
instances.- Author:
- Jeff Fischer
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionstatic RetryClusterService
create
(org.apache.camel.cluster.CamelClusterService camelClusterService, DurableNotificationProperties properties, List<NotificationStateRepository> repositories, NotificationHandler handler, String messageType, List<IgnoredNotificationStateRepository> ignoredRepositories, com.broadleafcommerce.common.extension.data.DataRouteReference reference) Create a newRetryClusterService
instancestatic RetryClusterService
create
(org.apache.camel.cluster.CamelClusterService camelClusterService, DurableNotificationProperties properties, List<NotificationStateRepository> repositories, NotificationHandler handler, String messageType, List<IgnoredNotificationStateRepository> ignoredRepositories, com.broadleafcommerce.common.extension.data.DataRouteReference reference, List<Consumer<RetryHandlerStatus>> consumers)
-
Constructor Details
-
RetryServiceFactory
public RetryServiceFactory()
-
-
Method Details
-
create
public static RetryClusterService create(org.apache.camel.cluster.CamelClusterService camelClusterService, DurableNotificationProperties properties, List<NotificationStateRepository> repositories, NotificationHandler handler, String messageType, List<IgnoredNotificationStateRepository> ignoredRepositories, com.broadleafcommerce.common.extension.data.DataRouteReference reference) throws Exception Create a newRetryClusterService
instance- Parameters:
camelClusterService
- The camel cluster instance controlling cluster service behaviorproperties
- The properties governing the configuration forRetryHandler
instancesrepositories
- AllNotificationStateRepository
instances recognized by the systemhandler
- TheNotificationHandler
instance that is associated with the messageTypemessageType
- The type of message being handledignoredRepositories
- Any repositories that should be ignored and not included in handling- Returns:
- The cluster singleton component controlling retry behavior
- Throws:
Exception
- Any problem with setting up the cluster singleton
-
create
public static RetryClusterService create(org.apache.camel.cluster.CamelClusterService camelClusterService, DurableNotificationProperties properties, List<NotificationStateRepository> repositories, NotificationHandler handler, String messageType, List<IgnoredNotificationStateRepository> ignoredRepositories, com.broadleafcommerce.common.extension.data.DataRouteReference reference, @Nullable List<Consumer<RetryHandlerStatus>> consumers) throws Exception - Throws:
Exception
-