Java KnowledgeBuilder类代码示例

OGeek|极客世界-中国程序员成长平台 › 门户 › 编程› Java›Java编程经验

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了Java中org.kie.internal.builder.KnowledgeBuilder类的典型用法代码示例。如果您正苦于以下问题：Java KnowledgeBuilder类的具体用法？Java KnowledgeBuilder怎么用？Java KnowledgeBuilder使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

KnowledgeBuilder类属于org.kie.internal.builder包，在下文中一共展示了KnowledgeBuilder类的20个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: loadDrools

import org.kie.internal.builder.KnowledgeBuilder; //导入依赖的package包/类
private void loadDrools() {
	try {
		logger.info("Initializing Drools rule engine");
		KnowledgeBuilder kbuilder = KnowledgeBuilderFactory.newKnowledgeBuilder();

		addDrls(kbuilder);

		KieSessionConfiguration config = KieServices.Factory.get().newKieSessionConfiguration();
		config.setOption(ClockTypeOption.get("pseudo"));

		logger.debug("Compiling rules");
		kSession = kbuilder.newKieBase().newKieSession(config, null);
		homeioSessionClock = new HomeioSessionClock(kSession.getSessionClock());

		initGlobals();

		droolsInitialized = true;

		logger.debug("Successfully initialized Drools rule engine");

	} catch (Exception e) {
		logger.error("Exiting because of an exception during the Drools initialization ", e);
		new RuntimeException("Exiting because of an exception during the Drools initialization");
	}
}

开发者ID:IncQueryLabs，项目名称:smarthome-cep-demonstrator，代码行数:26，代码来源:DroolsEventBusClient.java

示例2: loadDrools

import org.kie.internal.builder.KnowledgeBuilder; //导入依赖的package包/类
private void loadDrools() {
	try {
		logger.info("Initializing Drools rule engine");
		KnowledgeBuilder kbuilder = KnowledgeBuilderFactory.newKnowledgeBuilder();

		addDrls(kbuilder);

		logger.debug("Compiling rules");
		kSession = kbuilder.newKieBase().newKieSession();
		initGlobals();

		droolsInitialized = true;

		logger.info("Successfully initialized Drools rule engine");

	} catch (Exception e) {
		logger.error("Exiting because of an exception during the Drools initialization ", e);
		new RuntimeException("Exiting because of an exception during the Drools initialization");
	}
}

开发者ID:IncQueryLabs，项目名称:smarthome-cep-demonstrator，代码行数:21，代码来源:DroolsEventBusClient.java

示例3: addRule

import org.kie.internal.builder.KnowledgeBuilder; //导入依赖的package包/类
/**
 * 单一规则上线
 *
 * @param packageName
 * @param ruleName
 */
public void addRule(String packageName, String ruleName) {
    KnowledgeBuilder kbuilder = KnowledgeBuilderFactory.newKnowledgeBuilder();
    kbuilder.add(ResourceFactory.newClassPathResource(packageName + "/" + ruleName + ".drl"), ResourceType.DRL);
    if (kbuilder.hasErrors()) {
        logger.error("Unable to compile drl. " + packageName + ruleName + ".drl");
        return;
    } else {
        if (kbase.getRule(packageName, ruleName) != null) {
            logger.info("update rule: " + packageName + "." + ruleName);
        } else {
            logger.info("add rule: " + packageName + "." + ruleName);
        }
    }

    kbase.addKnowledgePackages(kbuilder.getKnowledgePackages());
    kieSession = kbase.newStatelessKieSession();
    setGlobal();
    printRules();
}

开发者ID:ysrc，项目名称:Liudao，代码行数:26，代码来源:KieService.java

示例4: testCallService

import org.kie.internal.builder.KnowledgeBuilder; //导入依赖的package包/类
@Test
public void testCallService() throws Exception {
    final Holder holder = new Holder();
    serviceDomain.registerService(new QName("CallService"), new InOnlyService(), new BaseHandler(){
        public void handleMessage(Exchange exchange) throws HandlerException {
            holder.setValue("message handled");
        }
    });
    serviceDomain.registerServiceReference(new QName("CallService"), new InOnlyService());
    KnowledgeBuilder kbuilder = KnowledgeBuilderFactory.newKnowledgeBuilder();
    kbuilder.add(ResourceFactory.newClassPathResource(CALL_SERVICE_BPMN), ResourceType.BPMN2);
    KieBase kbase = kbuilder.newKnowledgeBase();
    KieSession ksession = kbase.newKieSession();
    SwitchYardServiceTaskHandler ssth = new SwitchYardServiceTaskHandler();
    ssth.setProcessRuntime(ksession);
    ssth.setInvoker(new SwitchYardServiceInvoker(serviceDomain));
    ksession.getWorkItemManager().registerWorkItemHandler(SWITCHYARD_SERVICE_TASK, ssth);
    ksession.startProcess("CallService");
    ksession.halt();
    ksession.dispose();
    Assert.assertEquals("message handled", holder.getValue());
}

开发者ID:jboss-switchyard，项目名称:switchyard，代码行数:23，代码来源:BPMServiceTests.java

示例5: runFaultBoundaryProcess

