org.kie.api.builder.Message类的使用及代码示例

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

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

Message介绍

[英]A Message generated by the building process of a KieModule
[中]由模块的构建过程生成的消息

代码示例

代码示例来源：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: org.drools/drools-compiler

  1. @Test
  2. public void testDSLExpansion_MessageImplNPE() throws Exception {
  3.   final KieServices ks = KieServices.Factory.get();
  4.   final ReleaseId releaseId = ks.newReleaseId( "org.kie", "dsl-test", "1.0" );
  5.   final KieModuleModel kproj = ks.newKieModuleModel();
  6.   final KieFileSystem kfs = ks.newKieFileSystem();
  7.   kfs.writeKModuleXML( kproj.toXML() )
  8.       .writePomXML( generatePomXml( releaseId ) )
  9.       .write( "src/main/resources/KBase1/test-dsl.dsl", createDSL() )
  10.       .write( "src/main/resources/KBase1/test-rule.dslr", createDRL() );
  11.   final KieBuilder kieBuilder = ks.newKieBuilder( kfs );
  12.   final List<Message> messages = kieBuilder.buildAll().getResults().getMessages();
  13.   if ( !messages.isEmpty() ) {
  14.     for ( final Message m : messages ) {
  15.       System.out.println( m.getText() );
  16.     }
  17.   }
  18.   assertTrue( messages.isEmpty() );
  19. }

代码示例来源：origin: org.drools/drools-reteoo

  1. public static byte[] createKJar(KieServices ks,
  2.                 ReleaseId releaseId,
  3.                 String pom,
  4.                 String... drls) {
  5.   KieFileSystem kfs = ks.newKieFileSystem();
  6.   if( pom != null ) {
  7.     kfs.write("pom.xml", pom);
  8.   } else {
  9.     kfs.generateAndWritePomXML(releaseId);
  10.   }
  11.   for (int i = 0; i < drls.length; i++) {
  12.     if (drls[i] != null) {
  13.       kfs.write("src/main/resources/r" + i + ".drl", drls[i]);
  14.     }
  15.   }
  16.   KieBuilder kb = ks.newKieBuilder(kfs).buildAll();
  17.   if( kb.getResults().hasMessages( org.kie.api.builder.Message.Level.ERROR ) ) {
  18.     for( org.kie.api.builder.Message result : kb.getResults().getMessages() ) {
  19.       System.out.println(result.getText());
  20.     }
  21.     return null;
  22.   }
  23.   InternalKieModule kieModule = (InternalKieModule) ks.getRepository()
  24.                             .getKieModule(releaseId);
  25.   byte[] jar = kieModule.getBytes();
  26.   return jar;
  27. }

代码示例来源：origin: org.drools/drools-compiler

  1. public static byte[] buildKJar(KieServices ks, KieFileSystem kfs, ReleaseId releaseId) {
  2.   KieBuilder kb = ks.newKieBuilder(kfs).buildAll();
  3.   if (kb.getResults().hasMessages(Message.Level.ERROR)) {
  4.     for (Message result : kb.getResults().getMessages()) {
  5.       System.out.println(result.getText());
  6.     }
  7.     return null;
  8.   }
  9.   InternalKieModule kieModule = (InternalKieModule) ks.getRepository()
  10.       .getKieModule(releaseId);
  11.   byte[] jar = kieModule.getBytes();
  12.   return jar;
  13. }

代码示例来源：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: secbr/drools

  1. protected static KieSession getKieSessionByDrl(String drlContent) {
  2.   KieHelper kieHelper = new KieHelper();
  3.   kieHelper.addContent(drlContent, ResourceType.DRL);
  4.   Results verify = kieHelper.verify();
  5.   boolean hasMessages = verify.hasMessages(Message.Level.WARNING, Message.Level.ERROR);
  6.   if (hasMessages) {
  7.     List<Message> messages = verify.getMessages(Message.Level.WARNING, Message.Level.ERROR);
  8.     for (Message message : messages) {
  9.       System.out.println("ERROR : " + message.getText());
  10.     }
  11.     throw new RuntimeException("verify has errors!");
  12.   }
  13.   return kieHelper.build().newKieSession();
  14. }

代码示例来源：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/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: secbr/drools

  1. public static void main(String[] args) {
  2.     KieServices kieServices = KieServices.Factory.get();
  4.     KieContainer container = kieServices.getKieClasspathContainer();
  6.     Results results = container.verify();
  7.     List<Message> messages = results.getMessages();
  8.     System.out.println("messages size:" + messages.size());
  9.     for (Message msg : messages) {
  10.       System.out.println("level:" + msg.getLevel() + ";text=" + msg.getText());
  11.     }
  13.     Collection<String> kieBaseNames = container.getKieBaseNames();
  14.     for(String kieBaseName : kieBaseNames){
  15.       System.out.println("kieBaseName----" + kieBaseName);
  16.       Collection<String> kieSessionNamesInKieBase = container.getKieSessionNamesInKieBase(kieBaseName);
  17.       for(String kieSession : kieSessionNamesInKieBase){
  18.         System.out.println("kieSession-----" + kieSession);
  19.       }
  20.     }
  22.   }
  23. }

