JMS Kamelets: Expose Connection Pool parameters to make it customizab…

…le (#2113) Signed-off-by: Andrea Cosentino <ancosen@gmail.com>
apache · Jul 16, 2024 · e51fa7a · e51fa7a
1 parent 67565dd
commit e51fa7a
Show file tree

Hide file tree

Showing 4 changed files with 78 additions and 6 deletions.
diff --git a/kamelets/jms-pooled-apache-artemis-sink.kamelet.yaml b/kamelets/jms-pooled-apache-artemis-sink.kamelet.yaml
@@ -67,7 +67,22 @@ spec:
         x-descriptors:
         - urn:camel:group:credentials
         - urn:keda:authentication:password
-        - urn:keda:required   
+        - urn:keda:required
+      maxSessionsPerConnection:
+        title: "Max Sessions Per Connection"
+        description: "The maximum number of pooled sessions per connection in the pool"
+        type: int
+        default: 500 
+      maxIdleSessionsPerConnection:
+        title: "Max Idle Sessions Per Connection"
+        description: "The number of idle sessions allowed per connection before they are closed."
+        type: int
+        default: 500
+      connectionIdleTimeout:
+        title: "Connection Idle Timeout"
+        description: "The maximum time a pooled Connection can sit unused before it is eligible for removal (in milliseconds)"
+        type: int
+        default: 30000     
   dependencies:
   - "camel:jms"
   - "camel:kamelet"
@@ -85,6 +100,9 @@ spec:
         type: "#class:org.messaginghub.pooled.jms.JmsPoolConnectionFactory"
         properties:
           connectionFactory: '#bean:{{connectionFactoryBean}}'
+          maxSessionsPerConnection: "{{maxSessionsPerConnection}}"
+          maxIdleSessionsPerConnection: "{{maxIdleSessionsPerConnection}}"
+          connectionIdleTimeout: "{{connectionIdleTimeout}}"
     from:
       uri: "kamelet:source"
       steps:

diff --git a/kamelets/jms-pooled-apache-artemis-source.kamelet.yaml b/kamelets/jms-pooled-apache-artemis-source.kamelet.yaml
@@ -66,7 +66,22 @@ spec:
         x-descriptors:
         - urn:camel:group:credentials
         - urn:keda:authentication:password
-        - urn:keda:required        
+        - urn:keda:required
+      maxSessionsPerConnection:
+        title: "Max Session Per Connection"
+        description: "The maximum number of pooled sessions per connection in the pool"
+        type: int
+        default: 500
+      maxIdleSessionsPerConnection:
+        title: "Max Idle Sessions Per Connection"
+        description: "The number of idle sessions allowed per connection before they are closed."
+        type: int
+        default: 500
+      connectionIdleTimeout:
+        title: "Connection Idle Timeout"
+        description: "The maximum time a pooled Connection can sit unused before it is eligible for removal (in milliseconds)"
+        type: int
+        default: 30000       
   dependencies:
   - "camel:jms"
   - "camel:kamelet"
@@ -83,7 +98,10 @@ spec:
       - name: pooledFactoryBean
         type: "#class:org.messaginghub.pooled.jms.JmsPoolConnectionFactory"
         properties:
-          connectionFactory: '#bean:{{connectionFactoryBean}}'        
+          connectionFactory: '#bean:{{connectionFactoryBean}}'
+          maxSessionsPerConnection: "{{maxSessionsPerConnection}}"
+          maxIdleSessionsPerConnection: "{{maxIdleSessionsPerConnection}}"
+          connectionIdleTimeout: "{{connectionIdleTimeout}}"        
     from:
       uri: "jms:{{destinationType}}:{{destinationName}}"
       parameters:

diff --git a/...ry/camel-kamelets/src/main/resources/kamelets/jms-pooled-apache-artemis-sink.kamelet.yaml b/...ry/camel-kamelets/src/main/resources/kamelets/jms-pooled-apache-artemis-sink.kamelet.yaml
@@ -67,7 +67,22 @@ spec:
         x-descriptors:
         - urn:camel:group:credentials
         - urn:keda:authentication:password
-        - urn:keda:required   
+        - urn:keda:required
+      maxSessionsPerConnection:
+        title: "Max Sessions Per Connection"
+        description: "The maximum number of pooled sessions per connection in the pool"
+        type: int
+        default: 500 
+      maxIdleSessionsPerConnection:
+        title: "Max Idle Sessions Per Connection"
+        description: "The number of idle sessions allowed per connection before they are closed."
+        type: int
+        default: 500
+      connectionIdleTimeout:
+        title: "Connection Idle Timeout"
+        description: "The maximum time a pooled Connection can sit unused before it is eligible for removal (in milliseconds)"
+        type: int
+        default: 30000     
   dependencies:
   - "camel:jms"
   - "camel:kamelet"
@@ -85,6 +100,9 @@ spec:
         type: "#class:org.messaginghub.pooled.jms.JmsPoolConnectionFactory"
         properties:
           connectionFactory: '#bean:{{connectionFactoryBean}}'
+          maxSessionsPerConnection: "{{maxSessionsPerConnection}}"
+          maxIdleSessionsPerConnection: "{{maxIdleSessionsPerConnection}}"
+          connectionIdleTimeout: "{{connectionIdleTimeout}}"
     from:
       uri: "kamelet:source"
       steps:

diff --git a/.../camel-kamelets/src/main/resources/kamelets/jms-pooled-apache-artemis-source.kamelet.yaml b/.../camel-kamelets/src/main/resources/kamelets/jms-pooled-apache-artemis-source.kamelet.yaml
@@ -66,7 +66,22 @@ spec:
         x-descriptors:
         - urn:camel:group:credentials
         - urn:keda:authentication:password
-        - urn:keda:required        
+        - urn:keda:required
+      maxSessionsPerConnection:
+        title: "Max Session Per Connection"
+        description: "The maximum number of pooled sessions per connection in the pool"
+        type: int
+        default: 500
+      maxIdleSessionsPerConnection:
+        title: "Max Idle Sessions Per Connection"
+        description: "The number of idle sessions allowed per connection before they are closed."
+        type: int
+        default: 500
+      connectionIdleTimeout:
+        title: "Connection Idle Timeout"
+        description: "The maximum time a pooled Connection can sit unused before it is eligible for removal (in milliseconds)"
+        type: int
+        default: 30000       
   dependencies:
   - "camel:jms"
   - "camel:kamelet"
@@ -83,7 +98,10 @@ spec:
       - name: pooledFactoryBean
         type: "#class:org.messaginghub.pooled.jms.JmsPoolConnectionFactory"
         properties:
-          connectionFactory: '#bean:{{connectionFactoryBean}}'        
+          connectionFactory: '#bean:{{connectionFactoryBean}}'
+          maxSessionsPerConnection: "{{maxSessionsPerConnection}}"
+          maxIdleSessionsPerConnection: "{{maxIdleSessionsPerConnection}}"
+          connectionIdleTimeout: "{{connectionIdleTimeout}}"        
     from:
       uri: "jms:{{destinationType}}:{{destinationName}}"
       parameters: