Merge pull request #139 from pymma/kafka

Add System.getProperty("org.kie.server.swarm.port") to make differenc…
This commit is contained in:
Nicolas Héron 2020-09-21 16:33:58 +02:00 committed by GitHub
commit 6b6be804de
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23

View file

@ -157,7 +157,13 @@ public class KieServiceCommon {
}
String isSwarm = System.getProperty("org.kie.server.swarm");
if ("1".equals(isSwarm)) {
runtimePersist.setServerUrl("http://" + serverName + ":" + serverPort);
if (System.getProperty("org.kie.server.swarm.port")!= null &&
System.getProperty("org.kie.server.swarm.port").length()>0){
runtimePersist.setServerUrl("http://" + serverName + ":" + System.getProperty("org.kie.server.swarm.port"));
}else{
runtimePersist.setServerUrl("http://" + serverName + ":" + serverPort);
}
} else {
if (runtimePort==-1) {
runtimePersist.setServerUrl("http://" + hostName + ":" + serverPort);