代码示例来源：origin: stackoverflow.com

  1. KieHelper kieHelper = new KieHelper();
  2. for (String ruleId : drls.keySet()) {
  3.   kieHelper.addContent(drls.get(ruleId), ResourceType.DRL);
  4. }
  5. Results results = kieHelper.verify();
  6. for (Message message : results.getMessages()) {
  7.   log.error(">> Message ({}): {}", message.getLevel(), message.getText());
  8. }
  10. if (results.hasMessages(Message.Level.ERROR)) {
  11.   throw new IllegalStateException("There are errors in the KB.");
  12. }
  14. KieSession ksession = kieHelper.build().newKieSession();

代码示例来源：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: org.kie.server/kie-server-services-common

  1. public boolean verify(KieContainer container) {
  2.   boolean verified = true;
  3.   try {
  4.     Results results = container.verify();
  5.     for (Message message : results.getMessages()) {
  6.       Level level = message.getLevel();
  7.       switch (level) {
  8.         case INFO:
  9.           logger.info(message.toString());
  10.           break;
  11.         case WARNING:
  12.           logger.warn(message.toString());
  13.           break;
  14.         case ERROR:
  15.           logger.error(message.toString());
  16.           verified = false;
  17.           break;
  18.       }
  19.     }
  20.   } catch (Throwable t) {
  21.     logger.error(t.getMessage(), t);
  22.     verified = false;
  23.   }
  24.   return verified;
  25. }

代码示例来源：origin: stackoverflow.com

  1. if(logger.isDebugEnable()) {
  2.   for(Message mess:list) {
  3.      logger.debug("mess:" + mess.getText());
  4.   }
  5. }

代码示例来源：origin: stackoverflow.com

  1. mFirebaseAdapter = new FirebaseRecyclerAdapter<Message, MessageViewHolder>(
  2.      Message.class,
  3.      R.layout.item_message,
  4.      MessageViewHolder.class,
  5.      mFirebaseDatabaseReference.child(MESSAGES_CHILD)) {
  6.    @Override
  7.    protected void populateViewHolder(final MessageViewHolder viewHolder, Message friendlyMessage, int position) {
  8.      viewHolder.messageTextView.setText(friendlyMessage.getText());
  9.      viewHolder.messengerTextView.setText(friendlyMessage.getName());
  10.      if (friendlyMessage.getPhotoUrl() == null) {
  11.        viewHolder.messengerImageView.setImageDrawable(ContextCompat.getDrawable(MessageActivity.this,
  12.            R.drawable.profilepic_placeholder));
  13.      } else {
  14.        Glide.with(MessageActivity.this)
  15.            .load(friendlyMessage.getPhotoUrl())
  16.            .into(viewHolder.messengerImageView);
  17.      }
  18.    }
  19.  };

代码示例来源：origin: stackoverflow.com

  1. SimpleDateFormat ru = new SimpleDateFormat("yyyy-MM-dd hh:mm:ss", new Locale("ru"));
  2.   ru.setTimeZone(TimeZone.getTimeZone("GMT+03:00"));
  3.   Date jud = ru.parse(mLastMessage.getDate());
  4.   String targetFormat = new SimpleDateFormat("d MMMM, HH:mm", new Locale("ru")).format(jud);
  5.   final long milliseconds = jud.getTime();
  6. holder.message.setText(Helpers.stringLimit(Helpers.stripLineBreaks(mLastMessage.getText(), " "), 50));
  7.   if(mLastMessage.getSender_type().equals(Constants.CLIENT_TYPE)) {
  8.     holder.setClientWaiting();
  9.   } else {

代码示例来源：origin: stackoverflow.com

  1. holder.textView.setText(m.getText());
  2.   previousTs = pm.getTimeStamp();
  3. setTimeTextVisibility(m.getTimeStamp(), previousTs, holder.timeText);

代码示例来源：origin: stackoverflow.com

  1. public void onUpdateReceived(Update update) {
  2.   Message message = update.getMessage();
  3.   Long chatId = message.getChatId();
  4.   String input = message.getText();
  5.   if ("/recommendPizza".equals(input)) {
  6.     SendMessage request = new SendMessage();

代码示例来源：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.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.drools/drools-compiler

  1. @Test
  2. public void testDSLExpansion_NoExpansion() throws Exception {
  3.   final KieServices ks = KieServices.Factory.get();
  4.   final ReleaseId releaseId = ks.newReleaseId( "org.kie", "dsl-test", "1.0" );
  5.   final KieModuleModel kproj = ks.newKieModuleModel();
  6.   final KieFileSystem kfs = ks.newKieFileSystem();
  7.   kfs.writeKModuleXML( kproj.toXML() )
  8.       .writePomXML( generatePomXml( releaseId ) )
  9.       .write( "src/main/resources/KBase1/test-dsl.dsl", createDSL() )
  10.       .write( "src/main/resources/KBase1/test-rule.drl", createDRL() );
  11.   final KieBuilder kieBuilder = ks.newKieBuilder( kfs );
  12.   final List<Message> messages = kieBuilder.buildAll().getResults().getMessages();
  13.   if ( !messages.isEmpty() ) {
  14.     for ( final Message m : messages ) {
  15.       System.out.println( m.getText() );
  16.     }
  17.   }
  18.   assertFalse( messages.isEmpty() );
  19. }

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

Message

相关文章

    查看更多

    热门标签

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

    最新文章

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