import org.kie.internal.builder.KnowledgeBuilder; //导入依赖的package包/类
private void runFaultBoundaryProcess(final boolean bomb) throws Exception {
    serviceDomain.registerService(new QName("TestService"), new InOnlyService(), new BaseHandler(){
        public void handleMessage(Exchange exchange) throws HandlerException {
            if (bomb) {
                throw new HandlerException("BOOM!");
            }
        }
    });
    serviceDomain.registerServiceReference(new QName("TestService"), new InOutService());
    KnowledgeBuilder kbuilder = KnowledgeBuilderFactory.newKnowledgeBuilder();
    kbuilder.add(ResourceFactory.newClassPathResource(FAULT_BOUNDARY_PROCESS_BPMN), ResourceType.BPMN2);
    KieBase kbase = kbuilder.newKnowledgeBase();
    KieSession ksession = kbase.newKieSession();
    SwitchYardServiceTaskHandler ssth = new SwitchYardServiceTaskHandler();
    ssth.setProcessRuntime(ksession);
    ssth.setInvoker(new SwitchYardServiceInvoker(serviceDomain));
    ksession.getWorkItemManager().registerWorkItemHandler(SWITCHYARD_SERVICE_TASK, ssth);
    WorkflowProcessInstance wpi = (WorkflowProcessInstance)ksession.startProcess("FaultBoundaryProcess");
    String output = (String)wpi.getVariable("TestOutput");
    Assert.assertEquals(bomb ? "Failure" : "Success", output);
    ksession.halt();
    ksession.dispose();
}

开发者ID:jboss-switchyard，项目名称:switchyard，代码行数:24，代码来源:BPMServiceTests.java

示例6: testCallService

import org.kie.internal.builder.KnowledgeBuilder; //导入依赖的package包/类
@Test
public void testCallService() throws Exception {
    final Holder holder = new Holder();
    serviceDomain.registerService(new QName("CallService"), new InOnlyService(), new BaseHandler() {
        public void handleMessage(Exchange exchange) throws HandlerException {
            holder.setValue("message handled");
        }
    });
    serviceDomain.registerServiceReference(new QName("CallService"), new InOnlyService());
    KnowledgeBuilder kbuilder = KnowledgeBuilderFactory.newKnowledgeBuilder();
    kbuilder.add(ResourceFactory.newClassPathResource(CALL_SERVICE_BPMN), ResourceType.BPMN2);
    KieBase kbase = kbuilder.newKnowledgeBase();
    KieSession ksession = kbase.newKieSession();
    SwitchYardServiceTaskHandler ssth = new SwitchYardServiceTaskHandler();
    ssth.setProcessRuntime(ksession);
    ssth.setInvoker(new SwitchYardServiceInvoker(serviceDomain));
    ksession.getWorkItemManager().registerWorkItemHandler(SWITCHYARD_SERVICE_TASK, ssth);
    ksession.startProcess("CallService");
    ksession.halt();
    ksession.dispose();
    Assert.assertEquals("message handled", holder.getValue());
}

开发者ID:jboss-integration，项目名称:fuse-bxms-integ，代码行数:23，代码来源:BPMServiceTests.java

示例7: runFaultBoundaryProcess

import org.kie.internal.builder.KnowledgeBuilder; //导入依赖的package包/类
private void runFaultBoundaryProcess(final boolean bomb) throws Exception {
    serviceDomain.registerService(new QName("TestService"), new InOnlyService(), new BaseHandler() {
        public void handleMessage(Exchange exchange) throws HandlerException {
            if (bomb) {
                throw new HandlerException("BOOM!");
            }
        }
    });
    serviceDomain.registerServiceReference(new QName("TestService"), new InOutService());
    KnowledgeBuilder kbuilder = KnowledgeBuilderFactory.newKnowledgeBuilder();
    kbuilder.add(ResourceFactory.newClassPathResource(FAULT_BOUNDARY_PROCESS_BPMN), ResourceType.BPMN2);
    KieBase kbase = kbuilder.newKnowledgeBase();
    KieSession ksession = kbase.newKieSession();
    SwitchYardServiceTaskHandler ssth = new SwitchYardServiceTaskHandler();
    ssth.setProcessRuntime(ksession);
    ssth.setInvoker(new SwitchYardServiceInvoker(serviceDomain));
    ksession.getWorkItemManager().registerWorkItemHandler(SWITCHYARD_SERVICE_TASK, ssth);
    WorkflowProcessInstance wpi = (WorkflowProcessInstance)ksession.startProcess("FaultBoundaryProcess");
    String output = (String)wpi.getVariable("TestOutput");
    Assert.assertEquals(bomb ? "Failure" : "Success", output);
    ksession.halt();
    ksession.dispose();
}

开发者ID:jboss-integration，项目名称:fuse-bxms-integ，代码行数:24，代码来源:BPMServiceTests.java

示例8: addPackage

import org.kie.internal.builder.KnowledgeBuilder; //导入依赖的package包/类
/**
 * 规则集上线
 *
 * @param packageName
 */
