Merge pull request #124 from pymma/kafka

Kafka
This commit is contained in:
Nicolas Héron 2020-09-15 18:32:22 +02:00 committed by GitHub
commit 3ce95b29a9
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
6 changed files with 9 additions and 11 deletions

View file

@ -12,8 +12,7 @@ org.kie.server.location=${PYMMA_KIE_LOCATION:http://localhost:8200/api/server}
org.kie.server.id=${PYMMA_KIE_SERVER_ID:pymmaConsole2} org.kie.server.id=${PYMMA_KIE_SERVER_ID:pymmaConsole2}
spring.data.mongodb.database=${PYMMA_MONGO_DATABASE:businessProxyDB} spring.data.mongodb.database=${PYMMA_MONGO_DATABASE:businessProxyDB}
spring.data.mongodb.host=${PYMMA_MONGO_HOST:localhost:28017} spring.data.mongodb.host=${PYMMA_MONGO_HOST:localhost:28017}
spring.data.mongodb.password=${PYMMA_MONGO_PASSWORD}
spring.data.mongodb.username=${PYMMA_MONGO_USERNAME}
spring.servlet.multipart.enabled=false spring.servlet.multipart.enabled=false
kafka.bootstrapAddress=${PYMMA_KAFKA_BOOTSTRAP:localhost:9092,localhost:9093,localhost:9094} kafka.bootstrapAddress=${PYMMA_KAFKA_BOOTSTRAP:localhost:9092,localhost:9093,localhost:9094}

View file

@ -207,13 +207,14 @@ public class RuleBaseSingleton implements RuleBasePackage {
//_____ Wrapping the knowledge Session //_____ Wrapping the knowledge Session
newRuleBaseSession = new RuleBaseStatefulSession(this.ruleBaseID, sessionId, newDroolsSession, maxNumberRulesToExecute, sessionHistoryListener); newRuleBaseSession = new RuleBaseStatefulSession(this.ruleBaseID, sessionId, newDroolsSession, maxNumberRulesToExecute, sessionHistoryListener);
//_____ Release semaphore //_____ Release semaphore
lockKbase.release();
} else { } else {
throw new DroolsChtijbugException(DroolsChtijbugException.KbaseNotInitialised, "", null); throw new DroolsChtijbugException(DroolsChtijbugException.KbaseNotInitialised, "", null);
} }
//____ return the wrapped KnowledgeSession //____ return the wrapped KnowledgeSession
return newRuleBaseSession; return newRuleBaseSession;
} finally { } finally {
lockKbase.release();
logger.debug("<<createRuleBaseSession", newRuleBaseSession); logger.debug("<<createRuleBaseSession", newRuleBaseSession);
} }
} }

View file

@ -5,7 +5,6 @@ kieserver.password=${PYMMA_KIE_SERVEUR_PASSWORD:kieserver1}
kafka.index.groupid=${PYMMA_KIE_SERVEUR_GROUPID:index1} kafka.index.groupid=${PYMMA_KIE_SERVEUR_GROUPID:index1}
spring.data.mongodb.database=${PYMMA_MONGO_DATABASE:businessProxyDB} spring.data.mongodb.database=${PYMMA_MONGO_DATABASE:businessProxyDB}
spring.data.mongodb.host=${PYMMA_MONGO_HOST:localhost:28017} spring.data.mongodb.host=${PYMMA_MONGO_HOST:localhost:28017}
spring.data.mongodb.password=${PYMMA_MONGO_PASSWORD}
spring.data.mongodb.username=${PYMMA_MONGO_USERNAME}
server.port=${port:5547} server.port=${port:5547}

View file

@ -20,7 +20,7 @@ camel.springboot.name=MyCamel
# to reconfigure the camel servlet context-path mapping to use /api/* instead of /camel/* # to reconfigure the camel servlet context-path mapping to use /api/* instead of /camel/*
camel.component.servlet.mapping.context-path=/api/* camel.component.servlet.mapping.context-path=/api/*
spring.data.mongodb.host=${PYMMA_MONGO_HOST:mongodb:27017} spring.data.mongodb.host=${PYMMA_MONGO_HOST:mongodb:27017}
spring.data.mongodb.database=${PYMMA_MONGO_DATABASE:businessProxyDB:} spring.data.mongodb.database=${PYMMA_MONGO_DATABASE:businessProxyDB}
spring.data.mongodb.password=${PYMMA_MONGO_PASSWORD} spring.data.mongodb.password=${PYMMA_MONGO_PASSWORD}
spring.data.mongodb.username=${PYMMA_MONGO_USERNAME} spring.data.mongodb.username=${PYMMA_MONGO_USERNAME}
kie-wb.m2repo=${PYMMA_M2_REPO:http://kie-wb:8080/kie-wb/maven2/} kie-wb.m2repo=${PYMMA_M2_REPO:http://kie-wb:8080/kie-wb/maven2/}

View file

@ -19,10 +19,10 @@ server.port=8090
camel.springboot.name=MyCamel camel.springboot.name=MyCamel
# to reconfigure the camel servlet context-path mapping to use /api/* instead of /camel/* # to reconfigure the camel servlet context-path mapping to use /api/* instead of /camel/*
camel.component.servlet.mapping.context-path=/api/* camel.component.servlet.mapping.context-path=/api/*
spring.data.mongodb.database=${PYMMA_MONGO_DATABASE:businessProxyDB:} spring.data.mongodb.database=${PYMMA_MONGO_DATABASE:businessProxyDB}
spring.data.mongodb.host=${PYMMA_MONGO_HOST:localhost:28017:} spring.data.mongodb.host=${PYMMA_MONGO_HOST:localhost:28017}
eureka.client.service-url.defaultZone=http://127.0.0.1:8761/eureka/ eureka.client.service-url.defaultZone=http://127.0.0.1:8761/eureka/
spring.application.name=proxy-app-${org.kie.server.id} spring.application.name=proxy-app-${org.kie.server.id}
kafka.bootstrapAddress=${PYMMA_KAFKA_BOOTSTRAP:localhost:9092,localhost:9093,localhost:9094:} kafka.bootstrapAddress=${PYMMA_KAFKA_BOOTSTRAP:localhost:9092,localhost:9093,localhost:9094}

View file

@ -1,7 +1,6 @@
server.port=${port:9500} server.port=${port:9500}
spring.data.mongodb.database=${PYMMA_MONGO_DATABASE:businessProxyDB} spring.data.mongodb.database=${PYMMA_MONGO_DATABASE:businessProxyDB}
spring.data.mongodb.host=${PYMMA_MONGO_HOST:localhost:28017} spring.data.mongodb.host=${PYMMA_MONGO_HOST:localhost:28017}
spring.data.mongodb.password=${PYMMA_MONGO_PASSWORD}
spring.data.mongodb.username=${PYMMA_MONGO_USERNAME}
charon.tracing.enabled=true charon.tracing.enabled=true
kafka.bootstrapAddress=${PYMMA_KAFKA_BOOTSTRAP:localhost:9092,localhost:9093,localhost:9094} kafka.bootstrapAddress=${PYMMA_KAFKA_BOOTSTRAP:localhost:9092,localhost:9093,localhost:9094}