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

log(kieCommon) : add some log to kieCommon

Browse source
This commit is contained in:
Sébastien Velay 2020-10-01 10:14:31 +02:00
commit 7331b631b6
1 changed files with 5 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

6
drools-framework-business-proxy-parent/drools-framework-business-proxy-app/src/main/java/org/chtijbug/drools/proxy/service/KieServiceCommon.java
View file

@ -430,15 +430,17 @@ public class KieServiceCommon {
} }
@Scheduled(fixedDelay = 5000) @Scheduled(fixedDelay = 5000)
public void updateConfig(){ public void updateConfig(){
logger.info("updateConfig - check for new version to deploy");
try { try {
String serverName = KieServiceCommon.getKieServerID(); String serverName = KieServiceCommon.getKieServerID();
List<ContainerRuntimePojoPersist> containerRuntimePojoPersists = containerRuntimeRepository.findByServerNameAndHostname(serverName, hostName); List<ContainerRuntimePojoPersist> containerRuntimePojoPersists = containerRuntimeRepository.findByServerNameAndHostname(serverName, hostName);
for (ContainerRuntimePojoPersist element : containerRuntimePojoPersists) { for (ContainerRuntimePojoPersist element : containerRuntimePojoPersists) {
logger.info("runtime {} has status {}",element.getContainerId(),element.getStatus());
ContainerPojoPersist containerPojoPersist = containerRepository.findByServerNameAndContainerId(serverName, element.getContainerId()); ContainerPojoPersist containerPojoPersist = containerRepository.findByServerNameAndContainerId(serverName, element.getContainerId());
if (element.getStatus().equals(ContainerRuntimePojoPersist.STATUS.TODEPLOY.name())) { if (element.getStatus().equals(ContainerRuntimePojoPersist.STATUS.TODEPLOY.name())) {
logger.info("start deploy new container");
this.disposeContainer(element.getContainerId()); this.disposeContainer(element.getContainerId());
KieContainerResource newContainer = new KieContainerResource(); KieContainerResource newContainer = new KieContainerResource();
newContainer.setContainerId(element.getContainerId()); newContainer.setContainerId(element.getContainerId());
@ -447,7 +449,9 @@ public class KieServiceCommon {
newContainer.getReleaseId().setGroupId(containerPojoPersist.getGroupId()); newContainer.getReleaseId().setGroupId(containerPojoPersist.getGroupId());
newContainer.getReleaseId().setVersion(containerPojoPersist.getVersion()); newContainer.getReleaseId().setVersion(containerPojoPersist.getVersion());
this.createContainer(element.getContainerId(), newContainer); this.createContainer(element.getContainerId(), newContainer);
logger.info("container created {}",element.getContainerId());
this.initCamelBusinessRoute(containerPojoPersist); this.initCamelBusinessRoute(containerPojoPersist);
logger.info("route created");
element.setStatus(ContainerRuntimePojoPersist.STATUS.UP.toString()); element.setStatus(ContainerRuntimePojoPersist.STATUS.UP.toString());
containerRuntimeRepository.save(element); containerRuntimeRepository.save(element);