+ this.kieSession.insert(raiseAlarm);\r
+ this.kieSession.fireAllRules();\r
+ }\r
+\r
+ public List<String> queryAllPackage() {\r
+ List<KiePackage> kiePackages = (List<KiePackage>)kieBase.getKiePackages();\r
+ List<String> list = new ArrayList<>();\r
+ for(KiePackage kiePackage : kiePackages) {\r
+ list.add(kiePackage.getName());\r
+ }\r
+ return list;\r
+ }\r
+\r
+ private KieFileSystem createKieFileSystemWithKProject(KieServices ks) {\r
+ KieModuleModel kieModuleModel = ks.newKieModuleModel();\r
+ KieBaseModel kieBaseModel = kieModuleModel.newKieBaseModel("KBase")\r
+ .addPackage("rules")\r
+ .setDefault(true)\r
+ .setEqualsBehavior(EqualityBehaviorOption.EQUALITY)\r
+ .setEventProcessingMode(EventProcessingOption.STREAM);\r
+ KieSessionModel kieSessionModel = kieBaseModel.newKieSessionModel("KSession")\r
+ .setDefault( true )\r
+ .setType( KieSessionModel.KieSessionType.STATEFUL )\r
+ .setClockType( ClockTypeOption.get("realtime") );\r
+ KieFileSystem kfs = ks.newKieFileSystem();\r
+ kfs.writeKModuleXML(kieModuleModel.toXML());\r
+ return kfs;\r
+ }\r
+\r
+ private void avoidDeployBug() {\r
+ String tmp = Math.random() + "";\r
+ String rule = "package justInOrderToAvoidDeployBug" + tmp.substring(2);\r
+ kfs.write("src/main/resources/rules/rule.drl", rule);\r
+ kieBuilder = ks.newKieBuilder(kfs).buildAll();\r
+ InternalKieModule internalKieModule = (InternalKieModule)kieBuilder.getKieModule();\r
+ String packageName = internalKieModule.getKnowledgePackagesForKieBase("KBase").iterator().next().getName();\r
+ kieRepository.addKieModule(internalKieModule);\r
+ kieContainer.updateToVersion(internalKieModule.getReleaseId());\r
+\r
+ KiePackage kiePackage = kieBase.getKiePackage(packageName);\r
+ kieBase.removeKiePackage(kiePackage.getName());\r