public void addPackage(String packageName) {
    try {
        File path = new File(this.getClass().getClassLoader().getResource(packageName).toURI().getPath());
        if (path.isDirectory()) {
            KnowledgeBuilder kbuilder = KnowledgeBuilderFactory.newKnowledgeBuilder();
            File[] files = path.listFiles();
            for (File file : files) {
                if (file.getName().endsWith(".drl")) {
                    kbuilder.add(ResourceFactory.newClassPathResource(packageName + "/" + file.getName()), ResourceType.DRL);
                    if (kbuilder.hasErrors()) {
                        logger.error("Unable to compile drl. " + packageName + file.getName());
                        return;
                    } else {
                        String ruleName = file.getName().replace(".drl", "");
                        if (kbase.getRule(packageName, ruleName) != null) {
                            logger.info("update rule: " + packageName + "." + ruleName);
                        } else {
                            logger.info("add rule: " + packageName + "." + ruleName);
                        }
                    }
                }
            }

            kbase.addKnowledgePackages(kbuilder.getKnowledgePackages());
            kieSession = kbase.newStatelessKieSession();
            setGlobal();
            printRules();
        }
    } catch (URISyntaxException e) {
        e.printStackTrace();
    }
}

开发者ID:ysrc，项目名称:Liudao，代码行数:38，代码来源:KieService.java

示例9: runFaultResultProcess

import org.kie.internal.builder.KnowledgeBuilder; //导入依赖的package包/类
private void runFaultResultProcess(final boolean bomb) throws Exception {
    serviceDomain.registerService(new QName("TestService"), new InOnlyService(), new BaseHandler(){
        public void handleMessage(Exchange exchange) throws HandlerException {
            if (bomb) {
                throw new HandlerException("BOOM!");
            }
        }
    });
    serviceDomain.registerServiceReference(new QName("TestService"), new InOutService());
    KnowledgeBuilder kbuilder = KnowledgeBuilderFactory.newKnowledgeBuilder();
    kbuilder.add(ResourceFactory.newClassPathResource(FAULT_RESULT_PROCESS_BPMN), ResourceType.BPMN2);
    KieBase kbase = kbuilder.newKnowledgeBase();
    KieSession ksession = kbase.newKieSession();
    SwitchYardServiceTaskHandler ssth = new SwitchYardServiceTaskHandler();
    ssth.setProcessRuntime(ksession);
    ssth.setInvoker(new SwitchYardServiceInvoker(serviceDomain));
    ksession.getWorkItemManager().registerWorkItemHandler(SWITCHYARD_SERVICE_TASK, ssth);
    WorkflowProcessInstance wpi = (WorkflowProcessInstance)ksession.startProcess("FaultResultProcess");
    HandlerException he = (HandlerException)wpi.getVariable("faultResult");
    if (bomb) {
        Assert.assertNotNull(he);
        Assert.assertEquals("BOOM!", he.getMessage());
    } else {
        Assert.assertNull(he);
    }
    ksession.halt();
    ksession.dispose();
}

开发者ID:jboss-switchyard，项目名称:switchyard，代码行数:29，代码来源:BPMServiceTests.java

示例10: runFaultEventProcess

import org.kie.internal.builder.KnowledgeBuilder; //导入依赖的package包/类
private void runFaultEventProcess(final boolean bomb) throws Exception {
    serviceDomain.registerService(new QName("TestService"), new InOnlyService(), new BaseHandler(){
        public void handleMessage(Exchange exchange) throws HandlerException {
            if (bomb) {
                throw new HandlerException("BOOM!");
            }
        }
    });
    serviceDomain.registerServiceReference(new QName("TestService"), new InOutService());
    KnowledgeBuilder kbuilder = KnowledgeBuilderFactory.newKnowledgeBuilder();
    kbuilder.add(ResourceFactory.newClassPathResource(FAULT_EVENT_PROCESS_BPMN), ResourceType.BPMN2);
    KieBase kbase = kbuilder.newKnowledgeBase();
    KieSession ksession = kbase.newKieSession();
    SwitchYardServiceTaskHandler ssth = new SwitchYardServiceTaskHandler();
    ssth.setProcessRuntime(ksession);
    ssth.setInvoker(new SwitchYardServiceInvoker(serviceDomain));
    ksession.getWorkItemManager().registerWorkItemHandler(SWITCHYARD_SERVICE_TASK, ssth);
    WorkflowProcessInstance wpi = (WorkflowProcessInstance)ksession.startProcess("FaultEventProcess");
    HandlerException he = (HandlerException)wpi.getVariable("faultEvent");
    if (bomb) {
        Assert.assertNotNull(he);
        Assert.assertEquals("BOOM!", he.getMessage());
    } else {
        Assert.assertNull(he);
    }
    ksession.halt();
    ksession.dispose();
}

开发者ID:jboss-switchyard，项目名称:switchyard，代码行数:29，代码来源:BPMServiceTests.java

示例11: getDistributeSimplifyKnowledgeBase

import org.kie.internal.builder.KnowledgeBuilder; //导入依赖的package包/类
/**
 * Returns Drools ( <A href="http://drools.org">http://drools.org</A> ) knowledge base for algebraic simplification.
 * 
 * @return Drools ( <A href="http://drools.org">http://drools.org</A> ) knowledge base for algebraic simplification.
 */
