org.kie.api.builder.Message.getPath()方法的使用及代码示例

x33g5p2x  于2022-01-25 转载在 其他  
字(14.4k)|赞(0)|评价(0)|浏览(225)

本文整理了Java中org.kie.api.builder.Message.getPath()方法的一些代码示例，展示了Message.getPath()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Message.getPath()方法的具体详情如下：
包路径：org.kie.api.builder.Message
类名称：Message
方法名：getPath

Message.getPath介绍

[英]Returns the path of the resource that caused the creation of this Message
[中]返回导致创建此消息的资源的路径

代码示例

代码示例来源：origin: kiegroup/jbpm

  1. protected InternalKieModule createKieJar(KieServices ks, ReleaseId releaseId, Map<String, String> resources, ReleaseId... dependencies) {
  2.   KieFileSystem kfs = createKieFileSystemWithKProject(ks);
  3.   kfs.writePomXML(getPom(releaseId, dependencies));
  4.   for (Map.Entry<String, String> entry : resources.entrySet()) {
  5.     kfs.write(entry.getKey(), ResourceFactory
  6.         .newByteArrayResource(entry.getValue().getBytes()));
  7.   }
  8.   KieBuilder kieBuilder = ks.newKieBuilder(kfs);
  9.   if (!kieBuilder.buildAll().getResults().getMessages().isEmpty()) {
  10.     for (Message message : kieBuilder.buildAll().getResults()
  11.         .getMessages()) {
  12.       logger.error("Error Message: ({}) {}", message.getPath(), message.getText());
  13.     }
  14.     throw new RuntimeException(
  15.         "There are errors builing the package, please check your knowledge assets!");
  16.   }
  17.   return (InternalKieModule) kieBuilder.getKieModule();
  18. }

代码示例来源：origin: kiegroup/jbpm

  1. protected InternalKieModule createKieJar(KieServices ks, ReleaseId releaseId, List<String> resources ) {
  2.    
  3.   KieFileSystem kfs = createKieFileSystemWithKProject(ks);
  4.   kfs.writePomXML( getPom(releaseId) );
  5.   
  6.   for (String resource : resources) {
  7.     kfs.write("src/main/resources/rules/" + resource, ResourceFactory.newClassPathResource(resource));
  8.   }
  9.   KieBuilder kieBuilder = ks.newKieBuilder(kfs);
  10.   if (!kieBuilder.buildAll().getResults().getMessages().isEmpty()) {
  11.     for (Message message : kieBuilder.buildAll().getResults().getMessages()) {
  12.       logger.error("Error Message: ({}) {}", message.getPath(), message.getText());
  13.     }
  14.     throw new RuntimeException(
  15.         "There are errors builing the package, please check your knowledge assets!");
  16.   }
  17.   
  18.   return ( InternalKieModule ) kieBuilder.getKieModule();
  19. }

代码示例来源：origin: kiegroup/jbpm

  1. protected InternalKieModule createKieJar(KieServices ks, ReleaseId releaseId, List<String> resources ) {
  2.    
  3.   KieFileSystem kfs = createKieFileSystemWithKProject(ks);
  4.   kfs.writePomXML( getPom(releaseId) );
  5.   
  6.   for (String resource : resources) {
  7.     kfs.write("src/main/resources/KBase-test/" + resource, ResourceFactory.newClassPathResource(resource));
  8.   }
  9.   KieBuilder kieBuilder = ks.newKieBuilder(kfs);
  10.   if (!kieBuilder.buildAll().getResults().getMessages().isEmpty()) {
  11.     for (Message message : kieBuilder.buildAll().getResults().getMessages()) {
  12.       logger.error("Error Message: ({}) {}", message.getPath(), message.getText());
  13.     }
  14.     throw new RuntimeException(
  15.         "There are errors builing the package, please check your knowledge assets!");
  16.   }
  17.   
  18.   return ( InternalKieModule ) kieBuilder.getKieModule();
  19. }

