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 RetryClusterServicecreate(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 newRetryClusterServiceinstancestatic RetryClusterServicecreate(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 newRetryClusterServiceinstance- Parameters:
camelClusterService- The camel cluster instance controlling cluster service behaviorproperties- The properties governing the configuration forRetryHandlerinstancesrepositories- AllNotificationStateRepositoryinstances recognized by the systemhandler- TheNotificationHandlerinstance 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
-