public class ExecutorServiceBase extends Object
Modifier and Type | Field and Description |
---|---|
static org.slf4j.Logger |
logger |
Constructor and Description |
---|
ExecutorServiceBase(org.kie.api.executor.ExecutorService executorService,
KieServerRegistry context) |
Modifier and Type | Method and Description |
---|---|
protected org.kie.api.runtime.query.QueryContext |
buildQueryContext(Integer page,
Integer pageSize) |
void |
cancelRequest(long requestId) |
protected org.kie.server.api.model.instance.RequestInfoInstance |
convertToRequestInfo(org.kie.api.executor.RequestInfo request,
boolean withErrors,
boolean withData) |
protected org.kie.server.api.model.instance.RequestInfoInstanceList |
convertToRequestInfoList(List<org.kie.api.executor.RequestInfo> requests,
boolean withErrors,
boolean withData) |
String |
getRequestById(long requestId,
boolean withErrors,
boolean withData,
String marshallingType) |
org.kie.server.api.model.instance.RequestInfoInstanceList |
getRequestsByBusinessKey(String businessKey,
Integer page,
Integer pageSize) |
org.kie.server.api.model.instance.RequestInfoInstanceList |
getRequestsByCommand(String command,
Integer page,
Integer pageSize) |
org.kie.server.api.model.instance.RequestInfoInstanceList |
getRequestsByStatus(List<String> statuses,
Integer page,
Integer pageSize) |
protected Map<String,Object> |
readContent(byte[] data,
ClassLoader classLoader) |
void |
requeueRequest(long requestId) |
String |
scheduleRequest(String containerId,
String payload,
String marshallingType) |
public ExecutorServiceBase(org.kie.api.executor.ExecutorService executorService, KieServerRegistry context)
public String scheduleRequest(String containerId, String payload, String marshallingType)
public void cancelRequest(long requestId)
public void requeueRequest(long requestId)
public org.kie.server.api.model.instance.RequestInfoInstanceList getRequestsByStatus(List<String> statuses, Integer page, Integer pageSize)
public org.kie.server.api.model.instance.RequestInfoInstanceList getRequestsByBusinessKey(String businessKey, Integer page, Integer pageSize)
public org.kie.server.api.model.instance.RequestInfoInstanceList getRequestsByCommand(String command, Integer page, Integer pageSize)
public String getRequestById(long requestId, boolean withErrors, boolean withData, String marshallingType)
protected org.kie.server.api.model.instance.RequestInfoInstanceList convertToRequestInfoList(List<org.kie.api.executor.RequestInfo> requests, boolean withErrors, boolean withData)
protected org.kie.server.api.model.instance.RequestInfoInstance convertToRequestInfo(org.kie.api.executor.RequestInfo request, boolean withErrors, boolean withData)
protected Map<String,Object> readContent(byte[] data, ClassLoader classLoader)
Copyright © 2001–2018 JBoss by Red Hat. All rights reserved.