public class InMemoryExecutorStoreService extends Object implements org.kie.internal.executor.api.ExecutorStoreService
Constructor and Description |
---|
InMemoryExecutorStoreService(boolean active) |
Modifier and Type | Method and Description |
---|---|
Runnable |
buildExecutorRunnable() |
org.kie.internal.executor.api.ErrorInfo |
findError(Long id) |
org.kie.internal.executor.api.RequestInfo |
findRequest(Long id) |
org.kie.internal.executor.api.RequestInfo |
getAndLockFirst() |
Map<Long,org.kie.internal.executor.api.ErrorInfo> |
getErrors() |
Map<Long,org.kie.internal.executor.api.RequestInfo> |
getProcessedRequests() |
Map<Long,org.kie.internal.executor.api.RequestInfo> |
getRequests() |
void |
persistError(org.kie.internal.executor.api.ErrorInfo error) |
void |
persistRequest(org.kie.internal.executor.api.RequestInfo request) |
org.kie.internal.executor.api.ErrorInfo |
removeError(Long errorId) |
org.kie.internal.executor.api.RequestInfo |
removeRequest(Long requestId) |
protected void |
setId(Object object,
Long id) |
void |
updateError(org.kie.internal.executor.api.ErrorInfo error) |
void |
updateRequest(org.kie.internal.executor.api.RequestInfo request) |
public void persistRequest(org.kie.internal.executor.api.RequestInfo request)
persistRequest
in interface org.kie.internal.executor.api.ExecutorStoreService
public void updateRequest(org.kie.internal.executor.api.RequestInfo request)
updateRequest
in interface org.kie.internal.executor.api.ExecutorStoreService
public org.kie.internal.executor.api.RequestInfo removeRequest(Long requestId)
removeRequest
in interface org.kie.internal.executor.api.ExecutorStoreService
public org.kie.internal.executor.api.RequestInfo findRequest(Long id)
findRequest
in interface org.kie.internal.executor.api.ExecutorStoreService
public void persistError(org.kie.internal.executor.api.ErrorInfo error)
persistError
in interface org.kie.internal.executor.api.ExecutorStoreService
public void updateError(org.kie.internal.executor.api.ErrorInfo error)
updateError
in interface org.kie.internal.executor.api.ExecutorStoreService
public org.kie.internal.executor.api.ErrorInfo removeError(Long errorId)
removeError
in interface org.kie.internal.executor.api.ExecutorStoreService
public org.kie.internal.executor.api.ErrorInfo findError(Long id)
findError
in interface org.kie.internal.executor.api.ExecutorStoreService
public Runnable buildExecutorRunnable()
buildExecutorRunnable
in interface org.kie.internal.executor.api.ExecutorStoreService
public org.kie.internal.executor.api.RequestInfo getAndLockFirst()
public Map<Long,org.kie.internal.executor.api.RequestInfo> getProcessedRequests()
Copyright © 2001-2015 JBoss by Red Hat. All Rights Reserved.