本文整理汇总了Java中org.kie.api.runtime.StatelessKieSession类的典型用法代码示例。如果您正苦于以下问题:Java StatelessKieSession类的具体用法?Java StatelessKieSession怎么用?Java StatelessKieSession使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
StatelessKieSession类属于org.kie.api.runtime包,在下文中一共展示了StatelessKieSession类的20个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: determineWorkgroups
import org.kie.api.runtime.StatelessKieSession; //导入依赖的package包/类
@SuppressWarnings("unchecked")
public List<String> determineWorkgroups(TaskTemplate taskTemplate, TaskInstance taskInstance) throws StrategyException {
KieBase knowledgeBase = getKnowledgeBase();
StatelessKieSession knowledgeSession = knowledgeBase.newStatelessKieSession();
List<Object> facts = new ArrayList<Object>();
facts.add(getParameters());
knowledgeSession.setGlobal("taskTemplate", taskTemplate);
knowledgeSession.setGlobal("taskInstance", taskInstance);
knowledgeSession.setGlobal("now", new Date());
knowledgeSession.execute(CommandFactory.newInsertElements(facts));
return taskInstance.getWorkgroups();
}
开发者ID:CenturyLinkCloud,项目名称:mdw-demo,代码行数:17,代码来源:RulesBasedRoutingStrategy.java
示例2: determineDueDate
import org.kie.api.runtime.StatelessKieSession; //导入依赖的package包/类
@Override
@SuppressWarnings("unchecked")
public Date determineDueDate(TaskTemplate taskTemplate) throws StrategyException {
TaskInstance taskInstanceVO = new TaskInstance(); // for holding values
// execute rules only once (results are stored in taskInstanceVO)
KieBase knowledgeBase = getKnowledgeBase();
StatelessKieSession knowledgeSession = knowledgeBase.newStatelessKieSession();
List<Object> facts = new ArrayList<Object>();
facts.add(getParameters());
knowledgeSession.setGlobal("taskTemplate", taskTemplate);
knowledgeSession.setGlobal("taskInstance", taskInstanceVO);
knowledgeSession.execute(CommandFactory.newInsertElements(facts));
return Date.from(taskInstanceVO.getDue());
}
开发者ID:CenturyLinkCloud,项目名称:mdw-demo,代码行数:20,代码来源:RulesBasedPrioritizationStrategy.java
示例3: recommendMeal
import org.kie.api.runtime.StatelessKieSession; //导入依赖的package包/类
@Override
public Meal recommendMeal(Person person) throws BusinessException {
StatelessKieSession kieSession = kContainer.newStatelessKieSession();
InsertObjectCommand insertObjectCommand = new InsertObjectCommand(person);
FireAllRulesCommand fireAllRulesCommand = new FireAllRulesCommand();
QueryCommand queryCommand = new QueryCommand("results", "getMeal", (Object[]) null);
List<GenericCommand<?>> commands = new ArrayList<GenericCommand<?>>();
commands.add(insertObjectCommand);
commands.add(fireAllRulesCommand);
commands.add(queryCommand);
BatchExecutionCommand batch = new BatchExecutionCommandImpl(commands);
ExecutionResults results = kieSession.execute(batch);
QueryResults queryResults = (QueryResults) results.getValue("results");
Iterator<QueryResultsRow> iterator = queryResults.iterator();
while (iterator.hasNext()) {
Meal meal = (Meal) iterator.next().get("$m");
if (meal != null) {
System.out.println("Meal : " + meal);
return meal;
}
}
return null;
}
开发者ID:Salaboy,项目名称:drools-workshop,代码行数:27,代码来源:FoodRecommendationServiceImpl.java
示例4: execute
import org.kie.api.runtime.StatelessKieSession; //导入依赖的package包/类
@SuppressWarnings("unchecked")
@Override
public Object execute(Asset rulesAsset, Operand input) throws ExecutionException {
ClassLoader cloudClassLoader = null;
if (input.getContext() != null && input.getContext().getPackage() != null)
cloudClassLoader = input.getContext().getPackage().getCloudClassLoader();
if (cloudClassLoader == null) // fall back to rules asset pkg classloader
cloudClassLoader = PackageCache.getPackage(rulesAsset.getPackageName()).getCloudClassLoader();
KnowledgeBaseAsset kbAsset = DroolsKnowledgeBaseCache
.getKnowledgeBaseAsset(rulesAsset.getName(), null, null, cloudClassLoader);
if (kbAsset == null) {
throw new ExecutionException("Cannot load KnowledgeBase asset: "
+ rulesAsset.getPackageName() + "/" + rulesAsset.getLabel());
}
KieBase knowledgeBase = kbAsset.getKnowledgeBase();
StatelessKieSession kSession = knowledgeBase.newStatelessKieSession();
List<Object> facts = new ArrayList<Object>();
if (input.getInput() != null) {
facts.add(input.getInput()); // direct access
if (input.getInput() instanceof Jsonable)
facts.add(((Jsonable)input.getInput()).getJson());
}
kSession.setGlobal("operand", input);
kSession.execute(CommandFactory.newInsertElements(facts));
return input.getResult();
}
开发者ID:CenturyLinkCloud,项目名称:mdw-demo,代码行数:33,代码来源:DroolsExecutor.java
示例5: getSubTaskPlan
import org.kie.api.runtime.StatelessKieSession; //导入依赖的package包/类
@SuppressWarnings("unchecked")
public String getSubTaskPlan(TaskRuntimeContext masterTaskContext) throws StrategyException {
TaskInstance masterTaskInstance = masterTaskContext.getTaskInstance();
KieBase knowledgeBase = getKnowledgeBase();
StatelessKieSession knowledgeSession = knowledgeBase.newStatelessKieSession();
List<Object> facts = new ArrayList<Object>();
facts.add(getParameters());
knowledgeSession.setGlobal("masterTaskInstance", masterTaskInstance);
SubTaskPlan subTaskPlan = new SubTaskPlan();
knowledgeSession.setGlobal("subTaskPlan", subTaskPlan);
knowledgeSession.setGlobal("now", new Date());
knowledgeSession.execute(CommandFactory.newInsertElements(facts));
try {
String planXml = marshalJaxb(subTaskPlan);
if (logger.isDebugEnabled()) {
logger.debug("SubTask plan XML: " + planXml);
}
return planXml;
}
catch (Exception ex) {
throw new StrategyException(ex.getMessage(), ex);
}
}
开发者ID:CenturyLinkCloud,项目名称:mdw-demo,代码行数:28,代码来源:RulesBasedSubTaskStrategy.java
示例6: RuleServlet
import org.kie.api.runtime.StatelessKieSession; //导入依赖的package包/类
public RuleServlet() {
Inspector inspector = new Inspector();
KieServices kieServices = KieServices.Factory.get();
// returns default session
StatelessKieSession kieSession = kieServices.getKieClasspathContainer().newStatelessKieSession();
KieBase kieBase = kieSession.getKieBase();
this.rules = inspector.inspectBase(kieBase);
}
开发者ID:jSquirrel,项目名称:nutforms,代码行数:9,代码来源:RuleServlet.java
示例7: getStatelessKieSessionFromResource
import org.kie.api.runtime.StatelessKieSession; //导入依赖的package包/类
private StatelessKieSession getStatelessKieSessionFromResource(Resource resource) {
KieServices ks = KieServices.Factory.get();
KieFileSystem kfs = ks.newKieFileSystem();
kfs.write(resource);
KieBuilder kieBuilder = ks.newKieBuilder(kfs).buildAll();
List<Message> errors = kieBuilder.getResults().getMessages(Message.Level.ERROR);
if (!errors.isEmpty()) {
fail("" + errors);
}
return ks.newKieContainer(ks.getRepository().getDefaultReleaseId()).newStatelessKieSession();
}
开发者ID:jboss-integration,项目名称:fuse-bxms-integ,代码行数:16,代码来源:XStreamBatchExecutionTest.java
示例8: getStatelessKieSessionFromResource
import org.kie.api.runtime.StatelessKieSession; //导入依赖的package包/类
private StatelessKieSession getStatelessKieSessionFromResource(Resource resource) throws Exception {
KieServices ks = KieServices.Factory.get();
KieFileSystem kfs = ks.newKieFileSystem();
kfs.write(resource);
KieBuilder kieBuilder = ks.newKieBuilder(kfs).buildAll();
List<Message> errors = kieBuilder.getResults().getMessages(Message.Level.ERROR);
if (!errors.isEmpty()) {
fail("" + errors);
}
return ks.newKieContainer(ks.getRepository().getDefaultReleaseId()).newStatelessKieSession();
}
开发者ID:jboss-integration,项目名称:fuse-bxms-integ,代码行数:16,代码来源:BatchTest.java
示例9: testManualFireAllRules
import org.kie.api.runtime.StatelessKieSession; //导入依赖的package包/类
@Test
public void testManualFireAllRules() throws Exception {
String str = "";
str += "package org.kie \n";
str += "import org.kie.camel.testdomain.Cheese \n";
str += "global java.util.List list1 \n";
str += "rule rule1 \n";
str += " when \n";
str += " $c : Cheese() \n";
str += " \n";
str += " then \n";
str += " $c.setPrice( $c.getPrice() + 5 ); \n";
str += " list1.add( $c );";
str += "end\n";
StatelessKieSession ksession = getStatelessKieSession(ResourceFactory.newByteArrayResource(str.getBytes()));
setExec(ksession);
String outXml = execContent("testManualFireAllRules.in.1");
ExecutionResults result = unmarshalOutXml(outXml, ExecutionResults.class);
assertXMLEqual(getContent("testManualFireAllRules.expected.1", ((FactHandle)result.getFactHandle("outBrie")).toExternalForm()), outXml);
// brie should not have been added to the list
List list = (List)result.getValue("list1");
Cheese stilton25 = new Cheese("stilton", 30);
Cheese stilton30 = new Cheese("stilton", 35);
Set expectedList = new HashSet();
expectedList.add(stilton25);
expectedList.add(stilton30);
assertEquals(expectedList, new HashSet(list));
// brie should not have changed
Cheese brie10 = new Cheese("brie", 10);
brie10.setOldPrice(5);
assertEquals(brie10, result.getValue("outBrie"));
}
开发者ID:jboss-integration,项目名称:fuse-bxms-integ,代码行数:41,代码来源:BatchTest.java
示例10: execute
import org.kie.api.runtime.StatelessKieSession; //导入依赖的package包/类
@Override
@SuppressWarnings("unchecked")
public void execute() throws ActivityException {
String knowledgeBaseName = null;
String knowledgeBaseVersion = null;
try {
knowledgeBaseName = getAttributeValueSmart(KNOWLEDGE_BASE);
knowledgeBaseVersion = getAttributeValueSmart(KNOWLEDGE_BASE_ASSET_VERSION);
}
catch (PropertyException ex) {
throw new ActivityException(ex.getMessage(), ex);
}
if (StringHelper.isEmpty(knowledgeBaseName))
throw new ActivityException("Missing attribute: " + KNOWLEDGE_BASE);
KieBase knowledgeBase = getKnowledgeBase(knowledgeBaseName, knowledgeBaseVersion);
if (knowledgeBase == null)
throw new ActivityException("Cannot load KnowledgeBase: " + knowledgeBaseName);
// TODO stateful session option
StatelessKieSession kSession = knowledgeBase.newStatelessKieSession();
List<Object> facts = new ArrayList<Object>();
Map<String,Object> values = new HashMap<String,Object>();
for (VariableInstance variableInstance : getParameters()) {
Object value = getVariableValue(variableInstance.getName());
values.put(variableInstance.getName(), value);
}
facts.add(values);
setGlobalValues(kSession);
kSession.execute(CommandFactory.newInsertElements(facts));
String temp = getAttributeValue(OUTPUTDOCS);
setOutputDocuments(temp == null ? new String[0] : StringHelper.parseList(temp).toArray(new String[0]));
// TODO handle document variables
Process processVO = getProcessDefinition();
for (Variable variable : processVO.getVariables()) {
Object newValue = values.get(variable.getName());
if (newValue != null)
setVariableValue(variable.getName(), variable.getType(), newValue);
}
}
开发者ID:CenturyLinkCloud,项目名称:mdw-demo,代码行数:49,代码来源:DroolsActivity.java
示例11: setGlobalValues
import org.kie.api.runtime.StatelessKieSession; //导入依赖的package包/类
protected void setGlobalValues(StatelessKieSession knowledgeSession) throws ActivityException {
knowledgeSession.setGlobal("activity", this); // TODO deprecate
knowledgeSession.setGlobal("runtimeContext", getRuntimeContext());
knowledgeSession.setGlobal("now", new Date());
}
开发者ID:CenturyLinkCloud,项目名称:mdw-demo,代码行数:6,代码来源:DroolsActivity.java
示例12: getStatelessKnowledgeSession
import org.kie.api.runtime.StatelessKieSession; //导入依赖的package包/类
public static StatelessKieSession getStatelessKnowledgeSession(KieContainer kieContainer, String sessionName) {
StatelessKieSession kSession = kieContainer.newStatelessKieSession(sessionName);
return kSession;
}
开发者ID:nheron,项目名称:droolscourse,代码行数:6,代码来源:KnowledgeSessionHelper.java
示例13: getStatelessKnowledgeSession
import org.kie.api.runtime.StatelessKieSession; //导入依赖的package包/类
public static StatelessKieSession getStatelessKnowledgeSession(KieContainer kieContainer, String sessionName) {
StatelessKieSession kSession = kieContainer.newStatelessKieSession(sessionName);
return kSession;
}
开发者ID:nheron,项目名称:droolscourse,代码行数:6,代码来源:KnowledgeSessionHelper.java
示例14: createStatelessSessionSingleRuleFile
import org.kie.api.runtime.StatelessKieSession; //导入依赖的package包/类
private DroolsSession<?> createStatelessSessionSingleRuleFile() {
StatelessKieSession statelessKieSession = kieBase.newStatelessKieSession();
return new DroolsStatelessSession(statelessKieSession);
}
开发者ID:jeichler,项目名称:junit-drools,代码行数:5,代码来源:DroolsTestSupport.java
示例15: DroolsStatelessSession
import org.kie.api.runtime.StatelessKieSession; //导入依赖的package包/类
public DroolsStatelessSession(StatelessKieSession statelessKieSession) {
this.kSession = statelessKieSession;
}
开发者ID:jeichler,项目名称:junit-drools,代码行数:4,代码来源:DroolsStatelessSession.java
示例16: setKsession
import org.kie.api.runtime.StatelessKieSession; //导入依赖的package包/类
/**
* @param ksession the ksession to set
*/
public void setKsession(StatelessKieSession ksession) {
this.ksession = ksession;
}
开发者ID:apache,项目名称:servicemix,代码行数:7,代码来源:SimpleRuleBean.java
示例17: newStatelessKieSession
import org.kie.api.runtime.StatelessKieSession; //导入依赖的package包/类
@Override
public StatelessKieSession newStatelessKieSession() {
return kieContainer.newStatelessKieSession();
}
开发者ID:deepu105,项目名称:drools-demo,代码行数:5,代码来源:DefaultKieContainerBean.java
示例18: testInsertElements
import org.kie.api.runtime.StatelessKieSession; //导入依赖的package包/类
@Test
public void testInsertElements() throws Exception {
String str = "";
str += "package org.drools \n";
str += "import org.kie.camel.testdomain.Cheese \n";
str += "global java.util.List list \n";
str += "rule rule1 \n";
str += " when \n";
str += " $c : Cheese() \n";
str += " \n";
str += " then \n";
str += " $c.setPrice( $c.getPrice() + 5 ); \n";
str += " list.add( $c );";
str += "end\n";
String inXml = "";
inXml += "<batch-execution>";
inXml += " <set-global identifier='list' out-identifier='list' return-objects='true'>";
inXml += " <list/>";
inXml += " </set-global>";
inXml += " <insert-elements>";
inXml += " <org.kie.camel.testdomain.Cheese>";
inXml += " <type>stilton</type>";
inXml += " <price>25</price>";
inXml += " <oldPrice>0</oldPrice>";
inXml += " </org.kie.camel.testdomain.Cheese>";
inXml += " <org.kie.camel.testdomain.Cheese>";
inXml += " <type>stilton</type>";
inXml += " <price>30</price>";
inXml += " <oldPrice>0</oldPrice>";
inXml += " </org.kie.camel.testdomain.Cheese>";
inXml += " </insert-elements>";
inXml += "</batch-execution>";
StatelessKieSession ksession = getStatelessKieSession(ResourceFactory.newByteArrayResource(str.getBytes()));
setExec(ksession);
String outXml = template.requestBody("direct:exec", inXml, String.class);
String expectedXml = "";
expectedXml += "<execution-results>\n";
expectedXml += " <result identifier='list'>\n";
expectedXml += " <list>\n";
expectedXml += " <org.kie.camel.testdomain.Cheese>\n";
expectedXml += " <type>stilton</type>\n";
expectedXml += " <price>35</price>\n";
expectedXml += " <oldPrice>0</oldPrice>\n";
expectedXml += " </org.kie.camel.testdomain.Cheese>\n";
expectedXml += " <org.kie.camel.testdomain.Cheese>\n";
expectedXml += " <type>stilton</type>\n";
expectedXml += " <price>30</price>\n";
expectedXml += " <oldPrice>0</oldPrice>\n";
expectedXml += " </org.kie.camel.testdomain.Cheese>\n";
expectedXml += " </list>\n";
expectedXml += " </result>\n";
expectedXml += "</execution-results>\n";
assertXMLEqual(expectedXml, outXml);
ExecutionResults result = template.requestBody("direct:unmarshal", outXml, ExecutionResults.class);
List list = (List)result.getValue("list");
Cheese stilton25 = new Cheese("stilton", 30);
Cheese stilton30 = new Cheese("stilton", 35);
Set expectedList = new HashSet();
expectedList.add(stilton25);
expectedList.add(stilton30);
assertEquals(expectedList, new HashSet(list));
}
开发者ID:jboss-integration,项目名称:fuse-bxms-integ,代码行数:72,代码来源:XStreamBatchExecutionTest.java
示例19: testSetGlobal
import org.kie.api.runtime.StatelessKieSession; //导入依赖的package包/类
@Test
public void testSetGlobal() throws Exception {
String str = "";
str += "package org.drools \n";
str += "import org.kie.camel.testdomain.Cheese \n";
str += "global java.util.List list1 \n";
str += "global java.util.List list2 \n";
str += "global java.util.List list3 \n";
str += "rule rule1 \n";
str += " when \n";
str += " $c : Cheese() \n";
str += " \n";
str += " then \n";
str += " $c.setPrice( 30 ); \n";
str += " list1.add( $c ); \n";
str += " list2.add( $c ); \n";
str += " list3.add( $c ); \n";
str += "end\n";
String inXml = "";
inXml += "<batch-execution>";
inXml += " <set-global identifier='list1'>";
inXml += " <list/>";
inXml += " </set-global>";
inXml += " <set-global identifier='list2' out-identifier='list2'>";
inXml += " <list/>";
inXml += " </set-global>";
inXml += " <set-global identifier='list3' out-identifier='outList3'>";
inXml += " <list/>";
inXml += " </set-global>";
inXml += " <insert>";
inXml += " <org.kie.camel.testdomain.Cheese>";
inXml += " <type>stilton</type>";
inXml += " <price>5</price>";
inXml += " <oldPrice>0</oldPrice>";
inXml += " </org.kie.camel.testdomain.Cheese>";
inXml += " </insert>";
inXml += "</batch-execution>";
StatelessKieSession ksession = getStatelessKieSession(ResourceFactory.newByteArrayResource(str.getBytes()));
setExec(ksession);
String outXml = template.requestBody("direct:exec", inXml, String.class);
String expectedXml = "";
expectedXml += "<execution-results>\n";
expectedXml += " <result identifier='list2'>\n";
expectedXml += " <list>\n";
expectedXml += " <org.kie.camel.testdomain.Cheese>\n";
expectedXml += " <type>stilton</type>\n";
expectedXml += " <price>30</price>\n";
expectedXml += " <oldPrice>0</oldPrice>\n";
expectedXml += " </org.kie.camel.testdomain.Cheese>\n";
expectedXml += " </list>\n";
expectedXml += " </result>\n";
expectedXml += " <result identifier='outList3'>\n";
expectedXml += " <list>\n";
expectedXml += " <org.kie.camel.testdomain.Cheese reference='../../../result/list/org.kie.camel.testdomain.Cheese'/>\n";
expectedXml += " </list>\n";
expectedXml += " </result>\n";
expectedXml += "</execution-results>\n";
assertXMLEqual(expectedXml, outXml);
ExecutionResults result = (ExecutionResults)BatchExecutionHelper.newXStreamMarshaller().fromXML(outXml);
Cheese stilton = new Cheese("stilton", 30);
assertNull(result.getValue("list1"));
List list2 = (List)result.getValue("list2");
assertEquals(1, list2.size());
assertEquals(stilton, list2.get(0));
List list3 = (List)result.getValue("outList3");
assertEquals(1, list3.size());
assertEquals(stilton, list3.get(0));
}
开发者ID:jboss-integration,项目名称:fuse-bxms-integ,代码行数:78,代码来源:XStreamBatchExecutionTest.java
示例20: testGetGlobal
import org.kie.api.runtime.StatelessKieSession; //导入依赖的package包/类
@Test
public void testGetGlobal() throws Exception {
String str = "";
str += "package org.drools \n";
str += "import org.kie.camel.testdomain.Cheese \n";
str += "global java.util.List list \n";
str += "rule rule1 \n";
str += " when \n";
str += " $c : Cheese() \n";
str += " \n";
str += " then \n";
str += " list.add( $c ); \n";
str += "end\n";
String inXml = "";
inXml += "<batch-execution>";
inXml += " <set-global identifier='list'>";
inXml += " <list/>";
inXml += " </set-global>";
inXml += " <insert>";
inXml += " <org.kie.camel.testdomain.Cheese>";
inXml += " <type>stilton</type>";
inXml += " <price>25</price>";
inXml += " <oldPrice>0</oldPrice>";
inXml += " </org.kie.camel.testdomain.Cheese>";
inXml += " </insert>";
inXml += " <get-global identifier='list' out-identifier='out-list'/>";
inXml += "</batch-execution>";
StatelessKieSession ksession = getStatelessKieSession(ResourceFactory.newByteArrayResource(str.getBytes()));
setExec(ksession);
String outXml = template.requestBody("direct:exec", inXml, String.class);
String expectedXml = "";
expectedXml += "<execution-results>\n";
expectedXml += " <result identifier=\"out-list\">\n";
expectedXml += " <list>\n";
expectedXml += " <org.kie.camel.testdomain.Cheese>\n";
expectedXml += " <type>stilton</type>\n";
expectedXml += " <price>25</price>\n";
expectedXml += " <oldPrice>0</oldPrice>\n";
expectedXml += " </org.kie.camel.testdomain.Cheese>\n";
expectedXml += " </list>\n";
expectedXml += " </result>\n";
expectedXml += "</execution-results>\n";
assertXMLEqual(expectedXml, outXml);
}
开发者ID:jboss-integration,项目名称:fuse-bxms-integ,代码行数:50,代码来源:XStreamBatchExecutionTest.java
注:本文中的org.kie.api.runtime.StatelessKieSession类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论