public static KnowledgeBase getDistributeSimplifyKnowledgeBase()
{
	if( distributeSimplifyKnowledgeBase == null )
	{
		OptimizerFactory.setDefaultOptimizer( OptimizerFactory.SAFE_REFLECTIVE );
		
		KnowledgeBuilder builder = KnowledgeBuilderFactory.newKnowledgeBuilder();
		
		// Load in the reng support as a separate cross-cutting concern.
		builder.add( ResourceFactory.newClassPathResource( "reng.drl" )  , 
				ResourceType.DRL );
		
		builder.add( ResourceFactory.newClassPathResource( "distributeSimplify.drl" )  , 
				ResourceType.DRL );
		
		if( LoggingConfiguration.LOGGING_ON )
		{
			builder.add( ResourceFactory.newClassPathResource( "logging.drl" )  , 
					ResourceType.DRL );
		}
		
		if( builder.hasErrors() )
		{
			throw( new RuntimeException( builder.getErrors().toString() ) );
		}
		distributeSimplifyKnowledgeBase = KnowledgeBaseFactory.newKnowledgeBase();
		distributeSimplifyKnowledgeBase.addKnowledgePackages( builder.getKnowledgePackages() );
	}
	
	return( distributeSimplifyKnowledgeBase );
}

开发者ID:viridian1138，项目名称:SimpleAlgebra_V2，代码行数:37，代码来源:Elem.java

示例12: getDistributeSimplify2KnowledgeBase

import org.kie.internal.builder.KnowledgeBuilder; //导入依赖的package包/类
/**
 * Returns Drools ( <A href="http://drools.org">http://drools.org</A> ) knowledge base for algebraic simplification.
 * 
 * @return Drools ( <A href="http://drools.org">http://drools.org</A> ) knowledge base for algebraic simplification.
 */
public static KnowledgeBase getDistributeSimplify2KnowledgeBase()
{
	if( distributeSimplify2KnowledgeBase == null )
	{
		OptimizerFactory.setDefaultOptimizer( OptimizerFactory.SAFE_REFLECTIVE );
		
		KnowledgeBuilder builder = KnowledgeBuilderFactory.newKnowledgeBuilder();
		
		// Load in the reng support as a separate cross-cutting concern.
		builder.add( ResourceFactory.newClassPathResource( "reng.drl" )  , 
				ResourceType.DRL );
		
		builder.add( ResourceFactory.newClassPathResource( "distributeSimplify2.drl" )  , 
				ResourceType.DRL );
		
		if( LoggingConfiguration.LOGGING_ON )
		{
			builder.add( ResourceFactory.newClassPathResource( "logging.drl" )  , 
					ResourceType.DRL );
		}
		
		if( builder.hasErrors() )
		{
			throw( new RuntimeException( builder.getErrors().toString() ) );
		}
		distributeSimplify2KnowledgeBase = KnowledgeBaseFactory.newKnowledgeBase();
		distributeSimplify2KnowledgeBase.addKnowledgePackages( builder.getKnowledgePackages() );
	}
	
	return( distributeSimplify2KnowledgeBase );
}

开发者ID:viridian1138，项目名称:SimpleAlgebra_V2，代码行数:37，代码来源:Elem.java

示例13: runFaultResultProcess

import org.kie.internal.builder.KnowledgeBuilder; //导入依赖的package包/类
private void runFaultResultProcess(final boolean bomb) throws Exception {
    serviceDomain.registerService(new QName("TestService"), new InOnlyService(), new BaseHandler() {
        public void handleMessage(Exchange exchange) throws HandlerException {
            if (bomb) {
                throw new HandlerException("BOOM!");
            }
        }
    });
    serviceDomain.registerServiceReference(new QName("TestService"), new InOutService());
    KnowledgeBuilder kbuilder = KnowledgeBuilderFactory.newKnowledgeBuilder();
    kbuilder.add(ResourceFactory.newClassPathResource(FAULT_RESULT_PROCESS_BPMN), ResourceType.BPMN2);
    KieBase kbase = kbuilder.newKnowledgeBase();
    KieSession ksession = kbase.newKieSession();
    SwitchYardServiceTaskHandler ssth = new SwitchYardServiceTaskHandler();
    ssth.setProcessRuntime(ksession);
    ssth.setInvoker(new SwitchYardServiceInvoker(serviceDomain));
    ksession.getWorkItemManager().registerWorkItemHandler(SWITCHYARD_SERVICE_TASK, ssth);
    WorkflowProcessInstance wpi = (WorkflowProcessInstance)ksession.startProcess("FaultResultProcess");
    HandlerException he = (HandlerException)wpi.getVariable("faultResult");
    if (bomb) {
        Assert.assertNotNull(he);
        Assert.assertEquals("BOOM!", he.getMessage());
    } else {
        Assert.assertNull(he);
    }
    ksession.halt();
    ksession.dispose();
}

开发者ID:jboss-integration，项目名称:fuse-bxms-integ，代码行数:29，代码来源:BPMServiceTests.java

示例14: runFaultEventProcess

