This is an automated email from the ASF dual-hosted git repository.
mariofusco pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/incubator-kie-drools.git
The following commit(s) were added to refs/heads/main by this push:
new 5be1f6f25f [DROOLS-7587] fix session configuration lookup in session
pool (#5585)
5be1f6f25f is described below
commit 5be1f6f25f8b61e024ba860fb5c530c231ea229f
Author: Mario Fusco <[email protected]>
AuthorDate: Mon Nov 13 08:19:14 2023 +0100
[DROOLS-7587] fix session configuration lookup in session pool (#5585)
---
.../drools/kiesession/session/KieSessionsPoolImpl.java | 2 +-
.../mvel/integrationtests/session/SessionsPoolTest.java | 17 +++++++++++++++++
2 files changed, 18 insertions(+), 1 deletion(-)
diff --git
a/drools-kiesession/src/main/java/org/drools/kiesession/session/KieSessionsPoolImpl.java
b/drools-kiesession/src/main/java/org/drools/kiesession/session/KieSessionsPoolImpl.java
index 042554ff4f..670ced6c64 100644
---
a/drools-kiesession/src/main/java/org/drools/kiesession/session/KieSessionsPoolImpl.java
+++
b/drools-kiesession/src/main/java/org/drools/kiesession/session/KieSessionsPoolImpl.java
@@ -64,7 +64,7 @@ public class KieSessionsPoolImpl extends
AbstractKieSessionsPool {
protected StatefulSessionPool createStatefulSessionPool( String
kSessionName, KieSessionConfiguration conf, boolean stateless ) {
return new StatefulSessionPool(kBase, initialSize, () ->
stateless ?
- ((StatefulKnowledgeSessionImpl )
RuntimeComponentFactory.get().createStatefulSession(kBase, environment, (
SessionConfiguration ) conf, true )).setStateless( true ) :
+ ((StatefulKnowledgeSessionImpl )
RuntimeComponentFactory.get().createStatefulSession(kBase, environment,
conf.as(SessionConfiguration.KEY), true )).setStateless( true ) :
(StatefulKnowledgeSessionImpl ) kBase.newKieSession(conf,
environment, true));
}
diff --git
a/drools-test-coverage/test-compiler-integration/src/test/java/org/drools/mvel/integrationtests/session/SessionsPoolTest.java
b/drools-test-coverage/test-compiler-integration/src/test/java/org/drools/mvel/integrationtests/session/SessionsPoolTest.java
index 5bc42bd12b..737492325b 100644
---
a/drools-test-coverage/test-compiler-integration/src/test/java/org/drools/mvel/integrationtests/session/SessionsPoolTest.java
+++
b/drools-test-coverage/test-compiler-integration/src/test/java/org/drools/mvel/integrationtests/session/SessionsPoolTest.java
@@ -195,6 +195,23 @@ public class SessionsPoolTest {
assertThat(list.size()).isEqualTo(1);
}
+ @Test
+ public void testStatelessKieSessionsPoolWithConf() {
+ KieServices kieServices = KieServices.get();
+
+ KieSessionsPool pool =
getKieContainer().getKieBase().newKieSessionsPool( 1 );
+ StatelessKieSession session =
pool.newStatelessKieSession(kieServices.newKieSessionConfiguration());
+
+ List<String> list = new ArrayList<>();
+ session.setGlobal( "list", list );
+ session.execute( "test" );
+ assertThat(list.size()).isEqualTo(1);
+
+ list.clear();
+ session.execute( "test" );
+ assertThat(list.size()).isEqualTo(1);
+ }
+
private KieContainer getKieContainer() {
String drl =
"global java.util.List list\n" +
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
