Remove usage of elastichsearch =>MongoDB

drools-framework-admin-console-parent/drools-framework-admin-console/pom.xml

@@ -218,12 +218,7 @@
             <version>${project.version}</version>
             <scope>compile</scope>
         </dependency>
-        <dependency>
+
-            <groupId>com.pymmasoftware.jbpm</groupId>
-            <artifactId>drools-framework-business-indexer-persistence</artifactId>
-            <version>${project.version}</version>
-            <scope>compile</scope>
-        </dependency>
 
     </dependencies>
 

drools-framework-admin-console-parent/drools-framework-admin-console/src/main/java/org/chtijbug/drools/console/DroolsSpringBootConsoleApplication.java

@@ -7,14 +7,14 @@ import org.springframework.boot.autoconfigure.SpringBootApplication;
 import org.springframework.boot.builder.SpringApplicationBuilder;
 import org.springframework.boot.web.servlet.support.SpringBootServletInitializer;
 import org.springframework.context.annotation.*;
-import org.springframework.data.elasticsearch.repository.config.EnableElasticsearchRepositories;
+
 import org.springframework.data.mongodb.repository.config.EnableMongoRepositories;
 
 @Configuration
 @SpringBootApplication
-@ComponentScan({"org.chtijbug.drools.proxy.persistence","org.chtijbug.drools.indexer"})
+@ComponentScan({"org.chtijbug.drools.proxy.persistence"})
 @EnableMongoRepositories("org.chtijbug.drools.proxy.persistence.repository")