import org.kie.internal.builder.KnowledgeBuilder; //导入依赖的package包/类
private void runFaultEventProcess(final boolean bomb) throws Exception {
    serviceDomain.registerService(new QName("TestService"), new InOnlyService(), new BaseHandler() {
        public void handleMessage(Exchange exchange) throws HandlerException {
            if (bomb) {
                throw new HandlerException("BOOM!");
            }
        }
    });
    serviceDomain.registerServiceReference(new QName("TestService"), new InOutService());
    KnowledgeBuilder kbuilder = KnowledgeBuilderFactory.newKnowledgeBuilder();
    kbuilder.add(ResourceFactory.newClassPathResource(FAULT_EVENT_PROCESS_BPMN), ResourceType.BPMN2);
    KieBase kbase = kbuilder.newKnowledgeBase();
    KieSession ksession = kbase.newKieSession();
    SwitchYardServiceTaskHandler ssth = new SwitchYardServiceTaskHandler();
    ssth.setProcessRuntime(ksession);
    ssth.setInvoker(new SwitchYardServiceInvoker(serviceDomain));
    ksession.getWorkItemManager().registerWorkItemHandler(SWITCHYARD_SERVICE_TASK, ssth);
    WorkflowProcessInstance wpi = (WorkflowProcessInstance)ksession.startProcess("FaultEventProcess");
    HandlerException he = (HandlerException)wpi.getVariable("faultEvent");
    if (bomb) {
        Assert.assertNotNull(he);
        Assert.assertEquals("BOOM!", he.getMessage());
    } else {
        Assert.assertNull(he);
    }
    ksession.halt();
    ksession.dispose();
}

开发者ID:jboss-integration，项目名称:fuse-bxms-integ，代码行数:29，代码来源:BPMServiceTests.java

示例15: main

import org.kie.internal.builder.KnowledgeBuilder; //导入依赖的package包/类
public static void main(String[] args) {
	//rule,rule2可以放在数据库中，有个唯一code和他们对于，代码要执行规则的时候，根据code从数据库获取出来就OK了，这样自己开发的规则管理系统那边对数据库里的规则进行维护就行了
	String rule = "package com.neo.drools\r\n";
	rule += "import com.neo.drools.model.Message;\r\n";
	rule += "rule \"rule1\"\r\n";
	rule += "\twhen\r\n";
	rule += "Message( status == 1, myMessage : msg )";
	rule += "\tthen\r\n";
	rule += "\t\tSystem.out.println( 1+\":\"+myMessage );\r\n";
	rule += "end\r\n";


	String rule2 = "package com.neo.drools\r\n";
	rule += "import com.neo.drools.model.Message;\r\n";

	rule += "rule \"rule2\"\r\n";
	rule += "\twhen\r\n";
	rule += "Message( status == 2, myMessage : msg )";
	rule += "\tthen\r\n";
	rule += "\t\tSystem.out.println( 2+\":\"+myMessage );\r\n";
	rule += "end\r\n";


	StatefulKnowledgeSession kSession = null;
	try {


		KnowledgeBuilder kb = KnowledgeBuilderFactory.newKnowledgeBuilder();
		//装入规则，可以装入多个
		kb.add(ResourceFactory.newByteArrayResource(rule.getBytes("utf-8")), ResourceType.DRL);
		kb.add(ResourceFactory.newByteArrayResource(rule2.getBytes("utf-8")), ResourceType.DRL);

		KnowledgeBuilderErrors errors = kb.getErrors();
		for (KnowledgeBuilderError error : errors) {
			System.out.println(error);
		}
		KnowledgeBase kBase = KnowledgeBaseFactory.newKnowledgeBase();
		kBase.addKnowledgePackages(kb.getKnowledgePackages());

		kSession = kBase.newStatefulKnowledgeSession();


		Message message1 = new Message();
		message1.setStatus(1);
		message1.setMsg("hello world!");

		Message message2 = new Message();
		message2.setStatus(2);
		message2.setMsg("hi world!");

		kSession.insert(message1);
		kSession.insert(message2);
		kSession.fireAllRules();

	} catch (UnsupportedEncodingException e) {
		e.printStackTrace();
	} finally {
		if (kSession != null)
			kSession.dispose();
	}

}

开发者ID:ityouknow，项目名称:drools-examples，代码行数:63，代码来源:DdLoadTest.java

示例16: loadKnowledgePackages

