Package com.broadleafcommerce.orchestration.service.provider.external

Class ExternalWorkflowProvider

java.lang.Object

com.broadleafcommerce.orchestration.service.provider.external.AbstractExternalProvider

com.broadleafcommerce.orchestration.service.provider.external.ExternalWorkflowProvider

All Implemented Interfaces:

WorkflowProvider

public class ExternalWorkflowProvider
extends AbstractExternalProvider
implements WorkflowProvider

Constructor Summary

Constructors

Constructor	Description
ExternalWorkflowProvider(org.springframework.web.reactive.function.client.WebClient webClient, com.fasterxml.jackson.databind.ObjectMapper mapper, com.broadleafcommerce.common.extension.TypeFactory typeFactory)

Method Summary

Modifier and Type	Method	Description
protected com.fasterxml.jackson.databind.ObjectMapper	getObjectMapper()
protected ExternalWorkflowProviderProperties	getProperties()
protected String	getServiceClient()
protected com.broadleafcommerce.common.extension.TypeFactory	getTypeFactory()
protected String	getUrl()
protected org.springframework.web.reactive.function.client.WebClient	getWebClient()
protected String	getWorkflowUri()
boolean	incompleteExistsByContextValue(String contextValue, com.broadleafcommerce.data.tracking.core.context.ContextInfo contextInfo)	Determine if an active workflow exists for a context value
void	resume(@NonNull String workflowId, @NonNull Map<String,String> additionalWorkflowContext, com.broadleafcommerce.data.tracking.core.context.ContextInfo contextInfo)	Request that the remote workflow service resume a paused or failed workflow execution
void	setObjectMapper(com.fasterxml.jackson.databind.ObjectMapper objectMapper)
void	setProperties(ExternalWorkflowProviderProperties properties)
void	start(WorkflowRequest request)	Request that the remote workflow service start a new workflow execution

Methods inherited from class com.broadleafcommerce.orchestration.service.provider.external.AbstractExternalProvider

getHeaders, getMapper

Methods inherited from class java.lang.Object

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

Constructor Details

ExternalWorkflowProvider

public ExternalWorkflowProvider(@Qualifier("workflowWebClient")
 org.springframework.web.reactive.function.client.WebClient webClient,
 com.fasterxml.jackson.databind.ObjectMapper mapper,
 com.broadleafcommerce.common.extension.TypeFactory typeFactory)

Method Details

start

public void start(WorkflowRequest request)

Description copied from interface: WorkflowProvider

Request that the remote workflow service start a new workflow execution

Specified by:

start in interface WorkflowProvider

Parameters:

request - Request that the remote workflow service start a new workflow execution

resume

public void resume(@NonNull
 @NonNull String workflowId,
 @NonNull
 @NonNull Map<String,String> additionalWorkflowContext,
 @Nullable
 com.broadleafcommerce.data.tracking.core.context.ContextInfo contextInfo)

Description copied from interface: WorkflowProvider

Request that the remote workflow service resume a paused or failed workflow execution

Specified by:

resume in interface WorkflowProvider

Parameters:

workflowId - The id of the workflow to be resumed

additionalWorkflowContext - Additional parameters to add to the workflow's context

contextInfo - Context information about the multi-tenant state.

incompleteExistsByContextValue

public boolean incompleteExistsByContextValue(String contextValue,
 @Nullable
 com.broadleafcommerce.data.tracking.core.context.ContextInfo contextInfo)

Description copied from interface: WorkflowProvider

Determine if an active workflow exists for a context value

Specified by:

incompleteExistsByContextValue in interface WorkflowProvider

Parameters:

contextValue - The context value to check for an active workflow

contextInfo - The context information around multi-tenant state

Returns:

True if the workflow exists, false otherwise

getUrl

protected String getUrl()

getWorkflowUri

protected String getWorkflowUri()

getServiceClient

protected String getServiceClient()

getWebClient

protected org.springframework.web.reactive.function.client.WebClient getWebClient()

getTypeFactory

protected com.broadleafcommerce.common.extension.TypeFactory getTypeFactory()

getProperties

protected ExternalWorkflowProviderProperties getProperties()

setProperties

@Autowired
public void setProperties(ExternalWorkflowProviderProperties properties)

getObjectMapper

protected com.fasterxml.jackson.databind.ObjectMapper getObjectMapper()

setObjectMapper

@Autowired
public void setObjectMapper(com.fasterxml.jackson.databind.ObjectMapper objectMapper)