optimajet.workflow.redis

Class RedisProvider

java.lang.Object

optimajet.workflow.redis.RedisProvider

All Implemented Interfaces:

IWorkflowGenerator<Document>, IPersistenceProvider, ISchemePersistenceProvider<Document>, WorkflowDocumentProvider

public class RedisProvider
extends Object
implements WorkflowDocumentProvider

Constructor Summary

Constructors

Constructor and Description
RedisProvider(redis.clients.jedis.JedisPool jedisPool) Constructor
RedisProvider(redis.clients.jedis.JedisPool jedisPool, String providerNamespace) Constructor

Method Summary

Modifier and Type	Method and Description
void	bindProcessToNewScheme(ProcessInstance processInstance)
void	bindProcessToNewScheme(ProcessInstance processInstance, boolean resetIsDeterminingParametersChanged)
void	clearTimer(UUID timerId)
void	clearTimerIgnore(UUID timerId)
void	clearTimers(UUID processId, Collection<String> timersIgnoreList)
void	clearTimersIgnore()
void	deleteGlobalParameters(String type)
void	deleteGlobalParameters(String type, String name)
void	deleteProcess(UUID processId)
void	deleteProcess(UUID[] processIds)
void	fillPersistedProcessParameters(ProcessInstance processInstance)
void	fillProcessParameters(ProcessInstance processInstance)
void	fillSystemProcessParameters(ProcessInstance processInstance)
Document	generate(String schemeCode, UUID schemeId, Map<String,Object> parameters)
Date	getCloseExecutionDateTime()
ProcessStatus	getInstanceStatus(UUID processId)
List<ProcessHistoryItem>	getProcessHistory(UUID processId)
SchemeDefinition<Document>	getProcessSchemeByProcessId(UUID processId)
SchemeDefinition<Document>	getProcessSchemeBySchemeId(UUID schemeId)
SchemeDefinition<Document>	getProcessSchemeWithParameters(String schemeCode, String definingParameters, UUID rootSchemeId, boolean ignoreObsolete)
Document	getScheme(String code)
List<TimerToExecute>	getTimersToExecute()
void	init(WorkflowRuntime runtime)
void	initializeProcess(ProcessInstance processInstance)
boolean	isProcessExists(UUID processId)
<T> T	loadGlobalParameter(String type, String name, Class<T> cls)
<T> T	loadGlobalParameter(String type, String name, com.fasterxml.jackson.core.type.TypeReference<T> typeReference)
<T> Collection<T>	loadGlobalParameters(String type, Class<T> cls)
void	registerTimer(UUID processId, String name, Date nextExecutionDateTime, boolean notOverrideIfExists)
void	resetWorkflowRunning()
<T> void	saveGlobalParameter(String type, String name, T value)
void	savePersistenceParameters(ProcessInstance processInstance)
void	saveScheme(SchemeDefinition<Document> scheme)
void	saveScheme(String schemaCode, String scheme)
void	setSchemeIsObsolete(String schemeCode)
void	setSchemeIsObsolete(String schemeCode, Map<String,Object> parameters)
void	setWorkflowFinalized(ProcessInstance processInstance)
void	setWorkflowIdled(ProcessInstance processInstance)
void	setWorkflowInitialized(ProcessInstance processInstance)
void	setWorkflowRunning(ProcessInstance processInstance)
void	setWorkflowTerminated(ProcessInstance processInstance, ErrorLevel level, String errorMessage)
void	updatePersistenceState(ProcessInstance processInstance, TransitionDefinition transition)

Methods inherited from class java.lang.Object

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

Constructor Detail

RedisProvider

public RedisProvider(redis.clients.jedis.JedisPool jedisPool)

Constructor

Parameters:

jedisPool - JedisPool instance

RedisProvider

public RedisProvider(redis.clients.jedis.JedisPool jedisPool,
                     String providerNamespace)

Constructor

Parameters:

jedisPool - JedisPool instance

providerNamespace - Namespace

Method Detail

init

public void init(WorkflowRuntime runtime)

Specified by:

init in interface IPersistenceProvider

initializeProcess

public void initializeProcess(ProcessInstance processInstance)

Specified by:

initializeProcess in interface IPersistenceProvider

bindProcessToNewScheme

public void bindProcessToNewScheme(ProcessInstance processInstance)
                            throws ProcessNotFoundException

Specified by:

bindProcessToNewScheme in interface IPersistenceProvider

Throws:

ProcessNotFoundException

bindProcessToNewScheme

public void bindProcessToNewScheme(ProcessInstance processInstance,
                                   boolean resetIsDeterminingParametersChanged)
                            throws ProcessNotFoundException

Specified by:

bindProcessToNewScheme in interface IPersistenceProvider

Throws:

ProcessNotFoundException

fillProcessParameters

public void fillProcessParameters(ProcessInstance processInstance)

Specified by:

fillProcessParameters in interface IPersistenceProvider

fillPersistedProcessParameters

public void fillPersistedProcessParameters(ProcessInstance processInstance)

Specified by:

fillPersistedProcessParameters in interface IPersistenceProvider

fillSystemProcessParameters

public void fillSystemProcessParameters(ProcessInstance processInstance)

Specified by:

fillSystemProcessParameters in interface IPersistenceProvider

savePersistenceParameters

public void savePersistenceParameters(ProcessInstance processInstance)

Specified by:

savePersistenceParameters in interface IPersistenceProvider

setWorkflowInitialized

public void setWorkflowInitialized(ProcessInstance processInstance)

Specified by:

setWorkflowInitialized in interface IPersistenceProvider

setWorkflowIdled

