本文整理汇总了Java中org.kie.api.io.Resource类的典型用法代码示例。如果您正苦于以下问题：Java Resource类的具体用法？Java Resource怎么用？Java Resource使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
Resource类属于org.kie.api.io包，在下文中一共展示了Resource类的20个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: refreshContainer
import org.kie.api.io.Resource; //导入依赖的package包/类
public void refreshContainer(String containerName){
logger.info("refreshing container {}", containerName);
ReleaseId releaseId = new ReleaseIdImpl("org.demo.rule", containerName, "1.0.0-" + UUID.randomUUID().toString().replaceAll("-", ""));
// retrieve rules from db
List<String> rules = ruleBucket.findAll().stream().map((r -> r.getContent())).collect(Collectors.toList());
logger.info("total {} rules for [{}]", rules.size(), ruleBucket);
Resource resource = kieServices.getResources().newByteArrayResource(RuleEngineUtil.createKJar(releaseId, rules));
KieModule module = kieServices.getRepository().addKieModule(resource);
KieContainer kieContainer = kieServices.newKieContainer(module.getReleaseId());
// create container is heavy, we only create once and cache it
containerMap.put(containerName, kieContainer);
// remove the repo immediately
kieServices.getRepository().removeKieModule(module.getReleaseId());
}
开发者ID:barrykalok，项目名称:spring-boot-drools-example，代码行数:21，代码来源:RuleService.java
示例2: buildRelease
import org.kie.api.io.Resource; //导入依赖的package包/类
private static void buildRelease(ReleaseId releaseId, Resource pomResource, Resource kmodule, String... resources) {
if (releases.contains(releaseId)) {
ks.getRepository().removeKieModule(releaseId);
}
KieServices kieServices = KieServices.Factory.get();
KieFileSystem kfs = kieServices.newKieFileSystem();
kfs.write("pom.xml", pomResource);
kfs.write("src/main/resources/META-INF/kmodule.xml", kmodule);
for (String res : resources) {
Resource resource = new ClassPathResource(res);
kfs.write("src/main/resources/" + res, resource);
}
hasErrors(kieServices.newKieBuilder(kfs).buildAll().getResults());
releases.add(releaseId);
}
开发者ID:redhat-italy，项目名称:hacep，代码行数:22，代码来源:KieAPITestUtils.java
示例3: build
import org.kie.api.io.Resource; //导入依赖的package包/类
/**
* Builds a Resource.
* @return a Resource
*/
public Resource build() {
Resource resource = null;
if (_url != null) {
resource = _kieResources.newUrlResource(_url);
if (resource != null) {
if (_resourceType != null) {
resource.setResourceType(_resourceType);
}
if (_resourceConfiguration != null) {
resource.setConfiguration(_resourceConfiguration);
}
}
}
return resource;
}
开发者ID:jboss-switchyard，项目名称:switchyard，代码行数:20，代码来源:ResourceBuilder.java
示例4: build
import org.kie.api.io.Resource; //导入依赖的package包/类
/** Builds a Resource.
*
* @return a Resource */
public Resource build() {
Resource resource = null;
if (_url != null) {
resource = _kieResources.newUrlResource(_url);
if (resource != null) {
if (_resourceType != null) {
resource.setResourceType(_resourceType);
}
if (_resourceConfiguration != null) {
resource.setConfiguration(_resourceConfiguration);
}
}
}
return resource;
}
开发者ID:jboss-integration，项目名称:fuse-bxms-integ，代码行数:19，代码来源:ResourceBuilder.java
示例5: testExecuteUsingKieAPI
import org.kie.api.io.Resource; //导入依赖的package包/类
/**
* Test execute using kie api.
*
* @throws Exception the exception
*/
@Test
public void testExecuteUsingKieAPI() throws Exception {
// get the resource
Resource dt = ResourceFactory.newClassPathResource("/data/IntegrationExampleTest.xls", getClass());
// create the builder
KieSession ksession = getKieSession(dt);
ksession.insert(new Cheese("stilton", 42));
ksession.insert(new Person("michael", "stilton", 42));
final List<String> list = new ArrayList<String>();
ksession.setGlobal("list", list);
ksession.fireAllRules();
assertEquals(1, list.size());
assertEquals("Old man stilton", list.get(0));
}
开发者ID:jboss-integration，项目名称:fuse-bxms-integ，代码行数:22，代码来源:SpreadsheetIntegrationExampleTest.java
示例6: testNamedWorksheet
import org.kie.api.io.Resource; //导入依赖的package包/类
/**
* Test named worksheet.
*
* @throws Exception the exception
*/
@Test
public void testNamedWorksheet() throws Exception {
DecisionTableConfiguration dtconf = KnowledgeBuilderFactory.newDecisionTableConfiguration();
dtconf.setInputType(DecisionTableInputType.XLS);
dtconf.setWorksheetName("Tables");
Resource dt = ResourceFactory.newClassPathResource("/data/IntegrationExampleTest.xls", getClass()).setConfiguration(
dtconf);
KieSession ksession = getKieSession(dt);
// ASSERT AND FIRE
ksession.insert(new Cheese("cheddar", 42));
ksession.insert(new Person("michael", "stilton", 21));
final List<String> list = new ArrayList<String>();
ksession.setGlobal("list", list);
ksession.fireAllRules();
assertEquals(1, list.size());
assertEquals("Young man cheddar", list.get(0));
}
开发者ID:jboss-integration，项目名称:fuse-bxms-integ，代码行数:25，代码来源:SpreadsheetIntegrationExampleTest.java
示例7: addClassPathResource
import org.kie.api.io.Resource; //导入依赖的package包/类
@Override
public KnowledgeService addClassPathResource(String resourceName, Handler<AsyncResult<Void>> handler) {
Resource resource = ResourceFactory.newClassPathResource(resourceName);
environmentBuilder.addAsset(resource, resource.getResourceType());
handler.handle(Future.succeededFuture());
return this;
}
开发者ID:diabolicallabs，项目名称:vertx-process-manager，代码行数:10，代码来源:KnowledgeServiceImpl.java
示例8: addFileResource
import org.kie.api.io.Resource; //导入依赖的package包/类
@Override
public KnowledgeService addFileResource(String fileName, Handler<AsyncResult<Void>> handler) {
Resource resource = ResourceFactory.newFileResource(fileName);
environmentBuilder.addAsset(resource, resource.getResourceType());
handler.handle(Future.succeededFuture());
return this;
}
开发者ID:diabolicallabs，项目名称:vertx-process-manager，代码行数:10，代码来源:KnowledgeServiceImpl.java
示例9: buildKieBase
import org.kie.api.io.Resource; //导入依赖的package包/类
private KieBase buildKieBase(Map<Resource, ResourceType> resources) {
KieHelper kieHelper = new KieHelper();
for (Map.Entry<Resource, ResourceType> entrySet : resources.entrySet()) {
kieHelper.addResource(entrySet.getKey(), entrySet.getValue());
}
this.assertBuildResults(kieHelper.verify());
return kieHelper.build();
}
开发者ID:Salaboy，项目名称:drools-workshop，代码行数:12，代码来源:PhreakInspector.java
示例10: buildResources
import org.kie.api.io.Resource; //导入依赖的package包/类
/**
* Builds the Resources.
* @return the Resources
*/
public List<Resource> buildResources() {
List<Resource> resources = new ArrayList<Resource>();
for (ResourceBuilder builder : _resourceBuilders) {
Resource resource = builder.build();
if (resource != null) {
resources.add(resource);
}
}
return resources;
}
开发者ID:jboss-switchyard，项目名称:switchyard，代码行数:15，代码来源:ResourcesManifest.java
示例11: addAsset
import org.kie.api.io.Resource; //导入依赖的package包/类
/**
* Adds and asset.
* @param asset asset
* @param type type
* @return this RuntimeEnvironmentBuilder
*/
public RuntimeEnvironmentBuilder addAsset(Resource asset, ResourceType type) {
if (asset == null || type == null) {
return this;
}
_runtimeEnvironment.addAsset(asset, type);
return this;
}
开发者ID:jboss-switchyard，项目名称:switchyard，代码行数:14，代码来源:PatchedRuntimeEnvironmentBuilder.java
示例12: buildResources
import org.kie.api.io.Resource; //导入依赖的package包/类
/** Builds the Resources.
*
* @return the Resources */
public List<Resource> buildResources() {
List<Resource> resources = new ArrayList<Resource>();
for (ResourceBuilder builder : _resourceBuilders) {
Resource resource = builder.build();
if (resource != null) {
resources.add(resource);
}
}
return resources;
}
开发者ID:jboss-integration，项目名称:fuse-bxms-integ，代码行数:14，代码来源:ResourcesManifest.java
示例13: addAsset
import org.kie.api.io.Resource; //导入依赖的package包/类
/** Adds and asset.
*
* @param asset asset
* @param type type
* @return this RuntimeEnvironmentBuilder */
public RuntimeEnvironmentBuilder addAsset(Resource asset, ResourceType type) {
if (asset == null || type == null) {
return this;
}
_runtimeEnvironment.addAsset(asset, type);
return this;
}
开发者ID:jboss-integration，项目名称:fuse-bxms-integ，代码行数:13，代码来源:PatchedRuntimeEnvironmentBuilder.java
示例14: getStatelessKieSessionFromResource
import org.kie.api.io.Resource; //导入依赖的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
示例15: getKieSessionFromResource
import org.kie.api.io.Resource; //导入依赖的package包/类
private KieSession getKieSessionFromResource(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()).newKieSession();
}
开发者ID:jboss-integration，项目名称:fuse-bxms-integ，代码行数:16，代码来源:XStreamBatchExecutionTest.java
示例16: getStatelessKieSessionFromResource
import org.kie.api.io.Resource; //导入依赖的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
示例17: getKieSessionFromResource
import org.kie.api.io.Resource; //导入依赖的package包/类
private KieSession getKieSessionFromResource(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()).newKieSession();
}
开发者ID:jboss-integration，项目名称:fuse-bxms-integ，代码行数:16，代码来源:BatchTest.java
示例18: getKieSession
import org.kie.api.io.Resource; //导入依赖的package包/类
/**
* Gets the kie session.
*
* @param dt the dt
* @return the kie session
*/
private KieSession getKieSession(Resource dt) {
KieServices ks = KieServices.Factory.get();
KieFileSystem kfs = ks.newKieFileSystem().write(dt);
KieBuilder kb = ks.newKieBuilder(kfs).buildAll();
assertTrue(kb.getResults().getMessages().isEmpty());
// get the session
KieSession ksession = ks.newKieContainer(ks.getRepository().getDefaultReleaseId()).newKieSession();
return ksession;
}
开发者ID:jboss-integration，项目名称:fuse-bxms-integ，代码行数:18，代码来源:SpreadsheetIntegrationExampleTest.java
示例19: testExecuteJBRULES3005
import org.kie.api.io.Resource; //导入依赖的package包/类
/**
* Test execute jbrule s3005.
*
* @throws Exception the exception
*/
@Test
public void testExecuteJBRULES3005() throws Exception {
Resource dt = ResourceFactory.newClassPathResource("/data/IntegrationExampleTest.xls", getClass());
KieSession ksession = getKieSession(dt);
// ASSERT AND FIRE
ksession.insert(new Cheese("stilton", 42));
ksession.insert(new Person("michael", "stilton", 42));
final List<String> list = new ArrayList<String>();
ksession.setGlobal("list", list);
ksession.fireAllRules();
assertEquals(1, list.size());
assertEquals("Old man stilton", list.get(0));
}
开发者ID:jboss-integration，项目名称:fuse-bxms-integ，代码行数:20，代码来源:SpreadsheetIntegrationExampleTest.java
示例20: build
import org.kie.api.io.Resource; //导入依赖的package包/类
public BuildResults build(final Path resource,
final InputStream inputStream) {
synchronized (kieFileSystem) {
final String destinationPath = destinationPath(resource);
final Resource inputStreamResource = KieServices.Factory.get().getResources().newInputStreamResource(new BufferedInputStream(inputStream));
kieFileSystem.write(destinationPath,
inputStreamResource);
}
return build();
}
开发者ID:kiegroup，项目名称:kie-wb-common，代码行数:13，代码来源:Builder.java
注：本文中的org.kie.api.io.Resource类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。 |
客服电话
APP下载
官方微信
请发表评论