This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-spring-boot.git
The following commit(s) were added to refs/heads/main by this push:
new fbf3bd4c9ff CAMEL-22146: camel-pgevent - Re-connect in case of lost
connection to database.
fbf3bd4c9ff is described below
commit fbf3bd4c9ff76f898577710c02418b7f31d46d8b
Author: Claus Ibsen <[email protected]>
AuthorDate: Fri Jun 6 10:56:41 2025 +0200
CAMEL-22146: camel-pgevent - Re-connect in case of lost connection to
database.
---
.../apache/camel/springboot/catalog/components/pgevent.json | 12 ++++++++----
1 file changed, 8 insertions(+), 4 deletions(-)
diff --git
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/pgevent.json
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/pgevent.json
index 3aa99ff28fe..2a3086f3a34 100644
---
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/pgevent.json
+++
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/pgevent.json
@@ -39,9 +39,13 @@
"bridgeErrorHandler": { "index": 4, "kind": "parameter", "displayName":
"Bridge Error Handler", "group": "consumer (advanced)", "label":
"consumer,advanced", "required": false, "type": "boolean", "javaType":
"boolean", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": false, "description": "Allows for bridging the consumer to the
Camel routing Error Handler, which mean any exceptions (if possible) occurred
while the Camel consumer is trying to pickup incoming [...]
"exceptionHandler": { "index": 5, "kind": "parameter", "displayName":
"Exception Handler", "group": "consumer (advanced)", "label":
"consumer,advanced", "required": false, "type": "object", "javaType":
"org.apache.camel.spi.ExceptionHandler", "optionalPrefix": "consumer.",
"deprecated": false, "autowired": false, "secret": false, "description": "To
let the consumer use a custom ExceptionHandler. Notice if the option
bridgeErrorHandler is enabled then this option is not in use. By def [...]
"exchangePattern": { "index": 6, "kind": "parameter", "displayName":
"Exchange Pattern", "group": "consumer (advanced)", "label":
"consumer,advanced", "required": false, "type": "object", "javaType":
"org.apache.camel.ExchangePattern", "enum": [ "InOnly", "InOut" ],
"deprecated": false, "autowired": false, "secret": false, "description": "Sets
the exchange pattern when the consumer creates an exchange." },
- "lazyStartProducer": { "index": 7, "kind": "parameter", "displayName":
"Lazy Start Producer", "group": "producer (advanced)", "label":
"producer,advanced", "required": false, "type": "boolean", "javaType":
"boolean", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": false, "description": "Whether the producer should be started
lazy (on the first message). By starting lazy you can use this to allow
CamelContext and routes to startup in situations where a produc [...]
- "datasource": { "index": 8, "kind": "parameter", "displayName":
"Datasource", "group": "advanced", "label": "advanced", "required": false,
"type": "object", "javaType": "javax.sql.DataSource", "deprecated": false,
"autowired": false, "secret": false, "description": "To connect using the given
javax.sql.DataSource instead of using hostname and port." },
- "pass": { "index": 9, "kind": "parameter", "displayName": "Pass", "group":
"security", "label": "security", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": true, "description": "Password for login" },
- "user": { "index": 10, "kind": "parameter", "displayName": "User",
"group": "security", "label": "security", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": true, "defaultValue": "postgres", "description": "Username for login"
}
+ "reconnectDelay": { "index": 7, "kind": "parameter", "displayName":
"Reconnect Delay", "group": "consumer (advanced)", "label":
"consumer,advanced", "required": false, "type": "integer", "javaType": "int",
"deprecated": false, "autowired": false, "secret": false, "defaultValue": 5000,
"description": "When the consumer unexpected lose connection to the database,
then this specifies the interval (millis) between re-connection attempts to
establish a new connection." },
+ "workerPool": { "index": 8, "kind": "parameter", "displayName": "Worker
Pool", "group": "consumer (advanced)", "label": "consumer,advanced",
"required": false, "type": "object", "javaType":
"java.util.concurrent.ExecutorService", "deprecated": false, "autowired":
false, "secret": false, "description": "To use a custom worker pool for
processing the events from the database." },
+ "workerPoolCoreSize": { "index": 9, "kind": "parameter", "displayName":
"Worker Pool Core Size", "group": "consumer (advanced)", "label":
"consumer,advanced", "required": false, "type": "integer", "javaType": "int",
"deprecated": false, "autowired": false, "secret": false, "defaultValue": 1,
"description": "Number of core threads in the worker pool for processing the
events from the database." },
+ "workerPoolMaxSize": { "index": 10, "kind": "parameter", "displayName":
"Worker Pool Max Size", "group": "consumer (advanced)", "label":
"consumer,advanced", "required": false, "type": "integer", "javaType": "int",
"deprecated": false, "autowired": false, "secret": false, "defaultValue": 10,
"description": "Maximum number of threads in the worker pool for processing the
events from the database." },
+ "lazyStartProducer": { "index": 11, "kind": "parameter", "displayName":
"Lazy Start Producer", "group": "producer (advanced)", "label":
"producer,advanced", "required": false, "type": "boolean", "javaType":
"boolean", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": false, "description": "Whether the producer should be started
lazy (on the first message). By starting lazy you can use this to allow
CamelContext and routes to startup in situations where a produ [...]
+ "datasource": { "index": 12, "kind": "parameter", "displayName":
"Datasource", "group": "advanced", "label": "advanced", "required": false,
"type": "object", "javaType": "javax.sql.DataSource", "deprecated": false,
"autowired": false, "secret": false, "description": "To connect using the given
javax.sql.DataSource instead of using hostname and port." },
+ "pass": { "index": 13, "kind": "parameter", "displayName": "Pass",
"group": "security", "label": "security", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": true, "description": "Password for login" },
+ "user": { "index": 14, "kind": "parameter", "displayName": "User",
"group": "security", "label": "security", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": true, "defaultValue": "postgres", "description": "Username for login"
}
}
}
