Adding PYMMA_OPTS environnement variable => Add JAVA OPTS to drools runtime
When runtime is restarted can update hostname => Hostname can be renamed when updated docker container Using PYMMA_OPTS in docker compose file to indentify runtime proxy (drools runtime)
This commit is contained in:
parent
1188a69a71
commit
abb48f9d7d
3 changed files with 29 additions and 11 deletions
|
|
@ -46,6 +46,8 @@ services:
|
||||||
runtime-proxy-1:
|
runtime-proxy-1:
|
||||||
image: runtime-proxy
|
image: runtime-proxy
|
||||||
container_name: "runtime-proxy-1"
|
container_name: "runtime-proxy-1"
|
||||||
|
environment:
|
||||||
|
PYMMA_OPTS: "-Dorg.kie.server.id=server1"
|
||||||
networks:
|
networks:
|
||||||
drools-network-dev:
|
drools-network-dev:
|
||||||
ipv4_address: 172.27.1.22
|
ipv4_address: 172.27.1.22
|
||||||
|
|
@ -63,6 +65,8 @@ services:
|
||||||
runtime-proxy-2:
|
runtime-proxy-2:
|
||||||
image: runtime-proxy
|
image: runtime-proxy
|
||||||
container_name: "runtime-proxy-2"
|
container_name: "runtime-proxy-2"
|
||||||
|
environment:
|
||||||
|
PYMMA_OPTS: "-Dorg.kie.server.id=server2"
|
||||||
networks:
|
networks:
|
||||||
drools-network-dev:
|
drools-network-dev:
|
||||||
ipv4_address: 172.27.1.32
|
ipv4_address: 172.27.1.32
|
||||||
|
|
@ -80,6 +84,8 @@ services:
|
||||||
runtime-proxy-3:
|
runtime-proxy-3:
|
||||||
image: runtime-proxy
|
image: runtime-proxy
|
||||||
container_name: "runtime-proxy-3"
|
container_name: "runtime-proxy-3"
|
||||||
|
environment:
|
||||||
|
PYMMA_OPTS: "-Dorg.kie.server.id=server3"
|
||||||
networks:
|
networks:
|
||||||
drools-network-dev:
|
drools-network-dev:
|
||||||
ipv4_address: 172.27.1.42
|
ipv4_address: 172.27.1.42
|
||||||
|
|
@ -97,6 +103,8 @@ services:
|
||||||
runtime-proxy-4:
|
runtime-proxy-4:
|
||||||
image: runtime-proxy
|
image: runtime-proxy
|
||||||
container_name: "runtime-proxy-4"
|
container_name: "runtime-proxy-4"
|
||||||
|
environment:
|
||||||
|
PYMMA_OPTS: "-Dorg.kie.server.id=server4"
|
||||||
networks:
|
networks:
|
||||||
drools-network-dev:
|
drools-network-dev:
|
||||||
ipv4_address: 172.27.1.52
|
ipv4_address: 172.27.1.52
|
||||||
|
|
@ -114,6 +122,8 @@ services:
|
||||||
runtime-proxy-5:
|
runtime-proxy-5:
|
||||||
image: runtime-proxy
|
image: runtime-proxy
|
||||||
container_name: "runtime-proxy-5"
|
container_name: "runtime-proxy-5"
|
||||||
|
environment:
|
||||||
|
PYMMA_OPTS: "-Dorg.kie.server.id=server5"
|
||||||
networks:
|
networks:
|
||||||
drools-network-dev:
|
drools-network-dev:
|
||||||
ipv4_address: 172.27.1.62
|
ipv4_address: 172.27.1.62
|
||||||
|
|
|
||||||
|
|
@ -14,4 +14,4 @@ RUN mkdir /niodir-kieserver
|
||||||
RUN bash -c 'touch /app.jar'
|
RUN bash -c 'touch /app.jar'
|
||||||
ENV JAVA_OPTS "-Dspring.config.location=file:./ -DM2_HOME=/m2_kieserver -Dorg.chtijbug.server.tracedir=/trace -Dorg.appformer.m2repo.url=http://kie-wb:8080/kie-wb/maven2 -Dorg.uberfire.nio.git.dir=/niodir-kieserver -Dkie.maven.settings.custom=/m2_kieserver/settings.xml -Dorg.kie.server.repo=/niodir-kieserver -Dfile.encoding=UTF-8 -Duser.language=fr -Duser.country=FR -Dorg.chtijbug.server.sftpPort=9080"
|
ENV JAVA_OPTS "-Dspring.config.location=file:./ -DM2_HOME=/m2_kieserver -Dorg.chtijbug.server.tracedir=/trace -Dorg.appformer.m2repo.url=http://kie-wb:8080/kie-wb/maven2 -Dorg.uberfire.nio.git.dir=/niodir-kieserver -Dkie.maven.settings.custom=/m2_kieserver/settings.xml -Dorg.kie.server.repo=/niodir-kieserver -Dfile.encoding=UTF-8 -Duser.language=fr -Duser.country=FR -Dorg.chtijbug.server.sftpPort=9080"
|
||||||
|
|
||||||
ENTRYPOINT exec java $JAVA_OPTS -jar /app.jar
|
ENTRYPOINT exec java $JAVA_OPTS $PYMMA_OPTS -jar /app.jar
|
||||||
|
|
@ -71,34 +71,28 @@ public class KieServiceCommon {
|
||||||
|
|
||||||
public KieServiceCommon() {
|
public KieServiceCommon() {
|
||||||
// for now, if no server impl is passed as parameter, create one
|
// for now, if no server impl is passed as parameter, create one
|
||||||
System.out.println("step01");
|
|
||||||
this.server = KieServerLocator.getInstance();
|
this.server = KieServerLocator.getInstance();
|
||||||
System.out.println("step02");
|
|
||||||
List<KieServerExtension> serverExtensions = this.server.getServerExtensions();
|
List<KieServerExtension> serverExtensions = this.server.getServerExtensions();
|
||||||
System.out.println("step03");
|
|
||||||
for (KieServerExtension serverExtension : serverExtensions) {
|
for (KieServerExtension serverExtension : serverExtensions) {
|
||||||
if (serverExtension instanceof DroolsChtijbugKieServerExtension) {
|
if (serverExtension instanceof DroolsChtijbugKieServerExtension) {
|
||||||
droolsChtijbugKieServerExtension = (DroolsChtijbugKieServerExtension) serverExtension;
|
droolsChtijbugKieServerExtension = (DroolsChtijbugKieServerExtension) serverExtension;
|
||||||
System.out.println("step03a");
|
|
||||||
if (droolsChtijbugRulesExecutionService == null) {
|
if (droolsChtijbugRulesExecutionService == null) {
|
||||||
|
|
||||||
droolsChtijbugRulesExecutionService = droolsChtijbugKieServerExtension.getRulesExecutionService();
|
droolsChtijbugRulesExecutionService = droolsChtijbugKieServerExtension.getRulesExecutionService();
|
||||||
System.out.println("step03b");
|
|
||||||
}
|
}
|
||||||
if (registry == null) {
|
if (registry == null) {
|
||||||
registry = droolsChtijbugRulesExecutionService.getContext();
|
registry = droolsChtijbugRulesExecutionService.getContext();
|
||||||
System.out.println("step03c");
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
System.out.println("step04");
|
|
||||||
this.marshallerHelper = new MarshallerHelper(this.server.getServerRegistry());
|
this.marshallerHelper = new MarshallerHelper(this.server.getServerRegistry());
|
||||||
System.out.println("step05");
|
|
||||||
}
|
}
|
||||||
|
|
||||||
public static String getKieServerID(){
|
public static String getKieServerID(){
|
||||||
return System.getProperty("org.kie.server.id");
|
return System.getProperty("org.kie.server.id");
|
||||||
}
|
}
|
||||||
|
|
||||||
@PostConstruct
|
@PostConstruct
|
||||||
private void initCamelBusinessRoutes() {
|
private void initCamelBusinessRoutes() {
|
||||||
String serverName = KieServiceCommon.getKieServerID();
|
String serverName = KieServiceCommon.getKieServerID();
|
||||||
|
|
@ -114,11 +108,25 @@ public class KieServiceCommon {
|
||||||
} catch (UnknownHostException e) {
|
} catch (UnknownHostException e) {
|
||||||
logger.info("initCamelBusinessRoutes.getLocalHost", e);
|
logger.info("initCamelBusinessRoutes.getLocalHost", e);
|
||||||
}
|
}
|
||||||
RuntimePersist runtimePersist = new RuntimePersist(serverName, version, "http://" + hostName + ":" + serverPort, String.valueOf(serverPort), sftpPort,hostName,RuntimePersist.STATUS.UP.toString());
|
RuntimePersist runtimePersist = new RuntimePersist(serverName, version, "http://" + hostName + ":" + serverPort,
|
||||||
|
String.valueOf(serverPort), sftpPort,
|
||||||
|
hostName,RuntimePersist.STATUS.UP.toString());
|
||||||
runtimeRepository.save(runtimePersist);
|
runtimeRepository.save(runtimePersist);
|
||||||
}else{
|
}else{
|
||||||
RuntimePersist runtimePersist =itIsMes.get(0);
|
RuntimePersist runtimePersist =itIsMes.get(0);
|
||||||
runtimePersist.setStatus(RuntimePersist.STATUS.UP.toString());
|
runtimePersist.setStatus(RuntimePersist.STATUS.UP.toString());
|
||||||
|
try {
|
||||||
|
/**
|
||||||
|
* HostName may have changed by reboot so retake it and save it
|
||||||
|
*/
|
||||||
|
InetAddress inetAddress = InetAddress.getLocalHost();
|
||||||
|
String hostName = inetAddress.getHostName();
|
||||||
|
runtimePersist.setHostname("http://" + hostName + ":" + serverPort);
|
||||||
|
runtimePersist.setSftpHost(hostName);
|
||||||
|
runtimePersist.setSftpPort(sftpPort);
|
||||||
|
} catch (UnknownHostException e) {
|
||||||
|
logger.info("initCamelBusinessRoutes.getLocalHost", e);
|
||||||
|
}
|
||||||
runtimeRepository.save(runtimePersist);
|
runtimeRepository.save(runtimePersist);
|
||||||
}
|
}
|
||||||
try {
|
try {
|
||||||
|
|
|
||||||
Loading…
Add table
editor.link_modal.header
Reference in a new issue