作者:豆豆马捷 | 来源:互联网 | 2023-09-10 15:17
本文整理了Java中org.kie.server.services.api.KieServerExtension.getImplementedCapability()方
本文整理了Java中org.kie.server.services.api.KieServerExtension.getImplementedCapability()
方法的一些代码示例,展示了KieServerExtension.getImplementedCapability()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。KieServerExtension.getImplementedCapability()
方法的具体详情如下:
包路径:org.kie.server.services.api.KieServerExtension
类名称:KieServerExtension
方法名:getImplementedCapability
KieServerExtension.getImplementedCapability介绍
暂无
代码示例
代码示例来源:origin: org.kie.server/kie-server-controller-websocket-client
@Override
public String onMessage(String message) {
CommandScript script = deserialize(message, CommandScript.class);
String capability = TARGET_CAPABILITY;
boolean hasBPMCommand = script.getCommands().stream().anyMatch(cmd -> cmd instanceof DescriptorCommand);
if (hasBPMCommand) {
capability = KieServerConstants.CAPABILITY_BPM;
}
KieContainerCommandService> executor = null;
for (KieServerExtension extension : context.getServerExtensions()) {
KieContainerCommandService> tmp = extension.getAppComponents(KieContainerCommandService.class);
if (tmp != null && extension.getImplementedCapability().equalsIgnoreCase(capability)) {
executor = tmp;
logger.debug("Extension {} returned command executor {} with capability {}", extension, executor, extension.getImplementedCapability());
break;
}
}
if (executor == null) {
throw new IllegalStateException("No executor found for script execution");
}
// 4. process request
ServiceResponsesList respOnse= executor.executeScript(script, MarshallingFormat.JSON, null);
String reply = serialize(response);
return reply;
}
代码示例来源:origin: org.kie.server/kie-server-services-common
protected KieServerInfo getInfoInternal() {
Version version = KieServerEnvironment.getVersion();
String serverId = KieServerEnvironment.getServerId();
String serverName = KieServerEnvironment.getServerName();
String versiOnStr= version != null ? version.toString() : "Unknown-Version";
List capabilities = new ArrayList();
for (KieServerExtension extension : context.getServerExtensions()) {
capabilities.add(extension.getImplementedCapability());
}
return new KieServerInfo(serverId, serverName, versionStr, capabilities, kieServerLocation);
}