public void setWorkflowIdled(ProcessInstance processInstance)

Specified by:

setWorkflowIdled in interface IPersistenceProvider

setWorkflowRunning

public void setWorkflowRunning(ProcessInstance processInstance)

Specified by:

setWorkflowRunning in interface IPersistenceProvider

setWorkflowFinalized

public void setWorkflowFinalized(ProcessInstance processInstance)

Specified by:

setWorkflowFinalized in interface IPersistenceProvider

setWorkflowTerminated

public void setWorkflowTerminated(ProcessInstance processInstance,
                                  ErrorLevel level,
                                  String errorMessage)

Specified by:

setWorkflowTerminated in interface IPersistenceProvider

resetWorkflowRunning

public void resetWorkflowRunning()

Specified by:

resetWorkflowRunning in interface IPersistenceProvider

updatePersistenceState

public void updatePersistenceState(ProcessInstance processInstance,
                                   TransitionDefinition transition)

Specified by:

updatePersistenceState in interface IPersistenceProvider

isProcessExists

public boolean isProcessExists(UUID processId)

Specified by:

isProcessExists in interface IPersistenceProvider

getInstanceStatus

public ProcessStatus getInstanceStatus(UUID processId)

Specified by:

getInstanceStatus in interface IPersistenceProvider

deleteProcess

public void deleteProcess(UUID[] processIds)

Specified by:

deleteProcess in interface IPersistenceProvider

saveGlobalParameter

public <T> void saveGlobalParameter(String type,
                                    String name,
                                    T value)

Specified by:

saveGlobalParameter in interface IPersistenceProvider

loadGlobalParameter

public <T> T loadGlobalParameter(String type,
                                 String name,
                                 Class<T> cls)

Specified by:

loadGlobalParameter in interface IPersistenceProvider

loadGlobalParameter

public <T> T loadGlobalParameter(String type,
                                 String name,
                                 com.fasterxml.jackson.core.type.TypeReference<T> typeReference)

Specified by:

loadGlobalParameter in interface IPersistenceProvider

loadGlobalParameters

public <T> Collection<T> loadGlobalParameters(String type,
                                              Class<T> cls)

Specified by:

loadGlobalParameters in interface IPersistenceProvider

deleteGlobalParameters

public void deleteGlobalParameters(String type)

Specified by:

deleteGlobalParameters in interface IPersistenceProvider

deleteGlobalParameters

public void deleteGlobalParameters(String type,
                                   String name)

Specified by:

deleteGlobalParameters in interface IPersistenceProvider

deleteProcess

public void deleteProcess(UUID processId)

Specified by:

deleteProcess in interface IPersistenceProvider

registerTimer

public void registerTimer(UUID processId,
                          String name,
                          Date nextExecutionDateTime,
                          boolean notOverrideIfExists)

Specified by:

registerTimer in interface IPersistenceProvider

clearTimers

public void clearTimers(UUID processId,
                        Collection<String> timersIgnoreList)

Specified by:

clearTimers in interface IPersistenceProvider

clearTimersIgnore

public void clearTimersIgnore()

Specified by:

clearTimersIgnore in interface IPersistenceProvider

clearTimerIgnore

public void clearTimerIgnore(UUID timerId)

Specified by:

clearTimerIgnore in interface IPersistenceProvider

clearTimer

public void clearTimer(UUID timerId)

Specified by:

clearTimer in interface IPersistenceProvider

getCloseExecutionDateTime

public Date getCloseExecutionDateTime()

Specified by:

getCloseExecutionDateTime in interface IPersistenceProvider

getTimersToExecute

public List<TimerToExecute> getTimersToExecute()

Specified by:

getTimersToExecute in interface IPersistenceProvider

getProcessHistory

public List<ProcessHistoryItem> getProcessHistory(UUID processId)

Specified by:

getProcessHistory in interface IPersistenceProvider

getProcessSchemeByProcessId

public SchemeDefinition<Document> getProcessSchemeByProcessId(UUID processId)

Specified by:

getProcessSchemeByProcessId in interface ISchemePersistenceProvider<Document>

getProcessSchemeBySchemeId

public SchemeDefinition<Document> getProcessSchemeBySchemeId(UUID schemeId)

Specified by:

getProcessSchemeBySchemeId in interface ISchemePersistenceProvider<Document>

getProcessSchemeWithParameters

public SchemeDefinition<Document> getProcessSchemeWithParameters(String schemeCode,
                                                                 String definingParameters,
                                                                 UUID rootSchemeId,
                                                                 boolean ignoreObsolete)

Specified by:

getProcessSchemeWithParameters in interface ISchemePersistenceProvider<Document>

setSchemeIsObsolete

public void setSchemeIsObsolete(String schemeCode,
                                Map<String,Object> parameters)

Specified by:

setSchemeIsObsolete in interface ISchemePersistenceProvider<Document>

setSchemeIsObsolete

public void setSchemeIsObsolete(String schemeCode)

Specified by:

setSchemeIsObsolete in interface ISchemePersistenceProvider<Document>

saveScheme

public void saveScheme(SchemeDefinition<Document> scheme)

Specified by:

saveScheme in interface ISchemePersistenceProvider<Document>

saveScheme

public void saveScheme(String schemaCode,
                       String scheme)

Specified by:

saveScheme in interface ISchemePersistenceProvider<Document>

getScheme

public Document getScheme(String code)

Specified by:

getScheme in interface ISchemePersistenceProvider<Document>

generate

public Document generate(String schemeCode,
                         UUID schemeId,
                         Map<String,Object> parameters)

Specified by:

generate in interface IWorkflowGenerator<Document>