nheron/kie-platform
nheron/kie-platform
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

Suppression parametre ContainerID

Browse source
This commit is contained in:
Nicolas Héron 2019-01-22 11:21:22 +01:00
commit fb0b9fde30
1 changed files with 7 additions and 8 deletions
Download patch file Download diff file Expand all files Collapse all files

15
drools-framework-business-proxy-parent/drools-framework-business-proxy-app/src/main/java/org/chtijbug/drools/proxy/camel/DroolsRouter.java
View file

@ -7,20 +7,19 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
import static org.apache.camel.model.rest.RestParamType.body; import static org.apache.camel.model.rest.RestParamType.body;
import static org.apache.camel.model.rest.RestParamType.path;
public class DroolsRouter extends RouteBuilder { public class DroolsRouter extends RouteBuilder {
private static final Logger logger = LoggerFactory.getLogger(DroolsRouter.class); private static final Logger logger = LoggerFactory.getLogger(DroolsRouter.class);
private String projectName ; private String containerId;
private KieContainerInstance kci; private KieContainerInstance kci;
private Class<?> clazzUser; private Class<?> clazzUser;
private String processID; private String processID;
public DroolsRouter(CamelContext camelContext,Class<?> clazzUser, String projectName,KieContainerInstance kci,String processID) { public DroolsRouter(CamelContext camelContext, Class<?> clazzUser, String containerId, KieContainerInstance kci, String processID) {
super(camelContext); super(camelContext);
this.clazzUser = clazzUser; this.clazzUser = clazzUser;
this.projectName=projectName; this.containerId = containerId;
this.kci = kci; this.kci = kci;
this.processID = processID; this.processID = processID;
} }
@ -30,15 +29,15 @@ public class DroolsRouter extends RouteBuilder {
System.out.println("coucou"); System.out.println("coucou");
rest("/" + projectName).description(projectName + " Rest service") rest("/" + containerId).description(containerId + " Rest service")
.consumes("application/json") .consumes("application/json")
.produces("application/json") .produces("application/json")
.put("/{containerId}").description("Execute Business Service").type(clazzUser).outType(clazzUser) .put("/").description("Execute Business Service").type(clazzUser).outType(clazzUser)
.param().name("containerId").type(path).description("Container ID where the rule artefact id deployed").dataType("integer").endParam() // .param().name("containerId").type(path).description("Container ID where the rule artefact id deployed").dataType("integer").endParam()
.param().name("body").type(body).description("The Data drools should work on").endParam() .param().name("body").type(body).description("The Data drools should work on").endParam()
.responseMessage().code(200).message("Data drools worked on").endResponseMessage() .responseMessage().code(200).message("Data drools worked on").endResponseMessage()
.to("bean:ruleService?method=runSessionObject(${header.containerId},"+this.processID+",${body})"); .to("bean:ruleService?method=runSessionObject("+this.containerId+","+this.processID+",${body})");
} }