import org.kie.internal.builder.KnowledgeBuilder; //导入依赖的package包/类
private final Collection<KnowledgePackage> loadKnowledgePackages(EnumSet<ExtraEvaluators> extraEvaluators, File... kbFiles) throws RuntimeException, IOException
{
	HashMap<Resource, ResourceType> resources = new HashMap<Resource, ResourceType>();
	for (File f : kbFiles)
	{
		resources.put(ResourceFactory.newFileResource(f), ResourceType.DRL);
	}
	Properties props = new Properties();
	if (drools_dialect_java_compiler != null)
	{
		props.setProperty("drools.dialect.java.compiler", drools_dialect_java_compiler);
	}
	KnowledgeBuilderConfiguration builderConfig = KnowledgeBuilderFactory.newKnowledgeBuilderConfiguration(props, (ClassLoader) null);

	if (extraEvaluators.contains(ExtraEvaluators.IS_KIND_OF))
	{
		builderConfig.setOption(EvaluatorOption.get(IsKindOfEvaluatorDefinition.IS_KIND_OF.getOperatorString(), new IsKindOfEvaluatorDefinition()));
	}
	if (extraEvaluators.contains(ExtraEvaluators.SAFISFIES_CONSTRAINT))
	{
		builderConfig.setOption(EvaluatorOption.get(SatisfiesConstraintEvaluatorDefinition.SATISFIES_CONSTRAINT.getOperatorString(),
				new SatisfiesConstraintEvaluatorDefinition()));
	}
	if (extraEvaluators.contains(ExtraEvaluators.IS_MEMBER_OF))
	{
		builderConfig.setOption(EvaluatorOption.get(IsMemberOfEvaluatorDefinition.IS_MEMBER_OF.getOperatorString(), new IsMemberOfEvaluatorDefinition()));
	}
	if (extraEvaluators.contains(ExtraEvaluators.IS_MEMBER_OF_WITH_TYPE))
	{
		builderConfig.setOption(EvaluatorOption.get(IsMemberOfWithTypeEvaluatorDefinition.IS_MEMBER_OF_WITH_TYPE.getOperatorString(),
				new IsMemberOfWithTypeEvaluatorDefinition()));
	}
	if (extraEvaluators.contains(ExtraEvaluators.IS_PARENT_MEMBER_OF))
	{
		builderConfig.setOption(EvaluatorOption.get(IsParentMemberOfEvaluatorDefinition.IS_PARENT_MEMBER_OF.getOperatorString(),
				new IsParentMemberOfEvaluatorDefinition()));
	}
	if (extraEvaluators.contains(ExtraEvaluators.IS_MISSING_DESC_FOR))
	{
		builderConfig.setOption(EvaluatorOption.get(IsMissingDescForDialectEvaluatorDefinition.IS_MISSING_DESC_FOR.getOperatorString(),
				new IsMissingDescForDialectEvaluatorDefinition()));
	}

	if (extraEvaluators.contains(ExtraEvaluators.IS_GB_MEMBER_TYPE_OF))
	{
		builderConfig.setOption(EvaluatorOption.get(IsGbMemberTypeOfEvaluatorDefinition.IS_GB_MEMBER_TYPE_OF.getOperatorString(),
				new IsGbMemberTypeOfEvaluatorDefinition()));
	}

	if (extraEvaluators.contains(ExtraEvaluators.IS_US_MEMBER_TYPE_OF))
	{
		builderConfig.setOption(EvaluatorOption.get(IsUsMemberTypeOfEvaluatorDefinition.IS_US_MEMBER_TYPE_OF.getOperatorString(),
				new IsUsMemberTypeOfEvaluatorDefinition()));
	}

	if (extraEvaluators.contains(ExtraEvaluators.IS_SYNONYM_MEMBER_TYPE_OF))
	{
		builderConfig.setOption(EvaluatorOption.get(IsSynonymMemberTypeOfEvaluatorDefinition.IS_SYNONYM_MEMBER_TYPE_OF.getOperatorString(),
				new IsSynonymMemberTypeOfEvaluatorDefinition()));
	}

	KnowledgeBuilder kbuilder = KnowledgeBuilderFactory.newKnowledgeBuilder(kbase_, builderConfig);
	for (Resource resource : resources.keySet())
	{
		synchronized (this)
		{
			kbuilder.add(resource, resources.get(resource));
		}
	}
	if (kbuilder.hasErrors())
	{
		throw new RuntimeException(kbuilder.getErrors().toString());
	}

	return kbuilder.getKnowledgePackages();
}

开发者ID:Apelon-VA，项目名称:ISAAC，代码行数:77，代码来源:DroolsExecutor.java

示例17: processDaqHg

import org.kie.internal.builder.KnowledgeBuilder; //导入依赖的package包/类
/**
 * Executes a DaqHg (Drools As a Query language for HyperGraphDB) query.
 * 
 * @param drlPath The path to the Drools query description.
 * @param context The context for the query execution.
 * @param resultHandler The handler for the query results.
 */
public void processDaqHg( String drlPath , 
		DaqHgContext<T> context , DaqHgResultHandler<T> resultHandler )
{
	OptimizerFactory.setDefaultOptimizer( OptimizerFactory.SAFE_REFLECTIVE );
	
	KnowledgeBuilder builder = KnowledgeBuilderFactory.newKnowledgeBuilder();
	
	builder.add( ResourceFactory.newClassPathResource( drlPath )  , 
			ResourceType.DRL );
	
	KnowledgeBase knowledgeBase = KnowledgeBaseFactory.newKnowledgeBase();
	knowledgeBase.addKnowledgePackages( builder.getKnowledgePackages() );
	
	StatefulKnowledgeSession session = knowledgeBase.newStatefulKnowledgeSession();
	
	context.setResultHandler( resultHandler );
	
	session.insert( context );
			
	session.fireAllRules();

	session.dispose();
	
}

开发者ID:viridian1138，项目名称:SimpleAlgebra_V2，代码行数:32，代码来源:DaqHg.java

示例18: setUp

import org.kie.internal.builder.KnowledgeBuilder; //导入依赖的package包/类
@Before
public void setUp() throws Exception {
    KnowledgeBuilder kbuilder = KnowledgeBuilderFactory.newKnowledgeBuilder();
    ksession = kbuilder.newKnowledgeBase().newStatefulKnowledgeSession();
    initializeTemplate(ksession);
}