代码示例来源：origin: wyh-spring-ecosystem-student/spring-boot-student

  1. /**
  2.  * 加载KieContainer容器
  3.  */
  4. public static KieContainer loadKieContainer() throws RuntimeException {
  5.   //通过kmodule.xml 找到规则文件,这个文件默认放在resources/META-INF文件夹
  6.   log.info("准备创建 KieContainer");
  7.   if (kieContainer == null) {
  8.     log.info("首次创建：KieContainer");
  9.     // 设置drools的日期格式
  10.     System.setProperty("drools.dateformat", "yyyy-MM-dd HH:mm:ss");
  11.     //线程安全
  12.     synchronized (DroolsUtil.class) {
  13.       if (kieContainer == null) {
  14.         // 创建Container
  15.         kieContainer = kieServices.getKieClasspathContainer();
  16.         // 检查规则文件是否有错
  17.         Results results = kieContainer.verify();
  18.         if (results.hasMessages(Message.Level.ERROR)) {
  19.           StringBuffer sb = new StringBuffer();
  20.           for (Message mes : results.getMessages()) {
  21.             sb.append("解析错误的规则：").append(mes.getPath()).append(" 错误位置：").append(mes.getLine()).append(";");
  22.           }
  23.           throw new RuntimeException(sb.toString());
  24.         }
  25.       }
  26.     }
  27.   }
  28.   log.info("KieContainer创建完毕");
  29.   return kieContainer;
  30. }

代码示例来源：origin: org.kie.guvnor/guvnor-commons-builder

  1. public IncrementalBuildResults deleteResource( final Path resource ) {
  2.   //Check a full build has been performed
  3.   if ( !isBuilt() ) {
  4.     throw new IllegalStateException( "A full build needs to be performed before any incremental operations." );
  5.   }
  6.   //Delete resource
  7.   final String destinationPath = resource.toUri().toString().substring( projectPrefix.length() + 1 );
  8.   kieFileSystem.delete( destinationPath );
  9.   //Incremental build
  10.   final IncrementalResults incrementalResults = ( (InternalKieBuilder) kieBuilder ).createFileSet( destinationPath ).build();
  11.   //Messages from incremental build
  12.   final IncrementalBuildResults results = convertMessages( incrementalResults );
  13.   //Tidy-up removed message handles
  14.   for ( Message message : incrementalResults.getRemovedMessages() ) {
  15.     handles.remove( RESOURCE_PATH + "/" + message.getPath() );
  16.   }
  17.   return results;
  18. }

代码示例来源：origin: org.kie.guvnor/guvnor-commons-builder

  1. public IncrementalBuildResults addResource( final Path resource ) {
  2.   //Check a full build has been performed
  3.   if ( !isBuilt() ) {
  4.     throw new IllegalStateException( "A full build needs to be performed before any incremental operations." );
  5.   }
  6.   //Add new resource
  7.   final String destinationPath = resource.toUri().toString().substring( projectPrefix.length() + 1 );
  8.   final InputStream is = ioService.newInputStream( resource );
  9.   final BufferedInputStream bis = new BufferedInputStream( is );
  10.   kieFileSystem.write( destinationPath,
  11.              KieServices.Factory.get().getResources().newInputStreamResource( bis ) );
  12.   handles.put( destinationPath,
  13.          paths.convert( resource ) );
  14.   //Incremental build
  15.   final IncrementalResults incrementalResults = ( (InternalKieBuilder) kieBuilder ).createFileSet( destinationPath ).build();
  16.   //Messages from incremental build
  17.   final IncrementalBuildResults results = convertMessages( incrementalResults );
  18.   //Tidy-up removed message handles
  19.   for ( Message message : incrementalResults.getRemovedMessages() ) {
  20.     handles.remove( RESOURCE_PATH + "/" + message.getPath() );
  21.   }
  22.   return results;
  23. }

代码示例来源：origin: deepu105/drools-demo

  1. private static String prettyBuildMessage(Message msg) {
  2.   return "Message: {"
  3.     + "id="+ msg.getId()
  4.     + ", level=" + msg.getLevel()
  5.     + ", path=" + msg.getPath()
  6.     + ", line=" + msg.getLine()
  7.     + ", column=" + msg.getColumn()
  8.     + ", text=\"" + msg.getText() + "\""
  9.     + "}";
  10. }