-@EnableElasticsearchRepositories(basePackages = "org.chtijbug.drools.indexer.persistence.repository")
+
 @PropertySource("classpath:application.properties")
 @ImportResource("classpath:applicationContext.xml")
 public class DroolsSpringBootConsoleApplication extends SpringBootServletInitializer {

drools-framework-admin-console-parent/drools-framework-admin-console/src/main/java/org/chtijbug/drools/console/restExpose/ElasticSearchExpose.java

@@ -1,8 +1,8 @@
 package org.chtijbug.drools.console.restExpose;
 
 import org.chtijbug.drools.console.service.IndexerService;
-import org.chtijbug.drools.indexer.persistence.model.BusinessTransactionAction;
+import org.chtijbug.drools.proxy.persistence.model.BusinessTransactionAction;
-import org.chtijbug.drools.indexer.persistence.model.BusinessTransactionPersistence;
+import org.chtijbug.drools.proxy.persistence.model.BusinessTransactionPersistence;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.data.domain.PageRequest;
 import org.springframework.data.domain.Sort;

drools-framework-admin-console-parent/drools-framework-admin-console/src/main/java/org/chtijbug/drools/console/service/IndexerService.java

@@ -1,11 +1,11 @@
 package org.chtijbug.drools.console.service;
 
-import org.chtijbug.drools.indexer.persistence.repository.BusinessTransactionActionRepository;
+
-import org.chtijbug.drools.indexer.persistence.repository.BusinessTransactionPersistenceRepository;
+import org.chtijbug.drools.proxy.persistence.repository.BusinessTransactionActionRepository;
+import org.chtijbug.drools.proxy.persistence.repository.BusinessTransactionPersistenceRepository;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
-import java.time.LocalDate;
 import java.util.Date;
 import java.util.GregorianCalendar;
 

drools-framework-admin-console-parent/drools-framework-admin-console/src/main/java/org/chtijbug/drools/console/vaadinComponent/componentView/GridActionLogging.java

@@ -11,7 +11,7 @@ import com.vaadin.flow.data.value.ValueChangeMode;
 import com.vaadin.flow.function.SerializablePredicate;
 import org.chtijbug.drools.console.service.IndexerService;
 import org.chtijbug.drools.console.service.util.AppContext;
-import org.chtijbug.drools.indexer.persistence.model.BusinessTransactionAction;
+import org.chtijbug.drools.proxy.persistence.model.BusinessTransactionAction;
 import org.springframework.data.domain.PageRequest;
 import org.springframework.data.domain.Sort;
 

drools-framework-admin-console-parent/drools-framework-admin-console/src/main/java/org/chtijbug/drools/console/vaadinComponent/componentView/GridLogging.java

@@ -10,7 +10,7 @@ import com.vaadin.flow.data.value.ValueChangeMode;
 import com.vaadin.flow.function.SerializablePredicate;
 import org.chtijbug.drools.console.service.IndexerService;
 import org.chtijbug.drools.console.service.util.AppContext;
-import org.chtijbug.drools.indexer.persistence.model.BusinessTransactionPersistence;
+import org.chtijbug.drools.proxy.persistence.model.BusinessTransactionPersistence;
 import org.springframework.data.domain.PageRequest;
 
 import java.util.ArrayList;

drools-framework-admin-console-parent/drools-framework-admin-console/src/main/java/org/chtijbug/drools/console/vaadinComponent/leftMenu/Action/ActionLogging.java

@@ -11,7 +11,7 @@ import org.chtijbug.drools.console.vaadinComponent.ComponentPerso.DialogPerso;
 import org.chtijbug.drools.console.vaadinComponent.ComponentPerso.TextFieldPerso;
 import org.chtijbug.drools.console.view.ActionLoggingView;
 import org.chtijbug.drools.console.view.LoggingView;
-import org.chtijbug.drools.indexer.persistence.model.BusinessTransactionPersistence;
+import org.chtijbug.drools.proxy.persistence.model.BusinessTransactionPersistence;
 import org.springframework.data.domain.PageRequest;
 
 import java.util.List;

drools-framework-admin-console-parent/drools-framework-admin-console/src/main/java/org/chtijbug/drools/console/view/ActionLoggingView.java

@@ -6,9 +6,9 @@ import com.vaadin.flow.component.orderedlayout.VerticalLayout;
 import com.vaadin.flow.component.textfield.TextArea;
 import org.chtijbug.drools.console.vaadinComponent.ComponentPerso.DialogPerso;
 import org.chtijbug.drools.console.vaadinComponent.componentView.GridActionLogging;
-import org.chtijbug.drools.indexer.persistence.model.BusinessTransactionAction;
-import org.chtijbug.drools.indexer.persistence.model.BusinessTransactionPersistence;
 import org.chtijbug.drools.logging.Fact;
+import org.chtijbug.drools.proxy.persistence.model.BusinessTransactionAction;
+import org.chtijbug.drools.proxy.persistence.model.BusinessTransactionPersistence;
 
 
 public class ActionLoggingView extends VerticalLayout {

drools-framework-business-proxy-parent/drools-framework-business-indexer-app/drools-framework-business-indexer-app.iml

@@ -36,7 +36,7 @@
     <orderEntry type="library" name="Maven: javax.annotation:javax.annotation-api:1.3.2" level="project" />
     <orderEntry type="library" name="Maven: org.springframework:spring-core:5.1.2.RELEASE" level="project" />
     <orderEntry type="library" name="Maven: org.springframework:spring-jcl:5.1.2.RELEASE" level="project" />
-    <orderEntry type="library" name="Maven: org.yaml:snakeyaml:1.23" level="project" />
+    <orderEntry type="library" scope="RUNTIME" name="Maven: org.yaml:snakeyaml:1.23" level="project" />
     <orderEntry type="library" name="Maven: org.springframework.boot:spring-boot-starter-json:2.1.0.RELEASE" level="project" />
     <orderEntry type="library" name="Maven: com.fasterxml.jackson.datatype:jackson-datatype-jdk8:2.9.7" level="project" />
     <orderEntry type="library" name="Maven: com.fasterxml.jackson.datatype:jackson-datatype-jsr310:2.9.7" level="project" />
@@ -68,6 +68,7 @@
     <orderEntry type="library" name="Maven: org.apache.camel:camel-spring-boot-starter:2.23.0" level="project" />
     <orderEntry type="library" name="Maven: org.apache.camel:camel-spring-boot:2.23.0" level="project" />
     <orderEntry type="library" name="Maven: org.apache.camel:camel-spring:2.23.0" level="project" />
+    <orderEntry type="library" name="Maven: org.springframework:spring-tx:5.1.2.RELEASE" level="project" />
     <orderEntry type="library" name="Maven: org.apache.camel:camel-core-starter:2.23.0" level="project" />
     <orderEntry type="library" name="Maven: org.apache.camel:camel-quartz2:2.23.0" level="project" />
     <orderEntry type="library" name="Maven: org.apache.camel:camel-core:2.23.0" level="project" />
@@ -77,69 +78,14 @@
     <orderEntry type="library" name="Maven: com.mchange:c3p0:0.9.5.2" level="project" />
     <orderEntry type="library" name="Maven: com.sun.xml.bind:jaxb-core:2.3.0" level="project" />
     <orderEntry type="library" name="Maven: com.sun.xml.bind:jaxb-impl:2.3.0" level="project" />
-    <orderEntry type="module" module-name="drools-framework-business-indexer-persistence" />
-    <orderEntry type="library" name="Maven: org.springframework.boot:spring-boot-starter-data-elasticsearch:2.1.0.RELEASE" level="project" />
-    <orderEntry type="library" name="Maven: org.springframework.data:spring-data-elasticsearch:3.1.2.RELEASE" level="project" />
-    <orderEntry type="library" name="Maven: org.springframework:spring-tx:5.1.2.RELEASE" level="project" />
-    <orderEntry type="library" name="Maven: org.springframework.data:spring-data-commons:2.1.2.RELEASE" level="project" />
-    <orderEntry type="library" name="Maven: joda-time:joda-time:2.10.1" level="project" />
-    <orderEntry type="library" name="Maven: org.elasticsearch.client:transport:6.4.2" level="project" />
-    <orderEntry type="library" name="Maven: org.elasticsearch:elasticsearch:6.4.2" level="project" />
-    <orderEntry type="library" name="Maven: org.elasticsearch:elasticsearch-core:6.4.2" level="project" />
-    <orderEntry type="library" name="Maven: org.elasticsearch:elasticsearch-secure-sm:6.4.2" level="project" />
-    <orderEntry type="library" name="Maven: org.elasticsearch:elasticsearch-x-content:6.4.2" level="project" />
-    <orderEntry type="library" name="Maven: com.fasterxml.jackson.dataformat:jackson-dataformat-smile:2.9.7" level="project" />
-    <orderEntry type="library" name="Maven: com.fasterxml.jackson.dataformat:jackson-dataformat-yaml:2.9.7" level="project" />
-    <orderEntry type="library" name="Maven: com.fasterxml.jackson.dataformat:jackson-dataformat-cbor:2.9.7" level="project" />
-    <orderEntry type="library" name="Maven: org.apache.lucene:lucene-core:7.4.0" level="project" />
-    <orderEntry type="library" name="Maven: org.apache.lucene:lucene-analyzers-common:7.4.0" level="project" />
-    <orderEntry type="library" name="Maven: org.apache.lucene:lucene-backward-codecs:7.4.0" level="project" />
-    <orderEntry type="library" name="Maven: org.apache.lucene:lucene-grouping:7.4.0" level="project" />
-    <orderEntry type="library" name="Maven: org.apache.lucene:lucene-highlighter:7.4.0" level="project" />
-    <orderEntry type="library" name="Maven: org.apache.lucene:lucene-join:7.4.0" level="project" />
-    <orderEntry type="library" name="Maven: org.apache.lucene:lucene-memory:7.4.0" level="project" />
-    <orderEntry type="library" name="Maven: org.apache.lucene:lucene-misc:7.4.0" level="project" />
-    <orderEntry type="library" name="Maven: org.apache.lucene:lucene-queries:7.4.0" level="project" />
-    <orderEntry type="library" name="Maven: org.apache.lucene:lucene-queryparser:7.4.0" level="project" />
-    <orderEntry type="library" name="Maven: org.apache.lucene:lucene-sandbox:7.4.0" level="project" />
-    <orderEntry type="library" name="Maven: org.apache.lucene:lucene-spatial:7.4.0" level="project" />
-    <orderEntry type="library" name="Maven: org.apache.lucene:lucene-spatial-extras:7.4.0" level="project" />
-    <orderEntry type="library" name="Maven: org.apache.lucene:lucene-spatial3d:7.4.0" level="project" />
-    <orderEntry type="library" name="Maven: org.apache.lucene:lucene-suggest:7.4.0" level="project" />
-    <orderEntry type="library" name="Maven: org.elasticsearch:elasticsearch-cli:6.4.2" level="project" />
-    <orderEntry type="library" name="Maven: net.sf.jopt-simple:jopt-simple:5.0.2" level="project" />
-    <orderEntry type="library" name="Maven: com.carrotsearch:hppc:0.7.1" level="project" />
-    <orderEntry type="library" name="Maven: com.tdunning:t-digest:3.2" level="project" />
-    <orderEntry type="library" name="Maven: org.hdrhistogram:HdrHistogram:2.1.9" level="project" />
-    <orderEntry type="library" name="Maven: org.elasticsearch:jna:4.5.1" level="project" />
-    <orderEntry type="library" name="Maven: org.elasticsearch.plugin:reindex-client:6.4.2" level="project" />
-    <orderEntry type="library" name="Maven: org.elasticsearch.client:elasticsearch-rest-client:6.4.2" level="project" />
-    <orderEntry type="library" name="Maven: org.apache.httpcomponents:httpclient:4.5.6" level="project" />
-    <orderEntry type="library" name="Maven: org.apache.httpcomponents:httpcore:4.4.10" level="project" />
-    <orderEntry type="library" name="Maven: org.apache.httpcomponents:httpasyncclient:4.1.4" level="project" />
-    <orderEntry type="library" name="Maven: org.apache.httpcomponents:httpcore-nio:4.4.10" level="project" />
-    <orderEntry type="library" name="Maven: commons-codec:commons-codec:1.11" level="project" />
-    <orderEntry type="library" name="Maven: org.elasticsearch.plugin:lang-mustache-client:6.4.2" level="project" />
-    <orderEntry type="library" name="Maven: com.github.spullara.mustache.java:compiler:0.9.3" level="project" />
-    <orderEntry type="library" name="Maven: org.elasticsearch.plugin:percolator-client:6.4.2" level="project" />
-    <orderEntry type="library" name="Maven: org.elasticsearch.plugin:parent-join-client:6.4.2" level="project" />
-    <orderEntry type="library" name="Maven: org.elasticsearch.plugin:rank-eval-client:6.4.2" level="project" />
-    <orderEntry type="library" name="Maven: com.fasterxml.jackson.core:jackson-core:2.9.7" level="project" />
-    <orderEntry type="library" name="Maven: org.elasticsearch.plugin:transport-netty4-client:6.4.2" level="project" />
-    <orderEntry type="library" name="Maven: io.netty:netty-buffer:4.1.29.Final" level="project" />
-    <orderEntry type="library" name="Maven: io.netty:netty-codec:4.1.29.Final" level="project" />
-    <orderEntry type="library" name="Maven: io.netty:netty-codec-http:4.1.29.Final" level="project" />
-    <orderEntry type="library" name="Maven: io.netty:netty-common:4.1.29.Final" level="project" />
-    <orderEntry type="library" name="Maven: io.netty:netty-handler:4.1.29.Final" level="project" />
-    <orderEntry type="library" name="Maven: io.netty:netty-resolver:4.1.29.Final" level="project" />
-    <orderEntry type="library" name="Maven: io.netty:netty-transport:4.1.29.Final" level="project" />
-    <orderEntry type="library" name="Maven: com.fasterxml.jackson.core:jackson-annotations:2.9.0" level="project" />
     <orderEntry type="module" module-name="drools-framework-business-proxy-persistence" />
     <orderEntry type="library" name="Maven: org.springframework.boot:spring-boot-starter-data-mongodb:2.1.0.RELEASE" level="project" />
     <orderEntry type="library" name="Maven: org.mongodb:mongodb-driver:3.8.2" level="project" />
     <orderEntry type="library" name="Maven: org.mongodb:bson:3.8.2" level="project" />
     <orderEntry type="library" name="Maven: org.mongodb:mongodb-driver-core:3.8.2" level="project" />
     <orderEntry type="library" name="Maven: org.springframework.data:spring-data-mongodb:2.1.2.RELEASE" level="project" />
+    <orderEntry type="library" name="Maven: org.springframework.data:spring-data-commons:2.1.2.RELEASE" level="project" />
+    <orderEntry type="library" name="Maven: com.fasterxml.jackson.core:jackson-annotations:2.9.0" level="project" />
     <orderEntry type="library" name="Maven: org.apache.camel:camel-ftp:2.23.0" level="project" />
     <orderEntry type="library" name="Maven: com.jcraft:jsch:0.1.54" level="project" />
     <orderEntry type="library" name="Maven: commons-net:commons-net:3.6" level="project" />
@@ -150,6 +96,7 @@
     <orderEntry type="library" name="Maven: com.google.guava:guava:13.0.1" level="project" />
     <orderEntry type="library" name="Maven: commons-io:commons-io:2.6" level="project" />
     <orderEntry type="library" name="Maven: com.fasterxml.jackson.core:jackson-databind:2.9.7" level="project" />
+    <orderEntry type="library" name="Maven: com.fasterxml.jackson.core:jackson-core:2.9.7" level="project" />
     <orderEntry type="library" name="Maven: org.kie:kie-internal:7.28.0.Final" level="project" />
     <orderEntry type="library" name="Maven: org.kie:kie-api:7.28.0.Final" level="project" />
     <orderEntry type="library" name="Maven: org.kie.soup:kie-soup-maven-support:7.28.0.Final" level="project" />

drools-framework-business-proxy-parent/drools-framework-business-indexer-app/pom.xml

@@ -52,11 +52,7 @@
             <groupId>org.apache.camel</groupId>
             <artifactId>camel-quartz2</artifactId>
         </dependency>
-        <dependency>
+
-            <groupId>com.pymmasoftware.jbpm</groupId>
-            <artifactId>drools-framework-business-indexer-persistence</artifactId>
-            <version>${project.version}</version>
-        </dependency>
         <dependency>
             <groupId>com.pymmasoftware.jbpm</groupId>
             <artifactId>drools-framework-business-proxy-persistence</artifactId>

drools-framework-business-proxy-parent/drools-framework-business-indexer-app/src/main/java/org/chtijbug/drools/indexer/DroolsBusinessIndexerServer.java

@@ -19,14 +19,14 @@ package org.chtijbug.drools.indexer;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 import org.springframework.context.annotation.Configuration;
-import org.springframework.data.elasticsearch.repository.config.EnableElasticsearchRepositories;
+
 import org.springframework.data.mongodb.repository.config.EnableMongoRepositories;
 
 // CHECKSTYLE:OFF
 @SpringBootApplication
 @Configuration
 @EnableMongoRepositories(basePackages = "org.chtijbug.drools.proxy.persistence.repository")
-@EnableElasticsearchRepositories(basePackages = "org.chtijbug.drools.indexer.persistence.repository")
+
 public class DroolsBusinessIndexerServer {
 
 

drools-framework-business-proxy-parent/drools-framework-business-indexer-app/src/main/java/org/chtijbug/drools/indexer/service/StoreLoggingService.java

@@ -2,12 +2,12 @@ package org.chtijbug.drools.indexer.service;
 
 import com.fasterxml.jackson.databind.ObjectMapper;
 import org.chtijbug.drools.SessionContext;
-import org.chtijbug.drools.indexer.persistence.model.BusinessTransactionAction;
-import org.chtijbug.drools.indexer.persistence.model.BusinessTransactionPersistence;
-import org.chtijbug.drools.indexer.persistence.model.EventType;
-import org.chtijbug.drools.indexer.persistence.repository.BusinessTransactionActionRepository;
-import org.chtijbug.drools.indexer.persistence.repository.BusinessTransactionPersistenceRepository;
 import org.chtijbug.drools.logging.*;
+import org.chtijbug.drools.proxy.persistence.model.BusinessTransactionAction;
+import org.chtijbug.drools.proxy.persistence.model.BusinessTransactionPersistence;
+import org.chtijbug.drools.proxy.persistence.model.EventType;
+import org.chtijbug.drools.proxy.persistence.repository.BusinessTransactionActionRepository;
+import org.chtijbug.drools.proxy.persistence.repository.BusinessTransactionPersistenceRepository;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 

drools-framework-business-proxy-parent/drools-framework-business-reverse-proxy/drools-framework-business-reverse-proxy.iml

@@ -34,6 +34,16 @@
     <orderEntry type="library" name="Maven: org.springframework:spring-tx:5.1.2.RELEASE" level="project" />
     <orderEntry type="library" name="Maven: org.springframework.data:spring-data-commons:2.1.2.RELEASE" level="project" />
     <orderEntry type="library" name="Maven: com.fasterxml.jackson.core:jackson-annotations:2.9.0" level="project" />
+    <orderEntry type="module" module-name="drools-framework-runtime-entity" />
+    <orderEntry type="module" module-name="drools-framework-common" />
+    <orderEntry type="library" name="Maven: junit:junit:4.12" level="project" />
+    <orderEntry type="library" name="Maven: org.hamcrest:hamcrest-core:1.3" level="project" />
+    <orderEntry type="library" name="Maven: com.google.guava:guava:13.0.1" level="project" />
+    <orderEntry type="library" name="Maven: com.fasterxml.jackson.core:jackson-databind:2.9.7" level="project" />
+    <orderEntry type="library" name="Maven: com.fasterxml.jackson.core:jackson-core:2.9.7" level="project" />
+    <orderEntry type="library" name="Maven: org.kie:kie-internal:7.28.0.Final" level="project" />
+    <orderEntry type="library" name="Maven: org.kie:kie-api:7.28.0.Final" level="project" />
+    <orderEntry type="library" name="Maven: org.kie.soup:kie-soup-maven-support:7.28.0.Final" level="project" />
     <orderEntry type="library" name="Maven: com.github.mkopylec:charon-spring-boot-starter:3.1.0" level="project" />
     <orderEntry type="library" name="Maven: org.springframework.boot:spring-boot-starter-web:2.1.0.RELEASE" level="project" />
     <orderEntry type="library" name="Maven: org.springframework.boot:spring-boot-starter:2.1.0.RELEASE" level="project" />
@@ -48,8 +58,6 @@
     <orderEntry type="library" name="Maven: javax.annotation:javax.annotation-api:1.3.2" level="project" />
     <orderEntry type="library" scope="RUNTIME" name="Maven: org.yaml:snakeyaml:1.23" level="project" />
     <orderEntry type="library" name="Maven: org.springframework.boot:spring-boot-starter-json:2.1.0.RELEASE" level="project" />
-    <orderEntry type="library" name="Maven: com.fasterxml.jackson.core:jackson-databind:2.9.7" level="project" />
-    <orderEntry type="library" name="Maven: com.fasterxml.jackson.core:jackson-core:2.9.7" level="project" />
     <orderEntry type="library" name="Maven: com.fasterxml.jackson.datatype:jackson-datatype-jdk8:2.9.7" level="project" />
     <orderEntry type="library" name="Maven: com.fasterxml.jackson.datatype:jackson-datatype-jsr310:2.9.7" level="project" />
     <orderEntry type="library" name="Maven: com.fasterxml.jackson.module:jackson-module-parameter-names:2.9.7" level="project" />

drools-framework-business-proxy-parent/drools-framewwork-business-proxy-persistence/pom.xml

@@ -35,6 +35,11 @@
             <version>2.9.7</version>
             <scope>compile</scope>
         </dependency>
+        <dependency>
+            <groupId>com.pymmasoftware.jbpm</groupId>
+            <artifactId>drools-framework-runtime-entity</artifactId>
+            <version>${project.version}</version>
+        </dependency>
     </dependencies>
     <build>
         <plugins>

drools-framework-business-proxy-parent/drools-framewwork-business-proxy-persistence/src/main/java/org/chtijbug/drools/proxy/persistence/model/BusinessTransactionAction.java

@@ -0,0 +1,136 @@
+package org.chtijbug.drools.proxy.persistence.model;
+
+
+import org.chtijbug.drools.logging.Fact;
+import org.chtijbug.drools.logging.RuleExecution;
+import org.springframework.data.annotation.Id;
+import org.springframework.data.mongodb.core.mapping.Document;
+import org.springframework.data.mongodb.core.mapping.Field;
+
+
+@Document
+public class BusinessTransactionAction {
+    @Id
+    private String id;
+
+    @Field
+    private EventType eventType;
+
+    private long eventNumber;
+
+    private String businessTransactionId;
+
+
+    private Fact inputData;
+
+
+    private Fact outputData;
+
+
+    private RuleExecution ruleExecution;
+
+
+    private Fact fact;
+
+
+    private String processID;
+
+    private String ruleflowGroupName;
+
+    public String getId() {
+        return id;
+    }
+
+    public void setId(String id) {
+        this.id = id;
+    }
+
+    public EventType getEventType() {
+        return eventType;
+    }
+
+    public void setEventType(EventType eventType) {
+        this.eventType = eventType;
+    }
+
+    public long getEventNumber() {
+        return eventNumber;
+    }
+
+    public void setEventNumber(long eventNumber) {
+        this.eventNumber = eventNumber;
+    }
+
+    public String getBusinessTransactionId() {
+        return businessTransactionId;
+    }
+
+    public void setBusinessTransactionId(String businessTransactionId) {
+        this.businessTransactionId = businessTransactionId;
+    }
+
+    public Fact getInputData() {
+        return inputData;
+    }
+
+    public void setInputData(Fact inputData) {
+        this.inputData = inputData;
+    }
+
+    public Fact getOutputData() {
+        return outputData;
+    }
+
+    public void setOutputData(Fact outputData) {
+        this.outputData = outputData;
+    }
+
+    public RuleExecution getRuleExecution() {
+        return ruleExecution;
+    }
+
+    public void setRuleExecution(RuleExecution ruleExecution) {
+        this.ruleExecution = ruleExecution;
+    }
+
+    public String getProcessID() {
+        return processID;
+    }
+
+    public void setProcessID(String processID) {
+        this.processID = processID;
+    }
+
+    public String getRuleflowGroupName() {
+        return ruleflowGroupName;
+    }
+
+    public void setRuleflowGroupName(String ruleflowGroupName) {
+        this.ruleflowGroupName = ruleflowGroupName;
+    }
+
+    public Fact getFact() {
+        return fact;
+    }
+
+    public void setFact(Fact fact) {
+        this.fact = fact;
+    }
+
+    @Override
+    public String toString() {
+        final StringBuffer sb = new StringBuffer("BusinessTransactionAction{");
+        sb.append("id='").append(id).append('\'');
+        sb.append(", eventType=").append(eventType);
+        sb.append(", eventNumber=").append(eventNumber);
+        sb.append(", businessTransactionId='").append(businessTransactionId).append('\'');
+        sb.append(", inputData=").append(inputData);
+        sb.append(", outputData=").append(outputData);
+        sb.append(", ruleExecution=").append(ruleExecution);
+        sb.append(", fact=").append(fact);
+        sb.append(", processID='").append(processID).append('\'');
+        sb.append(", ruleflowGroupName='").append(ruleflowGroupName).append('\'');
+        sb.append('}');
+        return sb.toString();
+    }
+}

drools-framework-business-proxy-parent/drools-framewwork-business-proxy-persistence/src/main/java/org/chtijbug/drools/proxy/persistence/model/BusinessTransactionPersistence.java

@@ -0,0 +1,156 @@
+package org.chtijbug.drools.proxy.persistence.model;
+
+
+import org.springframework.data.annotation.Id;
+import org.springframework.data.mongodb.core.index.Indexed;
+import org.springframework.data.mongodb.core.mapping.Document;
+
+
+@Document
+public class BusinessTransactionPersistence {
+
+    @Id
+    private String id;
+    @Indexed
+    private String transactionId;
+
+    private Integer year;
+
+    private Integer month;
+
+    private Integer day;
+
+    private Integer hour;
+
+    private Integer minute;
+
+    private Integer second;
+
+    private Integer millis;
+
+    private String groupID;
+
+    private String artefactID;
+
+    private String version;
+
+    private String containerId;
+
+    private String serverName;
+
+
+
+    public String getId() {
+        return id;
+    }
+
+    public void setId(String id) {
+        this.id = id;
+    }
+
+    public String getTransactionId() {
+        return transactionId;
+    }
+
+    public void setTransactionId(String transactionId) {
+        this.transactionId = transactionId;
+    }
+
+    public Integer getYear() {
+        return year;
+    }
+
+    public void setYear(Integer year) {
+        this.year = year;
+    }
+
+    public Integer getMonth() {
+        return month;
+    }
+
+    public void setMonth(Integer month) {
+        this.month = month;
+    }
+
+    public Integer getDay() {
+        return day;
+    }
+
+    public void setDay(Integer day) {
+        this.day = day;
+    }
+
+    public Integer getHour() {
+        return hour;
+    }
+
+    public void setHour(Integer hour) {
+        this.hour = hour;
+    }
+
+    public Integer getMinute() {
+        return minute;
+    }
+
+    public void setMinute(Integer minute) {
+        this.minute = minute;
+    }
+
+    public Integer getSecond() {
+        return second;
+    }
+
+    public void setSecond(Integer second) {
+        this.second = second;
+    }
+
+    public Integer getMillis() {
+        return millis;
+    }
+
+    public void setMillis(Integer millis) {
+        this.millis = millis;
+    }
+
+    public String getGroupID() {
+        return groupID;
+    }
+
+    public void setGroupID(String groupID) {
+        this.groupID = groupID;
+    }
+
+    public String getArtefactID() {
+        return artefactID;
+    }
+
+    public void setArtefactID(String artefactID) {
+        this.artefactID = artefactID;
+    }
+
+    public String getVersion() {
+        return version;
+    }
+
+    public void setVersion(String version) {
+        this.version = version;
+    }
+
+    public String getContainerId() {
+        return containerId;
+    }
+
+    public void setContainerId(String containerId) {
+        this.containerId = containerId;
+    }
+
+    public String getServerName() {
+        return serverName;
+    }
+
+    public void setServerName(String serverName) {
+        this.serverName = serverName;
+    }
+
+
+}

drools-framework-business-proxy-parent/drools-framewwork-business-proxy-persistence/src/main/java/org/chtijbug/drools/proxy/persistence/model/EventType.java

@@ -0,0 +1,5 @@
+package org.chtijbug.drools.proxy.persistence.model;
+
+public enum EventType {
+    INPUT,OUPUT,INSERTFACT, UPDATEFACTOLDVALUE, UPDATEFACTNEWVALUE,RETRACTFACT,RULE,STARTPROCESS,STOPPROCESS, STARTRULEFLOWGROUP,STOPTRULEFLOWGROUP
+}

drools-framework-business-proxy-parent/drools-framewwork-business-proxy-persistence/src/main/java/org/chtijbug/drools/proxy/persistence/repository/BusinessTransactionActionRepository.java

@@ -0,0 +1,15 @@
+package org.chtijbug.drools.proxy.persistence.repository;
+
+
+import org.chtijbug.drools.proxy.persistence.model.BusinessTransactionAction;
+import org.springframework.data.domain.PageRequest;
+import org.springframework.data.domain.Sort;
+import org.springframework.data.mongodb.repository.MongoRepository;
+
+import java.util.List;
+
+public interface BusinessTransactionActionRepository extends MongoRepository<BusinessTransactionAction,String> {
+
+    public List<BusinessTransactionAction> findAllByBusinessTransactionId(String businessTransactionId, Sort sort, PageRequest pageRequest);
+
+}

drools-framework-business-proxy-parent/drools-framewwork-business-proxy-persistence/src/main/java/org/chtijbug/drools/proxy/persistence/repository/BusinessTransactionPersistenceRepository.java

@@ -0,0 +1,17 @@
+package org.chtijbug.drools.proxy.persistence.repository;
+
+
+import org.chtijbug.drools.proxy.persistence.model.BusinessTransactionPersistence;
+import org.springframework.data.domain.PageRequest;
+import org.springframework.data.mongodb.repository.MongoRepository;
+
+import java.util.List;
+
+public interface BusinessTransactionPersistenceRepository extends MongoRepository<BusinessTransactionPersistence,String> {
+
+    public BusinessTransactionPersistence findAllById(String id, PageRequest pageRequest);
+
+    public List<BusinessTransactionPersistence> findAllByTransactionId(String transactionId, PageRequest pageRequest);
+
+}
+