开发者ID:jboss-integration，项目名称:fuse-bxms-integ，代码行数:7，代码来源:JaxbInsertTest.java

示例19: buildProcessDefinition

import org.kie.internal.builder.KnowledgeBuilder; //导入依赖的package包/类
private List<BpmnProcessDataEventListener> buildProcessDefinition(String bpmn2Content,
                                                                  ClassLoader moduleClassLoader) throws IllegalArgumentException {
    if (StringUtils.isEmpty(bpmn2Content)) {
        return Collections.<BpmnProcessDataEventListener>emptyList();
    }

    // Set class loader
    KnowledgeBuilder kbuilder = null;
    if (moduleClassLoader != null) {
        KnowledgeBuilderConfigurationImpl pconf = new KnowledgeBuilderConfigurationImpl(moduleClassLoader);
        kbuilder = KnowledgeBuilderFactory.newKnowledgeBuilder(pconf);
    } else {
        kbuilder = KnowledgeBuilderFactory.newKnowledgeBuilder();
    }

    // Build
    kbuilder.add(new ByteArrayResource(bpmn2Content.getBytes()),
                 ResourceType.BPMN2);
    if (kbuilder.hasErrors()) {
        for (KnowledgeBuilderError error : kbuilder.getErrors()) {
            logger.error("Error: {}",
                         error.getMessage());
        }
        logger.debug("Process Cannot be Parsed! \n {} \n",
                     bpmn2Content);
        return Collections.<BpmnProcessDataEventListener>emptyList();
    }

    // Retrieve ProcessInfoHolder
    List<BpmnProcessDataEventListener> processDataList = new ArrayList<>();
    kbuilder.getKnowledgePackages().forEach(
            pkg ->
                    pkg.getProcesses().forEach(
                            p -> {
                                BpmnProcessDataEventListener processData
                                        = (BpmnProcessDataEventListener) p.getMetaData().get(BpmnProcessDataEventListener.NAME);
                                processDataList.add(processData);
                            })
    );
    return processDataList;
}

开发者ID:kiegroup，项目名称:kie-wb-common，代码行数:42，代码来源:BpmnFileIndexer.java

示例20: testSort

import org.kie.internal.builder.KnowledgeBuilder; //导入依赖的package包/类
/**
 * Verifies that Drools ( <A href="http://drools.org">http://drools.org</A> ) constructs a sorting algorithm from a set of heuristics.
 * Note: this is only intended to be notional, and one should use something different when efficient execution is desired.
 */
public void testSort()
{
	
	OptimizerFactory.setDefaultOptimizer( OptimizerFactory.SAFE_REFLECTIVE );
	
	KnowledgeBuilder builder = KnowledgeBuilderFactory.newKnowledgeBuilder();
	
	builder.add( ResourceFactory.newClassPathResource( "test_simplealgebra/sort_test/sort.drl" )  , 
			ResourceType.DRL );
	
	KnowledgeBase knowledgeBase = KnowledgeBaseFactory.newKnowledgeBase();
	knowledgeBase.addKnowledgePackages( builder.getKnowledgePackages() );
	
	StatefulKnowledgeSession session = knowledgeBase.newStatefulKnowledgeSession();
	
	session.insert( new DroolsSession( session ) );
	
	final Random rand = new Random( 65432 );
	
	SortNode<DoubleElem> currentSort = null;
	
	for( int count = 0 ; count < 10 ; count++ )
	{
		SortNode<DoubleElem> node = new SortNode<DoubleElem>( new DoubleElem( rand.nextDouble() ) , currentSort );
		currentSort = node;
		session.insert( node );
		session.insert( node.sortValue );
	}
	
	SortPlaceholder<DoubleElem> placeholder = new SortPlaceholder<DoubleElem>( currentSort );
	
	session.insert( placeholder );
			
	session.fireAllRules();

	session.dispose();
	
	SortNode<DoubleElem> prev = null;
	SortNode<DoubleElem> nxt = placeholder.getElem();
	
	while( nxt != null )
	{
		prev = nxt;
		nxt = prev.next;
		
		if( ( prev != null ) && ( nxt != null ) )
		{
			Assert.assertTrue( nxt.sortValue.compareTo( prev.sortValue ) >= 0 );
		}
		
	}
	
	
}

开发者ID:viridian1138，项目名称:SimpleAlgebra_V2，代码行数:59，代码来源:TestSort.java

注：本文中的org.kie.internal.builder.KnowledgeBuilder类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。

鲜花

握手

雷人

路过

鸡蛋

该文章已有0人参与评论

请发表评论

全部评论

专题导读

More+