代码示例来源：origin: gratiartis/qzr

  1. private static String prettyBuildMessage(Message msg) {
  2.   return "Message: {"
  3.     + "id="+ msg.getId()
  4.     + ", level=" + msg.getLevel()
  5.     + ", path=" + msg.getPath()
  6.     + ", line=" + msg.getLine()
  7.     + ", column=" + msg.getColumn()
  8.     + ", text=\"" + msg.getText() + "\""
  9.     + "}";
  10. }

代码示例来源：origin: deepu105/drools-demo

  1. private static String prettyBuildMessage(Message msg) {
  2.   return "Message: {"
  3.     + "id="+ msg.getId()
  4.     + ", level=" + msg.getLevel()
  5.     + ", path=" + msg.getPath()
  6.     + ", line=" + msg.getLine()
  7.     + ", column=" + msg.getColumn()
  8.     + ", text=\"" + msg.getText() + "\""
  9.     + "}";
  10. }

代码示例来源：origin: org.kie.guvnor/guvnor-commons-builder

  1. private BuildMessage convertMessage( final Message message ) {
  2.   final BuildMessage m = new BuildMessage();
  3.   switch ( message.getLevel() ) {
  4.     case ERROR:
  5.       m.setLevel( BuildMessage.Level.ERROR );
  6.       break;
  7.     case WARNING:
  8.       m.setLevel( BuildMessage.Level.WARNING );
  9.       break;
  10.     case INFO:
  11.       m.setLevel( BuildMessage.Level.INFO );
  12.       break;
  13.   }
  14.   m.setId( message.getId() );
  15.   m.setArtifactID( artifactId );
  16.   m.setLine( message.getLine() );
  17.   if ( message.getPath() != null && !message.getPath().isEmpty() ) {
  18.     m.setPath( handles.get( RESOURCE_PATH + "/" + message.getPath() ) );
  19.   }
  20.   m.setColumn( message.getColumn() );
  21.   m.setText( message.getText() );
  22.   return m;
  23. }

代码示例来源：origin: org.jbpm/jbpm-test

  1. protected InternalKieModule createKieJar(KieServices ks, ReleaseId releaseId, List<String> resources, Map<String, String> extraResources, ReleaseId... dependencies) {
  2.   KieFileSystem kfs = createKieFileSystemWithKProject(ks);
  3.   kfs.writePomXML(getPom(releaseId, dependencies));
  4.   DeploymentDescriptor customDescriptor = createDeploymentDescriptor();
  5.   if (extraResources == null) {
  6.     extraResources = new HashMap<String, String>();
  7.   }
  8.   if (customDescriptor != null) {
  9.     extraResources.put("src/main/resources/" + DeploymentDescriptor.META_INF_LOCATION, customDescriptor.toXml());
  10.   }
  11.   for (String resource : resources) {
  12.     kfs.write("src/main/resources/KBase-test/" + resource, ResourceFactory.newClassPathResource(resource));
  13.   }
  14.   if (extraResources != null) {
  15.     for (Map.Entry<String, String> entry : extraResources.entrySet()) {
  16.       kfs.write(entry.getKey(), ResourceFactory.newByteArrayResource(entry.getValue().getBytes()));
  17.     }
  18.   }
  19.   KieBuilder kieBuilder = ks.newKieBuilder(kfs);
  20.   if (!kieBuilder.buildAll().getResults().getMessages().isEmpty()) {
  21.     for (Message message : kieBuilder.buildAll().getResults().getMessages()) {
  22.       logger.error("Error Message: ({}) {}", message.getPath(), message.getText());
  23.     }
  24.     throw new RuntimeException("There are errors builing the package, please check your knowledge assets!");
  25.   }
  26.   return (InternalKieModule) kieBuilder.getKieModule();
  27. }

代码示例来源：origin: org.kie/kie-dmn-core

  1. @Test
  2. public void testAPIUsage() {
  3.   // DROOLS-3335 Broken DMN resource should inhibit KJAR and report KieBuilder message
  4.   final KieServices ks = KieServices.Factory.get();
  5.   final KieContainer kieContainer = DMNRuntimeUtil.getKieContainerIgnoringErrors(ks.newReleaseId("org.kie", "dmn-test-" + UUID.randomUUID(), "1.0"),
  6.                                           ks.getResources().newClassPathResource("incomplete_expression.dmn", this.getClass()),
  7.                                           ks.getResources().newClassPathResource("duff.drl", this.getClass()));
  8.   Results verify = kieContainer.verify();
  9.   List<Message> kie_messages = verify.getMessages();
  10.   kie_messages.forEach(m -> LOG.info("{}", m));
  11.   assertThat(kie_messages.size(), is(3));
  12.   assertThat(kie_messages.stream().filter(m -> m.getPath().equals("duff.drl")).count(), is(2L));
  13.   List<DMNMessage> dmnMessages = kie_messages.stream()
  14.                         .filter(DMNMessage.class::isInstance)
  15.                         .map(DMNMessage.class::cast)
  16.                         .collect(Collectors.toList());
  17.   assertThat(dmnMessages.size(), is(1));
  18.   DMNMessage dmnMessage = dmnMessages.get(0);
  19.   assertThat(dmnMessage.getSourceId(), is("_c990c3b2-e322-4ef9-931d-79bcdac99686"));
  20.   assertThat(dmnMessage.getMessageType(), is(DMNMessageType.ERR_COMPILING_FEEL));
  21.   assertThat(dmnMessage.getPath(), is("incomplete_expression.dmn"));
  22. }

代码示例来源：origin: org.kie.workbench.services/kie-wb-common-services-backend

  1. private void buildIncrementally(final IncrementalBuildResults results,
  2.                 final String... destinationPath) {
  3.   try {
  4.     final IncrementalResults incrementalResults = ((InternalKieBuilder) kieBuilder).createFileSet(destinationPath).build();
  5.     results.addAllAddedMessages(convertMessages(incrementalResults.getAddedMessages(),
  6.                           handles));
  7.     results.addAllRemovedMessages(convertMessages(incrementalResults.getRemovedMessages(),
  8.                            handles));
  9.     //Tidy-up removed message handles
  10.     for (Message message : incrementalResults.getRemovedMessages()) {
  11.       handles.remove(Handles.RESOURCE_PATH + "/" + getBaseFileName(message.getPath()));
  12.     }
  13.   } catch (LinkageError e) {
  14.     final String msg = MessageFormat.format(ERROR_CLASS_NOT_FOUND,
  15.                         e.getLocalizedMessage());
  16.     logger.warn(msg);
  17.     results.addAddedMessage(makeWarningMessage(msg));
  18.   } catch (Throwable e) {
  19.     final String msg = e.getLocalizedMessage();
  20.     logger.error(msg,
  21.            e);
  22.     results.addAddedMessage(makeErrorMessage(msg));
  23.   }
  24. }

代码示例来源：origin: org.kie/kie-spring

  1. protected InternalKieModule createKieJar(KieServices ks, ReleaseId releaseId, List<String> resources, Map<String, String> extraResources ) {
  2.   KieFileSystem kfs = createKieFileSystemWithKProject(ks);
  3.   kfs.writePomXML( getPom(releaseId) );
  4.   for (String resource : resources) {
  5.     kfs.write("src/main/resources/KBase-test/" + resource, ResourceFactory.newClassPathResource(resource));
  6.   }
  7.   if (extraResources != null) {
  8.     for (Map.Entry<String, String> entry : extraResources.entrySet()) {
  9.       kfs.write(entry.getKey(), ResourceFactory.newByteArrayResource(entry.getValue().getBytes()));
  10.     }
  11.   }
  12.   KieBuilder kieBuilder = ks.newKieBuilder(kfs);
  13.   if (!kieBuilder.buildAll().getResults().getMessages().isEmpty()) {
  14.     for (Message message : kieBuilder.buildAll().getResults().getMessages()) {
  15.       logger.error("Error Message: ({}) {}", message.getPath(), message.getText());
  16.     }
  17.     throw new RuntimeException(
  18.         "There are errors builing the package, please check your knowledge assets!");
  19.   }
  20.   return ( InternalKieModule ) kieBuilder.getKieModule();
  21. }