10-27 六六分期app的软件客服如何联系？(六六分期

11-06 可心卡盟:win10系统火狐flash插件崩溃怎么

11-06 亲亲特价:怎么删除回收站图标

11-06 济南大学虚拟社区:鲁大师节能降温的具体办

11-06 xlueops.exe:无线网络安装向导

11-06 女斗合众国:win7系统cf与主机连接不稳定怎

11-06 0xc000022-[cf烟雾头]cf怎么调烟雾头

11-06 qizideyouhuo:应用程序无法正常启动0xc0000

11-06 ipz-185:win7系统vcf文件怎么打开

11-06 傻哥蹦迪:win10系统s4怎么打开usb调试

11-06 八神浩树gtaste:回收站清空了怎么恢复

11-06 妖尾之黑色守护:win10系统电脑没有1440x900

11-06 校园至尊魔王小说:win7系统浏览网页时字体

11-06 女斗合众国:win10系统访问共享文件夹提示请

11-06 tokyo hot n0654:恢复win7系统默认字体一招

11-06 雨酷仙境:设置win7系统转移临时文件夹腾出

11-06 阿穆纳伊之杖:win7系统开始菜单在右边还原

11-06 tunespotting:win10系统火狐flash插件总是

11-06 甘尔葛分析师：计谋网站seo关键词暴涨有什

11-06 蔡贵霖: 计谋网站seo关键词暴涨有什么秘密

11-06 博益网首页:ao3网页版进入不了解决方法

11-06 漏斗子专栏: 网站数据分析小白易懂精华篇

11-06 见证双虹怎么做:win7系统开启telnet命令的

11-06 颾狐蝶蜋:系统资源不足无法完成请求的服务

11-06 国光中学校歌:提交网站到alexa查询详细步骤

11-06 西安有情天:静态网页和动态网页的区别

11-06 红木雅尚斋:外部链接构造对网站的好处

11-06 前官礼遇：防止域名劫持–增强域安全性的10

11-06 密传二转答案: 中文分词算法有哪些

11-06 金泉家园邮编:百度快照劫持的表现及应对方

Java PDFParserConfig类代码示例发布时间：2022-05-22

Java PathImpl类代码示例发布时间：2022-05-22

剪的笔顺,诠释剪的笔画,认识剪的部首

1 六六分期app的软件客服如何联系？(六六分期

六六分期app的软件客服如何联系？不知道吗？加qq群【895510560】即可！标题：六六分期

阅读：18285|2023-10-27

2 可心卡盟:win10系统火狐flash插件崩溃怎么

今天小编告诉大家如何处理win10系统火狐flash插件总是崩溃的问题，可能很多用户都不知

阅读：9681|2022-11-06

3 亲亲特价:怎么删除回收站图标

今天小编告诉大家如何对win10系统删除桌面回收站图标进行设置，可能很多用户都不知道

阅读：8180|2022-11-06

4 济南大学虚拟社区:鲁大师节能降温的具体办

今天小编告诉大家如何对win10系统电脑设置节能降温的设置方法，想必大家都遇到过需要

阅读：8551|2022-11-06

5 xlueops.exe:无线网络安装向导

我们在使用xp系统的过程中,经常需要对xp系统无线网络安装向导设置进行设置，可能很多

阅读：8458|2022-11-06

6 女斗合众国:win7系统cf与主机连接不稳定怎

今天小编告诉大家如何处理win7系统玩cf老是与主机连接不稳定的问题，可能很多用户都不

阅读：9395|2022-11-06

7 0xc000022-[cf烟雾头]cf怎么调烟雾头

电脑对日常生活的重要性小编就不多说了，可是一旦碰到win7系统设置cf烟雾头的问题，很

阅读：8431|2022-11-06

8 qizideyouhuo:应用程序无法正常启动0xc0000

我们在日常使用电脑的时候，有的小伙伴们可能在打开应用的时候会遇见提示应用程序无法

阅读：7865|2022-11-06

9 ipz-185:win7系统vcf文件怎么打开

今天小编告诉大家如何对win7系统打开vcf文件进行设置，可能很多用户都不知道怎么对win

阅读：8416|2022-11-06

10 傻哥蹦迪:win10系统s4怎么打开usb调试

今天小编告诉大家如何对win10系统s4开启USB调试模式进行设置，可能很多用户都不知道怎

阅读：7394|2022-11-06

客服电话

电子邮件

Java KnowledgeBuilder类代码示例

示例1: loadDrools

示例2: loadDrools

示例3: addRule

示例4: testCallService

示例5: runFaultBoundaryProcess

示例6: testCallService

示例7: runFaultBoundaryProcess

示例8: addPackage

示例9: runFaultResultProcess

示例10: runFaultEventProcess

示例11: getDistributeSimplifyKnowledgeBase

示例12: getDistributeSimplify2KnowledgeBase

示例13: runFaultResultProcess

示例14: runFaultEventProcess

示例15: main

示例16: loadKnowledgePackages

示例17: processDaqHg

示例18: setUp

示例19: buildProcessDefinition

示例20: testSort

请发表评论

全部评论

上一篇：

下一篇：

小程序接入指南

librespeed/speedtest: Self-hosted Speedt

avehtari/BDA_m_demos: Bayesian Data Anal

四维彩超怎么看性别？四维看男孩女孩诀窍

medfreeman/markdown-it-toc-and-anchor: m

剪的笔顺,诠释剪的笔画,认识剪的部首

六六分期app的软件客服如何联系？(六六分期

florent37/ViewAnimator: A fluent Android

florent37/Shrine-MaterialDesign2: implem

CVE-2020-36276

SimpleSoftwareIO/simple-sms: Send and re

关于我们

产品与服务

解决方案

139-2527-9053