代码示例来源：origin: kiegroup/droolsjbpm-integration

  1. protected InternalKieModule createKieJar(KieServices ks, ReleaseId releaseId, List<String> resources, Map<String, String> extraResources ) {
  2.   KieFileSystem kfs = createKieFileSystemWithKProject(ks);
  3.   kfs.writePomXML( getPom(releaseId) );
  4.   for (String resource : resources) {
  5.     kfs.write("src/main/resources/KBase-test/" + resource, ResourceFactory.newClassPathResource(resource));
  6.   }
  7.   if (extraResources != null) {
  8.     for (Map.Entry<String, String> entry : extraResources.entrySet()) {
  9.       kfs.write(entry.getKey(), ResourceFactory.newByteArrayResource(entry.getValue().getBytes()));
  10.     }
  11.   }
  12.   KieBuilder kieBuilder = ks.newKieBuilder(kfs);
  13.   if (!kieBuilder.buildAll().getResults().getMessages().isEmpty()) {
  14.     for (Message message : kieBuilder.buildAll().getResults().getMessages()) {
  15.       logger.error("Error Message: ({}) {}", message.getPath(), message.getText());
  16.     }
  17.     throw new RuntimeException(
  18.         "There are errors builing the package, please check your knowledge assets!");
  19.   }
  20.   return ( InternalKieModule ) kieBuilder.getKieModule();
  21. }

代码示例来源：origin: org.jbpm/jbpm-services-ejb-impl

  1. protected static InternalKieModule createKieJar(KieServices ks, ReleaseId releaseId, List<String> resources, Map<String, String> extraResources ) {
  2.    
  3.   KieFileSystem kfs = createKieFileSystemWithKProject(ks);
  4.   kfs.writePomXML( getPom(releaseId) );
  5.   
  6.   for (String resource : resources) {
  7.     kfs.write("src/main/resources/KBase-test/" + resource, ResourceFactory.newClassPathResource(resource));
  8.   }
  9.   if (extraResources != null) {
  10.     for (Map.Entry<String, String> entry : extraResources.entrySet()) {
  11.       kfs.write(entry.getKey(), ResourceFactory.newByteArrayResource(entry.getValue().getBytes()));
  12.     }
  13.   }
  14.   
  15.   kfs.write("src/main/resources/forms/DefaultProcess.ftl", ResourceFactory.newClassPathResource("repo/globals/forms/DefaultProcess.ftl"));
  16.   
  17.   KieBuilder kieBuilder = ks.newKieBuilder(kfs);
  18.   if (!kieBuilder.buildAll().getResults().getMessages().isEmpty()) {
  19.     for (Message message : kieBuilder.buildAll().getResults().getMessages()) {
  20.       logger.error("Error Message: ({}) {}", message.getPath(), message.getText());
  21.     }
  22.     throw new RuntimeException(
  23.         "There are errors builing the package, please check your knowledge assets!");
  24.   }
  25.   
  26.   return ( InternalKieModule ) kieBuilder.getKieModule();
  27. }

代码示例来源：origin: org.kie.workbench.services/kie-wb-common-services-backend

  1. static BuildMessage convertMessage(final Message message,
  2.                   Handles handles) {
  3.   final BuildMessage m = new BuildMessage();
  4.   switch (message.getLevel()) {
  5.     case ERROR:
  6.       m.setLevel(Level.ERROR);
  7.       break;
  8.     case WARNING:
  9.       m.setLevel(Level.WARNING);
  10.       break;
  11.     case INFO:
  12.       m.setLevel(Level.INFO);
  13.       break;
  14.   }
  15.   m.setId(message.getId());
  16.   m.setLine(message.getLine());
  17.   m.setPath(convertPath(message.getPath(),
  18.              handles));
  19.   m.setColumn(message.getColumn());
  20.   m.setText(convertMessageText(message));
  21.   return m;
  22. }

内容来源于网络，如有侵权，请联系作者删除！

Message

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com