This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch camel-4.10.x
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/camel-4.10.x by this push:
new 7ac463c08f6 CAMEL-21988: camel-jpa - Add @UriParam with
entityManagerFactory in JpaEndpoint (#17793)
7ac463c08f6 is described below
commit 7ac463c08f6a503b3196f9af510d40a278892da6
Author: Zheng Feng <zh.f...@gmail.com>
AuthorDate: Fri Apr 18 14:08:58 2025 +0800
CAMEL-21988: camel-jpa - Add @UriParam with entityManagerFactory in
JpaEndpoint (#17793)
---
.../org/apache/camel/catalog/components/jpa.json | 95 +++++++++++-----------
.../camel/component/jpa/JpaEndpointConfigurer.java | 6 ++
.../camel/component/jpa/JpaEndpointUriFactory.java | 3 +-
.../org/apache/camel/component/jpa/jpa.json | 95 +++++++++++-----------
.../apache/camel/component/jpa/JpaEndpoint.java | 1 +
.../endpoint/dsl/JpaEndpointBuilderFactory.java | 90 ++++++++++++++++++++
6 files changed, 195 insertions(+), 95 deletions(-)
diff --git
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/jpa.json
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/jpa.json
index 79aa3cafe3d..41d247c75d6 100644
---
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/jpa.json
+++
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/jpa.json
@@ -43,52 +43,53 @@
},
"properties": {
"entityType": { "index": 0, "kind": "path", "displayName": "Entity Type",
"group": "common", "label": "", "required": true, "type": "string", "javaType":
"java.lang.Class<java.lang.Object>", "deprecated": false, "deprecationNote":
"", "autowired": false, "secret": false, "description": "Entity class name" },
- "joinTransaction": { "index": 1, "kind": "parameter", "displayName": "Join
Transaction", "group": "common", "label": "", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": true, "description": "The camel-jpa component
will join transaction by default. You can use this option to turn this off, for
example, if you use LOCAL_RESOURCE and join transaction doesn't work with your
JPA provider. This option c [...]
- "maximumResults": { "index": 2, "kind": "parameter", "displayName":
"Maximum Results", "group": "common", "label": "", "required": false, "type":
"integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": -1, "description": "Set the maximum number of
results to retrieve on the Query." },
- "namedQuery": { "index": 3, "kind": "parameter", "displayName": "Named
Query", "group": "common", "label": "", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "description": "To use a named query." },
- "nativeQuery": { "index": 4, "kind": "parameter", "displayName": "Native
Query", "group": "common", "label": "", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "description": "To use a custom native query. You may want to
use the option resultClass also when using native queries." },
- "persistenceUnit": { "index": 5, "kind": "parameter", "displayName":
"Persistence Unit", "group": "common", "label": "", "required": true, "type":
"string", "javaType": "java.lang.String", "deprecated": false,
"deprecationNote": "", "autowired": false, "secret": false, "defaultValue":
"camel", "description": "The JPA persistence unit used by default." },
- "query": { "index": 6, "kind": "parameter", "displayName": "Query",
"group": "common", "label": "", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "description": "To use a custom query." },
- "resultClass": { "index": 7, "kind": "parameter", "displayName": "Result
Class", "group": "common", "label": "", "required": false, "type": "string",
"javaType": "java.lang.Class<java.lang.Object>", "deprecated": false,
"autowired": false, "secret": false, "description": "Defines the type of the
returned payload (we will call entityManager.createNativeQuery(nativeQuery,
resultClass) instead of entityManager.createNativeQuery(nativeQuery)). Without
this option, we will return an objec [...]
- "consumeDelete": { "index": 8, "kind": "parameter", "displayName":
"Consume Delete", "group": "consumer", "label": "consumer", "required": false,
"type": "boolean", "javaType": "boolean", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": true, "description": "If true, the
entity is deleted after it is consumed; if false, the entity is not deleted." },
- "consumeLockEntity": { "index": 9, "kind": "parameter", "displayName":
"Consume Lock Entity", "group": "consumer", "label": "consumer", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": true, "description":
"Specifies whether to set an exclusive lock on each entity bean while
processing the results from polling." },
- "deleteHandler": { "index": 10, "kind": "parameter", "displayName":
"Delete Handler", "group": "consumer", "label": "consumer", "required": false,
"type": "object", "javaType":
"org.apache.camel.component.jpa.DeleteHandler<java.lang.Object>", "deprecated":
false, "autowired": false, "secret": false, "description": "To use a custom
DeleteHandler to delete the row after the consumer is done processing the
exchange" },
- "lockModeType": { "index": 11, "kind": "parameter", "displayName": "Lock
Mode Type", "group": "consumer", "label": "consumer", "required": false,
"type": "object", "javaType": "jakarta.persistence.LockModeType", "enum": [
"READ", "WRITE", "OPTIMISTIC", "OPTIMISTIC_FORCE_INCREMENT",
"PESSIMISTIC_READ", "PESSIMISTIC_WRITE", "PESSIMISTIC_FORCE_INCREMENT", "NONE"
], "deprecated": false, "autowired": false, "secret": false, "defaultValue":
"PESSIMISTIC_WRITE", "description": "To configure [...]
- "maxMessagesPerPoll": { "index": 12, "kind": "parameter", "displayName":
"Max Messages Per Poll", "group": "consumer", "label": "consumer", "required":
false, "type": "integer", "javaType": "int", "deprecated": false, "autowired":
false, "secret": false, "description": "An integer value to define the maximum
number of messages to gather per poll. By default, no maximum is set. It can be
used to avoid polling many thousands of messages when starting up the server.
Set a value of 0 or [...]
- "preDeleteHandler": { "index": 13, "kind": "parameter", "displayName":
"Pre Delete Handler", "group": "consumer", "label": "consumer", "required":
false, "type": "object", "javaType":
"org.apache.camel.component.jpa.DeleteHandler<java.lang.Object>", "deprecated":
false, "autowired": false, "secret": false, "description": "To use a custom
Pre-DeleteHandler to delete the row after the consumer has read the entity." },
- "sendEmptyMessageWhenIdle": { "index": 14, "kind": "parameter",
"displayName": "Send Empty Message When Idle", "group": "consumer", "label":
"consumer", "required": false, "type": "boolean", "javaType": "boolean",
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
false, "description": "If the polling consumer did not poll any files, you can
enable this option to send an empty message (no body) instead." },
- "skipLockedEntity": { "index": 15, "kind": "parameter", "displayName":
"Skip Locked Entity", "group": "consumer", "label": "consumer", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": false, "description": "To
configure whether to use NOWAIT on lock and silently skip the entity." },
- "transacted": { "index": 16, "kind": "parameter", "displayName":
"Transacted", "group": "consumer", "label": "consumer", "required": false,
"type": "boolean", "javaType": "boolean", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": false, "description": "Whether to run
the consumer in transacted mode, by which all messages will either commit or
rollback, when the entire batch has been processed. The default behavior
(false) is to commit all the previously succ [...]
- "bridgeErrorHandler": { "index": 17, "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": 18, "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 de [...]
- "exchangePattern": { "index": 19, "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." },
- "parameters": { "index": 20, "kind": "parameter", "displayName":
"Parameters", "group": "consumer (advanced)", "label": "consumer,advanced",
"required": false, "type": "object", "javaType":
"java.util.Map<java.lang.String, java.lang.Object>", "prefix": "parameters.",
"multiValue": true, "deprecated": false, "autowired": false, "secret": false,
"description": "This key\/value mapping is used for building the query
parameters. It is expected to be of the generic type java.util.Map wher [...]
- "pollStrategy": { "index": 21, "kind": "parameter", "displayName": "Poll
Strategy", "group": "consumer (advanced)", "label": "consumer,advanced",
"required": false, "type": "object", "javaType":
"org.apache.camel.spi.PollingConsumerPollStrategy", "deprecated": false,
"autowired": false, "secret": false, "description": "A pluggable
org.apache.camel.PollingConsumerPollingStrategy allowing you to provide your
custom implementation to control error handling usually occurred during the po
[...]
- "findEntity": { "index": 22, "kind": "parameter", "displayName": "Find
Entity", "group": "producer", "label": "producer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "description": "If enabled, then the
producer will find a single entity by using the message body as a key and
entityType as the class type. This can be used instead of a query to find a
single entity." },
- "firstResult": { "index": 23, "kind": "parameter", "displayName": "First
Result", "group": "producer", "label": "producer", "required": false, "type":
"integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": -1, "description": "Set the position of the
first result to retrieve." },
- "flushOnSend": { "index": 24, "kind": "parameter", "displayName": "Flush
On Send", "group": "producer", "label": "producer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": true, "description": "Flushes the
EntityManager after the entity bean has been persisted." },
- "outputTarget": { "index": 25, "kind": "parameter", "displayName": "Output
Target", "group": "producer", "label": "producer", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "description": "To put the query (or find) result in a
header or property instead of the body. If the value starts with the prefix
property:, put the result into the so named property, otherwise into the
header." },
- "remove": { "index": 26, "kind": "parameter", "displayName": "Remove",
"group": "producer", "label": "producer", "required": false, "type": "boolean",
"javaType": "boolean", "deprecated": false, "autowired": false, "secret":
false, "defaultValue": false, "description": "Indicates to use
entityManager.remove(entity)." },
- "singleResult": { "index": 27, "kind": "parameter", "displayName": "Single
Result", "group": "producer", "label": "producer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "description": "If enabled, a query or
a find which would return no results or more than one result, will throw an
exception instead." },
- "useExecuteUpdate": { "index": 28, "kind": "parameter", "displayName":
"Use Execute Update", "group": "producer", "label": "producer", "required":
false, "type": "boolean", "javaType": "java.lang.Boolean", "deprecated": false,
"autowired": false, "secret": false, "description": "To configure whether to
use executeUpdate() when producer executes a query. When you use INSERT, UPDATE
or a DELETE statement as a named query, you need to specify this option to
'true'." },
- "usePersist": { "index": 29, "kind": "parameter", "displayName": "Use
Persist", "group": "producer", "label": "producer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "description": "Indicates to use
entityManager.persist(entity) instead of entityManager.merge(entity). Note:
entityManager.persist(entity) doesn't work for detached entities (where the
EntityManager has to execute an UPDATE [...]
- "lazyStartProducer": { "index": 30, "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 [...]
- "usePassedInEntityManager": { "index": 31, "kind": "parameter",
"displayName": "Use Passed In Entity Manager", "group": "producer (advanced)",
"label": "producer,advanced", "required": false, "type": "boolean", "javaType":
"boolean", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": false, "description": "If set to true, then Camel will use the
EntityManager from the header JpaConstants.ENTITY_MANAGER instead of the
configured entity manager on the component\/ [...]
- "entityManagerProperties": { "index": 32, "kind": "parameter",
"displayName": "Entity Manager Properties", "group": "advanced", "label":
"advanced", "required": false, "type": "object", "javaType":
"java.util.Map<java.lang.String, java.lang.Object>", "prefix": "emf.",
"multiValue": true, "deprecated": false, "autowired": false, "secret": false,
"description": "Additional properties for the entity manager to use." },
- "sharedEntityManager": { "index": 33, "kind": "parameter", "displayName":
"Shared Entity Manager", "group": "advanced", "label": "advanced", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": false, "description":
"Whether to use Spring's SharedEntityManager for the consumer\/producer. Note
in most cases, joinTransaction should be set to false as this is not an
EXTENDED EntityManager." },
- "backoffErrorThreshold": { "index": 34, "kind": "parameter",
"displayName": "Backoff Error Threshold", "group": "scheduler", "label":
"consumer,scheduler", "required": false, "type": "integer", "javaType": "int",
"deprecated": false, "autowired": false, "secret": false, "description": "The
number of subsequent error polls (failed due some error) that should happen
before the backoffMultipler should kick-in." },
- "backoffIdleThreshold": { "index": 35, "kind": "parameter", "displayName":
"Backoff Idle Threshold", "group": "scheduler", "label": "consumer,scheduler",
"required": false, "type": "integer", "javaType": "int", "deprecated": false,
"autowired": false, "secret": false, "description": "The number of subsequent
idle polls that should happen before the backoffMultipler should kick-in." },
- "backoffMultiplier": { "index": 36, "kind": "parameter", "displayName":
"Backoff Multiplier", "group": "scheduler", "label": "consumer,scheduler",
"required": false, "type": "integer", "javaType": "int", "deprecated": false,
"autowired": false, "secret": false, "description": "To let the scheduled
polling consumer backoff if there has been a number of subsequent idles\/errors
in a row. The multiplier is then the number of polls that will be skipped
before the next actual attempt is h [...]
- "delay": { "index": 37, "kind": "parameter", "displayName": "Delay",
"group": "scheduler", "label": "consumer,scheduler", "required": false, "type":
"integer", "javaType": "long", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 500, "description": "Milliseconds before the
next poll." },
- "greedy": { "index": 38, "kind": "parameter", "displayName": "Greedy",
"group": "scheduler", "label": "consumer,scheduler", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "description": "If greedy is enabled,
then the ScheduledPollConsumer will run immediately again, if the previous run
polled 1 or more messages." },
- "initialDelay": { "index": 39, "kind": "parameter", "displayName":
"Initial Delay", "group": "scheduler", "label": "consumer,scheduler",
"required": false, "type": "integer", "javaType": "long", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": 1000, "description":
"Milliseconds before the first poll starts." },
- "repeatCount": { "index": 40, "kind": "parameter", "displayName": "Repeat
Count", "group": "scheduler", "label": "consumer,scheduler", "required": false,
"type": "integer", "javaType": "long", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 0, "description": "Specifies a maximum limit
of number of fires. So if you set it to 1, the scheduler will only fire once.
If you set it to 5, it will only fire five times. A value of zero or negative
means fire forever." },
- "runLoggingLevel": { "index": 41, "kind": "parameter", "displayName": "Run
Logging Level", "group": "scheduler", "label": "consumer,scheduler",
"required": false, "type": "object", "javaType":
"org.apache.camel.LoggingLevel", "enum": [ "TRACE", "DEBUG", "INFO", "WARN",
"ERROR", "OFF" ], "deprecated": false, "autowired": false, "secret": false,
"defaultValue": "TRACE", "description": "The consumer logs a start\/complete
log line when it polls. This option allows you to configure the l [...]
- "scheduledExecutorService": { "index": 42, "kind": "parameter",
"displayName": "Scheduled Executor Service", "group": "scheduler", "label":
"consumer,scheduler", "required": false, "type": "object", "javaType":
"java.util.concurrent.ScheduledExecutorService", "deprecated": false,
"autowired": false, "secret": false, "description": "Allows for configuring a
custom\/shared thread pool to use for the consumer. By default each consumer
has its own single threaded thread pool." },
- "scheduler": { "index": 43, "kind": "parameter", "displayName":
"Scheduler", "group": "scheduler", "label": "consumer,scheduler", "required":
false, "type": "object", "javaType": "java.lang.Object", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "none", "description": "To
use a cron scheduler from either camel-spring or camel-quartz component. Use
value spring or quartz for built in scheduler" },
- "schedulerProperties": { "index": 44, "kind": "parameter", "displayName":
"Scheduler Properties", "group": "scheduler", "label": "consumer,scheduler",
"required": false, "type": "object", "javaType":
"java.util.Map<java.lang.String, java.lang.Object>", "prefix": "scheduler.",
"multiValue": true, "deprecated": false, "autowired": false, "secret": false,
"description": "To configure additional properties when using a custom
scheduler or any of the Quartz, Spring based scheduler." },
- "startScheduler": { "index": 45, "kind": "parameter", "displayName":
"Start Scheduler", "group": "scheduler", "label": "consumer,scheduler",
"required": false, "type": "boolean", "javaType": "boolean", "deprecated":
false, "autowired": false, "secret": false, "defaultValue": true,
"description": "Whether the scheduler should be auto started." },
- "timeUnit": { "index": 46, "kind": "parameter", "displayName": "Time
Unit", "group": "scheduler", "label": "consumer,scheduler", "required": false,
"type": "object", "javaType": "java.util.concurrent.TimeUnit", "enum": [
"NANOSECONDS", "MICROSECONDS", "MILLISECONDS", "SECONDS", "MINUTES", "HOURS",
"DAYS" ], "deprecated": false, "autowired": false, "secret": false,
"defaultValue": "MILLISECONDS", "description": "Time unit for initialDelay and
delay options." },
- "useFixedDelay": { "index": 47, "kind": "parameter", "displayName": "Use
Fixed Delay", "group": "scheduler", "label": "consumer,scheduler", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": true, "description":
"Controls if fixed delay or fixed rate is used. See ScheduledExecutorService in
JDK for details." }
+ "entityManagerFactory": { "index": 1, "kind": "parameter", "displayName":
"Entity Manager Factory", "group": "common", "label": "", "required": false,
"type": "object", "javaType": "jakarta.persistence.EntityManagerFactory",
"deprecated": false, "autowired": false, "secret": false, "description": "The
EntityManagerFactory to use." },
+ "joinTransaction": { "index": 2, "kind": "parameter", "displayName": "Join
Transaction", "group": "common", "label": "", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": true, "description": "The camel-jpa component
will join transaction by default. You can use this option to turn this off, for
example, if you use LOCAL_RESOURCE and join transaction doesn't work with your
JPA provider. This option c [...]
+ "maximumResults": { "index": 3, "kind": "parameter", "displayName":
"Maximum Results", "group": "common", "label": "", "required": false, "type":
"integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": -1, "description": "Set the maximum number of
results to retrieve on the Query." },
+ "namedQuery": { "index": 4, "kind": "parameter", "displayName": "Named
Query", "group": "common", "label": "", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "description": "To use a named query." },
+ "nativeQuery": { "index": 5, "kind": "parameter", "displayName": "Native
Query", "group": "common", "label": "", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "description": "To use a custom native query. You may want to
use the option resultClass also when using native queries." },
+ "persistenceUnit": { "index": 6, "kind": "parameter", "displayName":
"Persistence Unit", "group": "common", "label": "", "required": true, "type":
"string", "javaType": "java.lang.String", "deprecated": false,
"deprecationNote": "", "autowired": false, "secret": false, "defaultValue":
"camel", "description": "The JPA persistence unit used by default." },
+ "query": { "index": 7, "kind": "parameter", "displayName": "Query",
"group": "common", "label": "", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "description": "To use a custom query." },
+ "resultClass": { "index": 8, "kind": "parameter", "displayName": "Result
Class", "group": "common", "label": "", "required": false, "type": "string",
"javaType": "java.lang.Class<java.lang.Object>", "deprecated": false,
"autowired": false, "secret": false, "description": "Defines the type of the
returned payload (we will call entityManager.createNativeQuery(nativeQuery,
resultClass) instead of entityManager.createNativeQuery(nativeQuery)). Without
this option, we will return an objec [...]
+ "consumeDelete": { "index": 9, "kind": "parameter", "displayName":
"Consume Delete", "group": "consumer", "label": "consumer", "required": false,
"type": "boolean", "javaType": "boolean", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": true, "description": "If true, the
entity is deleted after it is consumed; if false, the entity is not deleted." },
+ "consumeLockEntity": { "index": 10, "kind": "parameter", "displayName":
"Consume Lock Entity", "group": "consumer", "label": "consumer", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": true, "description":
"Specifies whether to set an exclusive lock on each entity bean while
processing the results from polling." },
+ "deleteHandler": { "index": 11, "kind": "parameter", "displayName":
"Delete Handler", "group": "consumer", "label": "consumer", "required": false,
"type": "object", "javaType":
"org.apache.camel.component.jpa.DeleteHandler<java.lang.Object>", "deprecated":
false, "autowired": false, "secret": false, "description": "To use a custom
DeleteHandler to delete the row after the consumer is done processing the
exchange" },
+ "lockModeType": { "index": 12, "kind": "parameter", "displayName": "Lock
Mode Type", "group": "consumer", "label": "consumer", "required": false,
"type": "object", "javaType": "jakarta.persistence.LockModeType", "enum": [
"READ", "WRITE", "OPTIMISTIC", "OPTIMISTIC_FORCE_INCREMENT",
"PESSIMISTIC_READ", "PESSIMISTIC_WRITE", "PESSIMISTIC_FORCE_INCREMENT", "NONE"
], "deprecated": false, "autowired": false, "secret": false, "defaultValue":
"PESSIMISTIC_WRITE", "description": "To configure [...]
+ "maxMessagesPerPoll": { "index": 13, "kind": "parameter", "displayName":
"Max Messages Per Poll", "group": "consumer", "label": "consumer", "required":
false, "type": "integer", "javaType": "int", "deprecated": false, "autowired":
false, "secret": false, "description": "An integer value to define the maximum
number of messages to gather per poll. By default, no maximum is set. It can be
used to avoid polling many thousands of messages when starting up the server.
Set a value of 0 or [...]
+ "preDeleteHandler": { "index": 14, "kind": "parameter", "displayName":
"Pre Delete Handler", "group": "consumer", "label": "consumer", "required":
false, "type": "object", "javaType":
"org.apache.camel.component.jpa.DeleteHandler<java.lang.Object>", "deprecated":
false, "autowired": false, "secret": false, "description": "To use a custom
Pre-DeleteHandler to delete the row after the consumer has read the entity." },
+ "sendEmptyMessageWhenIdle": { "index": 15, "kind": "parameter",
"displayName": "Send Empty Message When Idle", "group": "consumer", "label":
"consumer", "required": false, "type": "boolean", "javaType": "boolean",
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
false, "description": "If the polling consumer did not poll any files, you can
enable this option to send an empty message (no body) instead." },
+ "skipLockedEntity": { "index": 16, "kind": "parameter", "displayName":
"Skip Locked Entity", "group": "consumer", "label": "consumer", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": false, "description": "To
configure whether to use NOWAIT on lock and silently skip the entity." },
+ "transacted": { "index": 17, "kind": "parameter", "displayName":
"Transacted", "group": "consumer", "label": "consumer", "required": false,
"type": "boolean", "javaType": "boolean", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": false, "description": "Whether to run
the consumer in transacted mode, by which all messages will either commit or
rollback, when the entire batch has been processed. The default behavior
(false) is to commit all the previously succ [...]
+ "bridgeErrorHandler": { "index": 18, "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": 19, "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 de [...]
+ "exchangePattern": { "index": 20, "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." },
+ "parameters": { "index": 21, "kind": "parameter", "displayName":
"Parameters", "group": "consumer (advanced)", "label": "consumer,advanced",
"required": false, "type": "object", "javaType":
"java.util.Map<java.lang.String, java.lang.Object>", "prefix": "parameters.",
"multiValue": true, "deprecated": false, "autowired": false, "secret": false,
"description": "This key\/value mapping is used for building the query
parameters. It is expected to be of the generic type java.util.Map wher [...]
+ "pollStrategy": { "index": 22, "kind": "parameter", "displayName": "Poll
Strategy", "group": "consumer (advanced)", "label": "consumer,advanced",
"required": false, "type": "object", "javaType":
"org.apache.camel.spi.PollingConsumerPollStrategy", "deprecated": false,
"autowired": false, "secret": false, "description": "A pluggable
org.apache.camel.PollingConsumerPollingStrategy allowing you to provide your
custom implementation to control error handling usually occurred during the po
[...]
+ "findEntity": { "index": 23, "kind": "parameter", "displayName": "Find
Entity", "group": "producer", "label": "producer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "description": "If enabled, then the
producer will find a single entity by using the message body as a key and
entityType as the class type. This can be used instead of a query to find a
single entity." },
+ "firstResult": { "index": 24, "kind": "parameter", "displayName": "First
Result", "group": "producer", "label": "producer", "required": false, "type":
"integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": -1, "description": "Set the position of the
first result to retrieve." },
+ "flushOnSend": { "index": 25, "kind": "parameter", "displayName": "Flush
On Send", "group": "producer", "label": "producer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": true, "description": "Flushes the
EntityManager after the entity bean has been persisted." },
+ "outputTarget": { "index": 26, "kind": "parameter", "displayName": "Output
Target", "group": "producer", "label": "producer", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "description": "To put the query (or find) result in a
header or property instead of the body. If the value starts with the prefix
property:, put the result into the so named property, otherwise into the
header." },
+ "remove": { "index": 27, "kind": "parameter", "displayName": "Remove",
"group": "producer", "label": "producer", "required": false, "type": "boolean",
"javaType": "boolean", "deprecated": false, "autowired": false, "secret":
false, "defaultValue": false, "description": "Indicates to use
entityManager.remove(entity)." },
+ "singleResult": { "index": 28, "kind": "parameter", "displayName": "Single
Result", "group": "producer", "label": "producer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "description": "If enabled, a query or
a find which would return no results or more than one result, will throw an
exception instead." },
+ "useExecuteUpdate": { "index": 29, "kind": "parameter", "displayName":
"Use Execute Update", "group": "producer", "label": "producer", "required":
false, "type": "boolean", "javaType": "java.lang.Boolean", "deprecated": false,
"autowired": false, "secret": false, "description": "To configure whether to
use executeUpdate() when producer executes a query. When you use INSERT, UPDATE
or a DELETE statement as a named query, you need to specify this option to
'true'." },
+ "usePersist": { "index": 30, "kind": "parameter", "displayName": "Use
Persist", "group": "producer", "label": "producer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "description": "Indicates to use
entityManager.persist(entity) instead of entityManager.merge(entity). Note:
entityManager.persist(entity) doesn't work for detached entities (where the
EntityManager has to execute an UPDATE [...]
+ "lazyStartProducer": { "index": 31, "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 [...]
+ "usePassedInEntityManager": { "index": 32, "kind": "parameter",
"displayName": "Use Passed In Entity Manager", "group": "producer (advanced)",
"label": "producer,advanced", "required": false, "type": "boolean", "javaType":
"boolean", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": false, "description": "If set to true, then Camel will use the
EntityManager from the header JpaConstants.ENTITY_MANAGER instead of the
configured entity manager on the component\/ [...]
+ "entityManagerProperties": { "index": 33, "kind": "parameter",
"displayName": "Entity Manager Properties", "group": "advanced", "label":
"advanced", "required": false, "type": "object", "javaType":
"java.util.Map<java.lang.String, java.lang.Object>", "prefix": "emf.",
"multiValue": true, "deprecated": false, "autowired": false, "secret": false,
"description": "Additional properties for the entity manager to use." },
+ "sharedEntityManager": { "index": 34, "kind": "parameter", "displayName":
"Shared Entity Manager", "group": "advanced", "label": "advanced", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": false, "description":
"Whether to use Spring's SharedEntityManager for the consumer\/producer. Note
in most cases, joinTransaction should be set to false as this is not an
EXTENDED EntityManager." },
+ "backoffErrorThreshold": { "index": 35, "kind": "parameter",
"displayName": "Backoff Error Threshold", "group": "scheduler", "label":
"consumer,scheduler", "required": false, "type": "integer", "javaType": "int",
"deprecated": false, "autowired": false, "secret": false, "description": "The
number of subsequent error polls (failed due some error) that should happen
before the backoffMultipler should kick-in." },
+ "backoffIdleThreshold": { "index": 36, "kind": "parameter", "displayName":
"Backoff Idle Threshold", "group": "scheduler", "label": "consumer,scheduler",
"required": false, "type": "integer", "javaType": "int", "deprecated": false,
"autowired": false, "secret": false, "description": "The number of subsequent
idle polls that should happen before the backoffMultipler should kick-in." },
+ "backoffMultiplier": { "index": 37, "kind": "parameter", "displayName":
"Backoff Multiplier", "group": "scheduler", "label": "consumer,scheduler",
"required": false, "type": "integer", "javaType": "int", "deprecated": false,
"autowired": false, "secret": false, "description": "To let the scheduled
polling consumer backoff if there has been a number of subsequent idles\/errors
in a row. The multiplier is then the number of polls that will be skipped
before the next actual attempt is h [...]
+ "delay": { "index": 38, "kind": "parameter", "displayName": "Delay",
"group": "scheduler", "label": "consumer,scheduler", "required": false, "type":
"integer", "javaType": "long", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 500, "description": "Milliseconds before the
next poll." },
+ "greedy": { "index": 39, "kind": "parameter", "displayName": "Greedy",
"group": "scheduler", "label": "consumer,scheduler", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "description": "If greedy is enabled,
then the ScheduledPollConsumer will run immediately again, if the previous run
polled 1 or more messages." },
+ "initialDelay": { "index": 40, "kind": "parameter", "displayName":
"Initial Delay", "group": "scheduler", "label": "consumer,scheduler",
"required": false, "type": "integer", "javaType": "long", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": 1000, "description":
"Milliseconds before the first poll starts." },
+ "repeatCount": { "index": 41, "kind": "parameter", "displayName": "Repeat
Count", "group": "scheduler", "label": "consumer,scheduler", "required": false,
"type": "integer", "javaType": "long", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 0, "description": "Specifies a maximum limit
of number of fires. So if you set it to 1, the scheduler will only fire once.
If you set it to 5, it will only fire five times. A value of zero or negative
means fire forever." },
+ "runLoggingLevel": { "index": 42, "kind": "parameter", "displayName": "Run
Logging Level", "group": "scheduler", "label": "consumer,scheduler",
"required": false, "type": "object", "javaType":
"org.apache.camel.LoggingLevel", "enum": [ "TRACE", "DEBUG", "INFO", "WARN",
"ERROR", "OFF" ], "deprecated": false, "autowired": false, "secret": false,
"defaultValue": "TRACE", "description": "The consumer logs a start\/complete
log line when it polls. This option allows you to configure the l [...]
+ "scheduledExecutorService": { "index": 43, "kind": "parameter",
"displayName": "Scheduled Executor Service", "group": "scheduler", "label":
"consumer,scheduler", "required": false, "type": "object", "javaType":
"java.util.concurrent.ScheduledExecutorService", "deprecated": false,
"autowired": false, "secret": false, "description": "Allows for configuring a
custom\/shared thread pool to use for the consumer. By default each consumer
has its own single threaded thread pool." },
+ "scheduler": { "index": 44, "kind": "parameter", "displayName":
"Scheduler", "group": "scheduler", "label": "consumer,scheduler", "required":
false, "type": "object", "javaType": "java.lang.Object", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "none", "description": "To
use a cron scheduler from either camel-spring or camel-quartz component. Use
value spring or quartz for built in scheduler" },
+ "schedulerProperties": { "index": 45, "kind": "parameter", "displayName":
"Scheduler Properties", "group": "scheduler", "label": "consumer,scheduler",
"required": false, "type": "object", "javaType":
"java.util.Map<java.lang.String, java.lang.Object>", "prefix": "scheduler.",
"multiValue": true, "deprecated": false, "autowired": false, "secret": false,
"description": "To configure additional properties when using a custom
scheduler or any of the Quartz, Spring based scheduler." },
+ "startScheduler": { "index": 46, "kind": "parameter", "displayName":
"Start Scheduler", "group": "scheduler", "label": "consumer,scheduler",
"required": false, "type": "boolean", "javaType": "boolean", "deprecated":
false, "autowired": false, "secret": false, "defaultValue": true,
"description": "Whether the scheduler should be auto started." },
+ "timeUnit": { "index": 47, "kind": "parameter", "displayName": "Time
Unit", "group": "scheduler", "label": "consumer,scheduler", "required": false,
"type": "object", "javaType": "java.util.concurrent.TimeUnit", "enum": [
"NANOSECONDS", "MICROSECONDS", "MILLISECONDS", "SECONDS", "MINUTES", "HOURS",
"DAYS" ], "deprecated": false, "autowired": false, "secret": false,
"defaultValue": "MILLISECONDS", "description": "Time unit for initialDelay and
delay options." },
+ "useFixedDelay": { "index": 48, "kind": "parameter", "displayName": "Use
Fixed Delay", "group": "scheduler", "label": "consumer,scheduler", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": true, "description":
"Controls if fixed delay or fixed rate is used. See ScheduledExecutorService in
JDK for details." }
}
}
diff --git
a/components/camel-jpa/src/generated/java/org/apache/camel/component/jpa/JpaEndpointConfigurer.java
b/components/camel-jpa/src/generated/java/org/apache/camel/component/jpa/JpaEndpointConfigurer.java
index 7443d772c55..786dd065b41 100644
---
a/components/camel-jpa/src/generated/java/org/apache/camel/component/jpa/JpaEndpointConfigurer.java
+++
b/components/camel-jpa/src/generated/java/org/apache/camel/component/jpa/JpaEndpointConfigurer.java
@@ -38,6 +38,8 @@ public class JpaEndpointConfigurer extends
PropertyConfigurerSupport implements
case "delay": target.setDelay(property(camelContext, long.class,
value)); return true;
case "deletehandler":
case "deleteHandler": target.setDeleteHandler(property(camelContext,
org.apache.camel.component.jpa.DeleteHandler.class, value)); return true;
+ case "entitymanagerfactory":
+ case "entityManagerFactory":
target.setEntityManagerFactory(property(camelContext,
jakarta.persistence.EntityManagerFactory.class, value)); return true;
case "entitymanagerproperties":
case "entityManagerProperties":
target.setEntityManagerProperties(property(camelContext, java.util.Map.class,
value)); return true;
case "exceptionhandler":
@@ -132,6 +134,8 @@ public class JpaEndpointConfigurer extends
PropertyConfigurerSupport implements
case "delay": return long.class;
case "deletehandler":
case "deleteHandler": return
org.apache.camel.component.jpa.DeleteHandler.class;
+ case "entitymanagerfactory":
+ case "entityManagerFactory": return
jakarta.persistence.EntityManagerFactory.class;
case "entitymanagerproperties":
case "entityManagerProperties": return java.util.Map.class;
case "exceptionhandler":
@@ -227,6 +231,8 @@ public class JpaEndpointConfigurer extends
PropertyConfigurerSupport implements
case "delay": return target.getDelay();
case "deletehandler":
case "deleteHandler": return target.getDeleteHandler();
+ case "entitymanagerfactory":
+ case "entityManagerFactory": return target.getEntityManagerFactory();
case "entitymanagerproperties":
case "entityManagerProperties": return
target.getEntityManagerProperties();
case "exceptionhandler":
diff --git
a/components/camel-jpa/src/generated/java/org/apache/camel/component/jpa/JpaEndpointUriFactory.java
b/components/camel-jpa/src/generated/java/org/apache/camel/component/jpa/JpaEndpointUriFactory.java
index 10e8a720749..a4b44dd19e2 100644
---
a/components/camel-jpa/src/generated/java/org/apache/camel/component/jpa/JpaEndpointUriFactory.java
+++
b/components/camel-jpa/src/generated/java/org/apache/camel/component/jpa/JpaEndpointUriFactory.java
@@ -23,7 +23,7 @@ public class JpaEndpointUriFactory extends
org.apache.camel.support.component.En
private static final Set<String> SECRET_PROPERTY_NAMES;
private static final Set<String> MULTI_VALUE_PREFIXES;
static {
- Set<String> props = new HashSet<>(48);
+ Set<String> props = new HashSet<>(49);
props.add("backoffErrorThreshold");
props.add("backoffIdleThreshold");
props.add("backoffMultiplier");
@@ -32,6 +32,7 @@ public class JpaEndpointUriFactory extends
org.apache.camel.support.component.En
props.add("consumeLockEntity");
props.add("delay");
props.add("deleteHandler");
+ props.add("entityManagerFactory");
props.add("entityManagerProperties");
props.add("entityType");
props.add("exceptionHandler");
diff --git
a/components/camel-jpa/src/generated/resources/META-INF/org/apache/camel/component/jpa/jpa.json
b/components/camel-jpa/src/generated/resources/META-INF/org/apache/camel/component/jpa/jpa.json
index 79aa3cafe3d..41d247c75d6 100644
---
a/components/camel-jpa/src/generated/resources/META-INF/org/apache/camel/component/jpa/jpa.json
+++
b/components/camel-jpa/src/generated/resources/META-INF/org/apache/camel/component/jpa/jpa.json
@@ -43,52 +43,53 @@
},
"properties": {
"entityType": { "index": 0, "kind": "path", "displayName": "Entity Type",
"group": "common", "label": "", "required": true, "type": "string", "javaType":
"java.lang.Class<java.lang.Object>", "deprecated": false, "deprecationNote":
"", "autowired": false, "secret": false, "description": "Entity class name" },
- "joinTransaction": { "index": 1, "kind": "parameter", "displayName": "Join
Transaction", "group": "common", "label": "", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": true, "description": "The camel-jpa component
will join transaction by default. You can use this option to turn this off, for
example, if you use LOCAL_RESOURCE and join transaction doesn't work with your
JPA provider. This option c [...]
- "maximumResults": { "index": 2, "kind": "parameter", "displayName":
"Maximum Results", "group": "common", "label": "", "required": false, "type":
"integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": -1, "description": "Set the maximum number of
results to retrieve on the Query." },
- "namedQuery": { "index": 3, "kind": "parameter", "displayName": "Named
Query", "group": "common", "label": "", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "description": "To use a named query." },
- "nativeQuery": { "index": 4, "kind": "parameter", "displayName": "Native
Query", "group": "common", "label": "", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "description": "To use a custom native query. You may want to
use the option resultClass also when using native queries." },
- "persistenceUnit": { "index": 5, "kind": "parameter", "displayName":
"Persistence Unit", "group": "common", "label": "", "required": true, "type":
"string", "javaType": "java.lang.String", "deprecated": false,
"deprecationNote": "", "autowired": false, "secret": false, "defaultValue":
"camel", "description": "The JPA persistence unit used by default." },
- "query": { "index": 6, "kind": "parameter", "displayName": "Query",
"group": "common", "label": "", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "description": "To use a custom query." },
- "resultClass": { "index": 7, "kind": "parameter", "displayName": "Result
Class", "group": "common", "label": "", "required": false, "type": "string",
"javaType": "java.lang.Class<java.lang.Object>", "deprecated": false,
"autowired": false, "secret": false, "description": "Defines the type of the
returned payload (we will call entityManager.createNativeQuery(nativeQuery,
resultClass) instead of entityManager.createNativeQuery(nativeQuery)). Without
this option, we will return an objec [...]
- "consumeDelete": { "index": 8, "kind": "parameter", "displayName":
"Consume Delete", "group": "consumer", "label": "consumer", "required": false,
"type": "boolean", "javaType": "boolean", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": true, "description": "If true, the
entity is deleted after it is consumed; if false, the entity is not deleted." },
- "consumeLockEntity": { "index": 9, "kind": "parameter", "displayName":
"Consume Lock Entity", "group": "consumer", "label": "consumer", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": true, "description":
"Specifies whether to set an exclusive lock on each entity bean while
processing the results from polling." },
- "deleteHandler": { "index": 10, "kind": "parameter", "displayName":
"Delete Handler", "group": "consumer", "label": "consumer", "required": false,
"type": "object", "javaType":
"org.apache.camel.component.jpa.DeleteHandler<java.lang.Object>", "deprecated":
false, "autowired": false, "secret": false, "description": "To use a custom
DeleteHandler to delete the row after the consumer is done processing the
exchange" },
- "lockModeType": { "index": 11, "kind": "parameter", "displayName": "Lock
Mode Type", "group": "consumer", "label": "consumer", "required": false,
"type": "object", "javaType": "jakarta.persistence.LockModeType", "enum": [
"READ", "WRITE", "OPTIMISTIC", "OPTIMISTIC_FORCE_INCREMENT",
"PESSIMISTIC_READ", "PESSIMISTIC_WRITE", "PESSIMISTIC_FORCE_INCREMENT", "NONE"
], "deprecated": false, "autowired": false, "secret": false, "defaultValue":
"PESSIMISTIC_WRITE", "description": "To configure [...]
- "maxMessagesPerPoll": { "index": 12, "kind": "parameter", "displayName":
"Max Messages Per Poll", "group": "consumer", "label": "consumer", "required":
false, "type": "integer", "javaType": "int", "deprecated": false, "autowired":
false, "secret": false, "description": "An integer value to define the maximum
number of messages to gather per poll. By default, no maximum is set. It can be
used to avoid polling many thousands of messages when starting up the server.
Set a value of 0 or [...]
- "preDeleteHandler": { "index": 13, "kind": "parameter", "displayName":
"Pre Delete Handler", "group": "consumer", "label": "consumer", "required":
false, "type": "object", "javaType":
"org.apache.camel.component.jpa.DeleteHandler<java.lang.Object>", "deprecated":
false, "autowired": false, "secret": false, "description": "To use a custom
Pre-DeleteHandler to delete the row after the consumer has read the entity." },
- "sendEmptyMessageWhenIdle": { "index": 14, "kind": "parameter",
"displayName": "Send Empty Message When Idle", "group": "consumer", "label":
"consumer", "required": false, "type": "boolean", "javaType": "boolean",
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
false, "description": "If the polling consumer did not poll any files, you can
enable this option to send an empty message (no body) instead." },
- "skipLockedEntity": { "index": 15, "kind": "parameter", "displayName":
"Skip Locked Entity", "group": "consumer", "label": "consumer", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": false, "description": "To
configure whether to use NOWAIT on lock and silently skip the entity." },
- "transacted": { "index": 16, "kind": "parameter", "displayName":
"Transacted", "group": "consumer", "label": "consumer", "required": false,
"type": "boolean", "javaType": "boolean", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": false, "description": "Whether to run
the consumer in transacted mode, by which all messages will either commit or
rollback, when the entire batch has been processed. The default behavior
(false) is to commit all the previously succ [...]
- "bridgeErrorHandler": { "index": 17, "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": 18, "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 de [...]
- "exchangePattern": { "index": 19, "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." },
- "parameters": { "index": 20, "kind": "parameter", "displayName":
"Parameters", "group": "consumer (advanced)", "label": "consumer,advanced",
"required": false, "type": "object", "javaType":
"java.util.Map<java.lang.String, java.lang.Object>", "prefix": "parameters.",
"multiValue": true, "deprecated": false, "autowired": false, "secret": false,
"description": "This key\/value mapping is used for building the query
parameters. It is expected to be of the generic type java.util.Map wher [...]
- "pollStrategy": { "index": 21, "kind": "parameter", "displayName": "Poll
Strategy", "group": "consumer (advanced)", "label": "consumer,advanced",
"required": false, "type": "object", "javaType":
"org.apache.camel.spi.PollingConsumerPollStrategy", "deprecated": false,
"autowired": false, "secret": false, "description": "A pluggable
org.apache.camel.PollingConsumerPollingStrategy allowing you to provide your
custom implementation to control error handling usually occurred during the po
[...]
- "findEntity": { "index": 22, "kind": "parameter", "displayName": "Find
Entity", "group": "producer", "label": "producer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "description": "If enabled, then the
producer will find a single entity by using the message body as a key and
entityType as the class type. This can be used instead of a query to find a
single entity." },
- "firstResult": { "index": 23, "kind": "parameter", "displayName": "First
Result", "group": "producer", "label": "producer", "required": false, "type":
"integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": -1, "description": "Set the position of the
first result to retrieve." },
- "flushOnSend": { "index": 24, "kind": "parameter", "displayName": "Flush
On Send", "group": "producer", "label": "producer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": true, "description": "Flushes the
EntityManager after the entity bean has been persisted." },
- "outputTarget": { "index": 25, "kind": "parameter", "displayName": "Output
Target", "group": "producer", "label": "producer", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "description": "To put the query (or find) result in a
header or property instead of the body. If the value starts with the prefix
property:, put the result into the so named property, otherwise into the
header." },
- "remove": { "index": 26, "kind": "parameter", "displayName": "Remove",
"group": "producer", "label": "producer", "required": false, "type": "boolean",
"javaType": "boolean", "deprecated": false, "autowired": false, "secret":
false, "defaultValue": false, "description": "Indicates to use
entityManager.remove(entity)." },
- "singleResult": { "index": 27, "kind": "parameter", "displayName": "Single
Result", "group": "producer", "label": "producer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "description": "If enabled, a query or
a find which would return no results or more than one result, will throw an
exception instead." },
- "useExecuteUpdate": { "index": 28, "kind": "parameter", "displayName":
"Use Execute Update", "group": "producer", "label": "producer", "required":
false, "type": "boolean", "javaType": "java.lang.Boolean", "deprecated": false,
"autowired": false, "secret": false, "description": "To configure whether to
use executeUpdate() when producer executes a query. When you use INSERT, UPDATE
or a DELETE statement as a named query, you need to specify this option to
'true'." },
- "usePersist": { "index": 29, "kind": "parameter", "displayName": "Use
Persist", "group": "producer", "label": "producer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "description": "Indicates to use
entityManager.persist(entity) instead of entityManager.merge(entity). Note:
entityManager.persist(entity) doesn't work for detached entities (where the
EntityManager has to execute an UPDATE [...]
- "lazyStartProducer": { "index": 30, "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 [...]
- "usePassedInEntityManager": { "index": 31, "kind": "parameter",
"displayName": "Use Passed In Entity Manager", "group": "producer (advanced)",
"label": "producer,advanced", "required": false, "type": "boolean", "javaType":
"boolean", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": false, "description": "If set to true, then Camel will use the
EntityManager from the header JpaConstants.ENTITY_MANAGER instead of the
configured entity manager on the component\/ [...]
- "entityManagerProperties": { "index": 32, "kind": "parameter",
"displayName": "Entity Manager Properties", "group": "advanced", "label":
"advanced", "required": false, "type": "object", "javaType":
"java.util.Map<java.lang.String, java.lang.Object>", "prefix": "emf.",
"multiValue": true, "deprecated": false, "autowired": false, "secret": false,
"description": "Additional properties for the entity manager to use." },
- "sharedEntityManager": { "index": 33, "kind": "parameter", "displayName":
"Shared Entity Manager", "group": "advanced", "label": "advanced", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": false, "description":
"Whether to use Spring's SharedEntityManager for the consumer\/producer. Note
in most cases, joinTransaction should be set to false as this is not an
EXTENDED EntityManager." },
- "backoffErrorThreshold": { "index": 34, "kind": "parameter",
"displayName": "Backoff Error Threshold", "group": "scheduler", "label":
"consumer,scheduler", "required": false, "type": "integer", "javaType": "int",
"deprecated": false, "autowired": false, "secret": false, "description": "The
number of subsequent error polls (failed due some error) that should happen
before the backoffMultipler should kick-in." },
- "backoffIdleThreshold": { "index": 35, "kind": "parameter", "displayName":
"Backoff Idle Threshold", "group": "scheduler", "label": "consumer,scheduler",
"required": false, "type": "integer", "javaType": "int", "deprecated": false,
"autowired": false, "secret": false, "description": "The number of subsequent
idle polls that should happen before the backoffMultipler should kick-in." },
- "backoffMultiplier": { "index": 36, "kind": "parameter", "displayName":
"Backoff Multiplier", "group": "scheduler", "label": "consumer,scheduler",
"required": false, "type": "integer", "javaType": "int", "deprecated": false,
"autowired": false, "secret": false, "description": "To let the scheduled
polling consumer backoff if there has been a number of subsequent idles\/errors
in a row. The multiplier is then the number of polls that will be skipped
before the next actual attempt is h [...]
- "delay": { "index": 37, "kind": "parameter", "displayName": "Delay",
"group": "scheduler", "label": "consumer,scheduler", "required": false, "type":
"integer", "javaType": "long", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 500, "description": "Milliseconds before the
next poll." },
- "greedy": { "index": 38, "kind": "parameter", "displayName": "Greedy",
"group": "scheduler", "label": "consumer,scheduler", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "description": "If greedy is enabled,
then the ScheduledPollConsumer will run immediately again, if the previous run
polled 1 or more messages." },
- "initialDelay": { "index": 39, "kind": "parameter", "displayName":
"Initial Delay", "group": "scheduler", "label": "consumer,scheduler",
"required": false, "type": "integer", "javaType": "long", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": 1000, "description":
"Milliseconds before the first poll starts." },
- "repeatCount": { "index": 40, "kind": "parameter", "displayName": "Repeat
Count", "group": "scheduler", "label": "consumer,scheduler", "required": false,
"type": "integer", "javaType": "long", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 0, "description": "Specifies a maximum limit
of number of fires. So if you set it to 1, the scheduler will only fire once.
If you set it to 5, it will only fire five times. A value of zero or negative
means fire forever." },
- "runLoggingLevel": { "index": 41, "kind": "parameter", "displayName": "Run
Logging Level", "group": "scheduler", "label": "consumer,scheduler",
"required": false, "type": "object", "javaType":
"org.apache.camel.LoggingLevel", "enum": [ "TRACE", "DEBUG", "INFO", "WARN",
"ERROR", "OFF" ], "deprecated": false, "autowired": false, "secret": false,
"defaultValue": "TRACE", "description": "The consumer logs a start\/complete
log line when it polls. This option allows you to configure the l [...]
- "scheduledExecutorService": { "index": 42, "kind": "parameter",
"displayName": "Scheduled Executor Service", "group": "scheduler", "label":
"consumer,scheduler", "required": false, "type": "object", "javaType":
"java.util.concurrent.ScheduledExecutorService", "deprecated": false,
"autowired": false, "secret": false, "description": "Allows for configuring a
custom\/shared thread pool to use for the consumer. By default each consumer
has its own single threaded thread pool." },
- "scheduler": { "index": 43, "kind": "parameter", "displayName":
"Scheduler", "group": "scheduler", "label": "consumer,scheduler", "required":
false, "type": "object", "javaType": "java.lang.Object", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "none", "description": "To
use a cron scheduler from either camel-spring or camel-quartz component. Use
value spring or quartz for built in scheduler" },
- "schedulerProperties": { "index": 44, "kind": "parameter", "displayName":
"Scheduler Properties", "group": "scheduler", "label": "consumer,scheduler",
"required": false, "type": "object", "javaType":
"java.util.Map<java.lang.String, java.lang.Object>", "prefix": "scheduler.",
"multiValue": true, "deprecated": false, "autowired": false, "secret": false,
"description": "To configure additional properties when using a custom
scheduler or any of the Quartz, Spring based scheduler." },
- "startScheduler": { "index": 45, "kind": "parameter", "displayName":
"Start Scheduler", "group": "scheduler", "label": "consumer,scheduler",
"required": false, "type": "boolean", "javaType": "boolean", "deprecated":
false, "autowired": false, "secret": false, "defaultValue": true,
"description": "Whether the scheduler should be auto started." },
- "timeUnit": { "index": 46, "kind": "parameter", "displayName": "Time
Unit", "group": "scheduler", "label": "consumer,scheduler", "required": false,
"type": "object", "javaType": "java.util.concurrent.TimeUnit", "enum": [
"NANOSECONDS", "MICROSECONDS", "MILLISECONDS", "SECONDS", "MINUTES", "HOURS",
"DAYS" ], "deprecated": false, "autowired": false, "secret": false,
"defaultValue": "MILLISECONDS", "description": "Time unit for initialDelay and
delay options." },
- "useFixedDelay": { "index": 47, "kind": "parameter", "displayName": "Use
Fixed Delay", "group": "scheduler", "label": "consumer,scheduler", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": true, "description":
"Controls if fixed delay or fixed rate is used. See ScheduledExecutorService in
JDK for details." }
+ "entityManagerFactory": { "index": 1, "kind": "parameter", "displayName":
"Entity Manager Factory", "group": "common", "label": "", "required": false,
"type": "object", "javaType": "jakarta.persistence.EntityManagerFactory",
"deprecated": false, "autowired": false, "secret": false, "description": "The
EntityManagerFactory to use." },
+ "joinTransaction": { "index": 2, "kind": "parameter", "displayName": "Join
Transaction", "group": "common", "label": "", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": true, "description": "The camel-jpa component
will join transaction by default. You can use this option to turn this off, for
example, if you use LOCAL_RESOURCE and join transaction doesn't work with your
JPA provider. This option c [...]
+ "maximumResults": { "index": 3, "kind": "parameter", "displayName":
"Maximum Results", "group": "common", "label": "", "required": false, "type":
"integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": -1, "description": "Set the maximum number of
results to retrieve on the Query." },
+ "namedQuery": { "index": 4, "kind": "parameter", "displayName": "Named
Query", "group": "common", "label": "", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "description": "To use a named query." },
+ "nativeQuery": { "index": 5, "kind": "parameter", "displayName": "Native
Query", "group": "common", "label": "", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "description": "To use a custom native query. You may want to
use the option resultClass also when using native queries." },
+ "persistenceUnit": { "index": 6, "kind": "parameter", "displayName":
"Persistence Unit", "group": "common", "label": "", "required": true, "type":
"string", "javaType": "java.lang.String", "deprecated": false,
"deprecationNote": "", "autowired": false, "secret": false, "defaultValue":
"camel", "description": "The JPA persistence unit used by default." },
+ "query": { "index": 7, "kind": "parameter", "displayName": "Query",
"group": "common", "label": "", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "description": "To use a custom query." },
+ "resultClass": { "index": 8, "kind": "parameter", "displayName": "Result
Class", "group": "common", "label": "", "required": false, "type": "string",
"javaType": "java.lang.Class<java.lang.Object>", "deprecated": false,
"autowired": false, "secret": false, "description": "Defines the type of the
returned payload (we will call entityManager.createNativeQuery(nativeQuery,
resultClass) instead of entityManager.createNativeQuery(nativeQuery)). Without
this option, we will return an objec [...]
+ "consumeDelete": { "index": 9, "kind": "parameter", "displayName":
"Consume Delete", "group": "consumer", "label": "consumer", "required": false,
"type": "boolean", "javaType": "boolean", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": true, "description": "If true, the
entity is deleted after it is consumed; if false, the entity is not deleted." },
+ "consumeLockEntity": { "index": 10, "kind": "parameter", "displayName":
"Consume Lock Entity", "group": "consumer", "label": "consumer", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": true, "description":
"Specifies whether to set an exclusive lock on each entity bean while
processing the results from polling." },
+ "deleteHandler": { "index": 11, "kind": "parameter", "displayName":
"Delete Handler", "group": "consumer", "label": "consumer", "required": false,
"type": "object", "javaType":
"org.apache.camel.component.jpa.DeleteHandler<java.lang.Object>", "deprecated":
false, "autowired": false, "secret": false, "description": "To use a custom
DeleteHandler to delete the row after the consumer is done processing the
exchange" },
+ "lockModeType": { "index": 12, "kind": "parameter", "displayName": "Lock
Mode Type", "group": "consumer", "label": "consumer", "required": false,
"type": "object", "javaType": "jakarta.persistence.LockModeType", "enum": [
"READ", "WRITE", "OPTIMISTIC", "OPTIMISTIC_FORCE_INCREMENT",
"PESSIMISTIC_READ", "PESSIMISTIC_WRITE", "PESSIMISTIC_FORCE_INCREMENT", "NONE"
], "deprecated": false, "autowired": false, "secret": false, "defaultValue":
"PESSIMISTIC_WRITE", "description": "To configure [...]
+ "maxMessagesPerPoll": { "index": 13, "kind": "parameter", "displayName":
"Max Messages Per Poll", "group": "consumer", "label": "consumer", "required":
false, "type": "integer", "javaType": "int", "deprecated": false, "autowired":
false, "secret": false, "description": "An integer value to define the maximum
number of messages to gather per poll. By default, no maximum is set. It can be
used to avoid polling many thousands of messages when starting up the server.
Set a value of 0 or [...]
+ "preDeleteHandler": { "index": 14, "kind": "parameter", "displayName":
"Pre Delete Handler", "group": "consumer", "label": "consumer", "required":
false, "type": "object", "javaType":
"org.apache.camel.component.jpa.DeleteHandler<java.lang.Object>", "deprecated":
false, "autowired": false, "secret": false, "description": "To use a custom
Pre-DeleteHandler to delete the row after the consumer has read the entity." },
+ "sendEmptyMessageWhenIdle": { "index": 15, "kind": "parameter",
"displayName": "Send Empty Message When Idle", "group": "consumer", "label":
"consumer", "required": false, "type": "boolean", "javaType": "boolean",
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
false, "description": "If the polling consumer did not poll any files, you can
enable this option to send an empty message (no body) instead." },
+ "skipLockedEntity": { "index": 16, "kind": "parameter", "displayName":
"Skip Locked Entity", "group": "consumer", "label": "consumer", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": false, "description": "To
configure whether to use NOWAIT on lock and silently skip the entity." },
+ "transacted": { "index": 17, "kind": "parameter", "displayName":
"Transacted", "group": "consumer", "label": "consumer", "required": false,
"type": "boolean", "javaType": "boolean", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": false, "description": "Whether to run
the consumer in transacted mode, by which all messages will either commit or
rollback, when the entire batch has been processed. The default behavior
(false) is to commit all the previously succ [...]
+ "bridgeErrorHandler": { "index": 18, "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": 19, "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 de [...]
+ "exchangePattern": { "index": 20, "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." },
+ "parameters": { "index": 21, "kind": "parameter", "displayName":
"Parameters", "group": "consumer (advanced)", "label": "consumer,advanced",
"required": false, "type": "object", "javaType":
"java.util.Map<java.lang.String, java.lang.Object>", "prefix": "parameters.",
"multiValue": true, "deprecated": false, "autowired": false, "secret": false,
"description": "This key\/value mapping is used for building the query
parameters. It is expected to be of the generic type java.util.Map wher [...]
+ "pollStrategy": { "index": 22, "kind": "parameter", "displayName": "Poll
Strategy", "group": "consumer (advanced)", "label": "consumer,advanced",
"required": false, "type": "object", "javaType":
"org.apache.camel.spi.PollingConsumerPollStrategy", "deprecated": false,
"autowired": false, "secret": false, "description": "A pluggable
org.apache.camel.PollingConsumerPollingStrategy allowing you to provide your
custom implementation to control error handling usually occurred during the po
[...]
+ "findEntity": { "index": 23, "kind": "parameter", "displayName": "Find
Entity", "group": "producer", "label": "producer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "description": "If enabled, then the
producer will find a single entity by using the message body as a key and
entityType as the class type. This can be used instead of a query to find a
single entity." },
+ "firstResult": { "index": 24, "kind": "parameter", "displayName": "First
Result", "group": "producer", "label": "producer", "required": false, "type":
"integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": -1, "description": "Set the position of the
first result to retrieve." },
+ "flushOnSend": { "index": 25, "kind": "parameter", "displayName": "Flush
On Send", "group": "producer", "label": "producer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": true, "description": "Flushes the
EntityManager after the entity bean has been persisted." },
+ "outputTarget": { "index": 26, "kind": "parameter", "displayName": "Output
Target", "group": "producer", "label": "producer", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "description": "To put the query (or find) result in a
header or property instead of the body. If the value starts with the prefix
property:, put the result into the so named property, otherwise into the
header." },
+ "remove": { "index": 27, "kind": "parameter", "displayName": "Remove",
"group": "producer", "label": "producer", "required": false, "type": "boolean",
"javaType": "boolean", "deprecated": false, "autowired": false, "secret":
false, "defaultValue": false, "description": "Indicates to use
entityManager.remove(entity)." },
+ "singleResult": { "index": 28, "kind": "parameter", "displayName": "Single
Result", "group": "producer", "label": "producer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "description": "If enabled, a query or
a find which would return no results or more than one result, will throw an
exception instead." },
+ "useExecuteUpdate": { "index": 29, "kind": "parameter", "displayName":
"Use Execute Update", "group": "producer", "label": "producer", "required":
false, "type": "boolean", "javaType": "java.lang.Boolean", "deprecated": false,
"autowired": false, "secret": false, "description": "To configure whether to
use executeUpdate() when producer executes a query. When you use INSERT, UPDATE
or a DELETE statement as a named query, you need to specify this option to
'true'." },
+ "usePersist": { "index": 30, "kind": "parameter", "displayName": "Use
Persist", "group": "producer", "label": "producer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "description": "Indicates to use
entityManager.persist(entity) instead of entityManager.merge(entity). Note:
entityManager.persist(entity) doesn't work for detached entities (where the
EntityManager has to execute an UPDATE [...]
+ "lazyStartProducer": { "index": 31, "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 [...]
+ "usePassedInEntityManager": { "index": 32, "kind": "parameter",
"displayName": "Use Passed In Entity Manager", "group": "producer (advanced)",
"label": "producer,advanced", "required": false, "type": "boolean", "javaType":
"boolean", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": false, "description": "If set to true, then Camel will use the
EntityManager from the header JpaConstants.ENTITY_MANAGER instead of the
configured entity manager on the component\/ [...]
+ "entityManagerProperties": { "index": 33, "kind": "parameter",
"displayName": "Entity Manager Properties", "group": "advanced", "label":
"advanced", "required": false, "type": "object", "javaType":
"java.util.Map<java.lang.String, java.lang.Object>", "prefix": "emf.",
"multiValue": true, "deprecated": false, "autowired": false, "secret": false,
"description": "Additional properties for the entity manager to use." },
+ "sharedEntityManager": { "index": 34, "kind": "parameter", "displayName":
"Shared Entity Manager", "group": "advanced", "label": "advanced", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": false, "description":
"Whether to use Spring's SharedEntityManager for the consumer\/producer. Note
in most cases, joinTransaction should be set to false as this is not an
EXTENDED EntityManager." },
+ "backoffErrorThreshold": { "index": 35, "kind": "parameter",
"displayName": "Backoff Error Threshold", "group": "scheduler", "label":
"consumer,scheduler", "required": false, "type": "integer", "javaType": "int",
"deprecated": false, "autowired": false, "secret": false, "description": "The
number of subsequent error polls (failed due some error) that should happen
before the backoffMultipler should kick-in." },
+ "backoffIdleThreshold": { "index": 36, "kind": "parameter", "displayName":
"Backoff Idle Threshold", "group": "scheduler", "label": "consumer,scheduler",
"required": false, "type": "integer", "javaType": "int", "deprecated": false,
"autowired": false, "secret": false, "description": "The number of subsequent
idle polls that should happen before the backoffMultipler should kick-in." },
+ "backoffMultiplier": { "index": 37, "kind": "parameter", "displayName":
"Backoff Multiplier", "group": "scheduler", "label": "consumer,scheduler",
"required": false, "type": "integer", "javaType": "int", "deprecated": false,
"autowired": false, "secret": false, "description": "To let the scheduled
polling consumer backoff if there has been a number of subsequent idles\/errors
in a row. The multiplier is then the number of polls that will be skipped
before the next actual attempt is h [...]
+ "delay": { "index": 38, "kind": "parameter", "displayName": "Delay",
"group": "scheduler", "label": "consumer,scheduler", "required": false, "type":
"integer", "javaType": "long", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 500, "description": "Milliseconds before the
next poll." },
+ "greedy": { "index": 39, "kind": "parameter", "displayName": "Greedy",
"group": "scheduler", "label": "consumer,scheduler", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "description": "If greedy is enabled,
then the ScheduledPollConsumer will run immediately again, if the previous run
polled 1 or more messages." },
+ "initialDelay": { "index": 40, "kind": "parameter", "displayName":
"Initial Delay", "group": "scheduler", "label": "consumer,scheduler",
"required": false, "type": "integer", "javaType": "long", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": 1000, "description":
"Milliseconds before the first poll starts." },
+ "repeatCount": { "index": 41, "kind": "parameter", "displayName": "Repeat
Count", "group": "scheduler", "label": "consumer,scheduler", "required": false,
"type": "integer", "javaType": "long", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 0, "description": "Specifies a maximum limit
of number of fires. So if you set it to 1, the scheduler will only fire once.
If you set it to 5, it will only fire five times. A value of zero or negative
means fire forever." },
+ "runLoggingLevel": { "index": 42, "kind": "parameter", "displayName": "Run
Logging Level", "group": "scheduler", "label": "consumer,scheduler",
"required": false, "type": "object", "javaType":
"org.apache.camel.LoggingLevel", "enum": [ "TRACE", "DEBUG", "INFO", "WARN",
"ERROR", "OFF" ], "deprecated": false, "autowired": false, "secret": false,
"defaultValue": "TRACE", "description": "The consumer logs a start\/complete
log line when it polls. This option allows you to configure the l [...]
+ "scheduledExecutorService": { "index": 43, "kind": "parameter",
"displayName": "Scheduled Executor Service", "group": "scheduler", "label":
"consumer,scheduler", "required": false, "type": "object", "javaType":
"java.util.concurrent.ScheduledExecutorService", "deprecated": false,
"autowired": false, "secret": false, "description": "Allows for configuring a
custom\/shared thread pool to use for the consumer. By default each consumer
has its own single threaded thread pool." },
+ "scheduler": { "index": 44, "kind": "parameter", "displayName":
"Scheduler", "group": "scheduler", "label": "consumer,scheduler", "required":
false, "type": "object", "javaType": "java.lang.Object", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "none", "description": "To
use a cron scheduler from either camel-spring or camel-quartz component. Use
value spring or quartz for built in scheduler" },
+ "schedulerProperties": { "index": 45, "kind": "parameter", "displayName":
"Scheduler Properties", "group": "scheduler", "label": "consumer,scheduler",
"required": false, "type": "object", "javaType":
"java.util.Map<java.lang.String, java.lang.Object>", "prefix": "scheduler.",
"multiValue": true, "deprecated": false, "autowired": false, "secret": false,
"description": "To configure additional properties when using a custom
scheduler or any of the Quartz, Spring based scheduler." },
+ "startScheduler": { "index": 46, "kind": "parameter", "displayName":
"Start Scheduler", "group": "scheduler", "label": "consumer,scheduler",
"required": false, "type": "boolean", "javaType": "boolean", "deprecated":
false, "autowired": false, "secret": false, "defaultValue": true,
"description": "Whether the scheduler should be auto started." },
+ "timeUnit": { "index": 47, "kind": "parameter", "displayName": "Time
Unit", "group": "scheduler", "label": "consumer,scheduler", "required": false,
"type": "object", "javaType": "java.util.concurrent.TimeUnit", "enum": [
"NANOSECONDS", "MICROSECONDS", "MILLISECONDS", "SECONDS", "MINUTES", "HOURS",
"DAYS" ], "deprecated": false, "autowired": false, "secret": false,
"defaultValue": "MILLISECONDS", "description": "Time unit for initialDelay and
delay options." },
+ "useFixedDelay": { "index": 48, "kind": "parameter", "displayName": "Use
Fixed Delay", "group": "scheduler", "label": "consumer,scheduler", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": true, "description":
"Controls if fixed delay or fixed rate is used. See ScheduledExecutorService in
JDK for details." }
}
}
diff --git
a/components/camel-jpa/src/main/java/org/apache/camel/component/jpa/JpaEndpoint.java
b/components/camel-jpa/src/main/java/org/apache/camel/component/jpa/JpaEndpoint.java
index 3ea22bc425a..3d0eba7a8e2 100644
---
a/components/camel-jpa/src/main/java/org/apache/camel/component/jpa/JpaEndpoint.java
+++
b/components/camel-jpa/src/main/java/org/apache/camel/component/jpa/JpaEndpoint.java
@@ -50,6 +50,7 @@ import org.springframework.orm.jpa.SharedEntityManagerCreator;
category = { Category.DATABASE }, headersClass =
JpaConstants.class)
public class JpaEndpoint extends ScheduledPollEndpoint {
+ @UriParam
private EntityManagerFactory entityManagerFactory;
private TransactionStrategy transactionStrategy;
private Expression producerExpression;
diff --git
a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/JpaEndpointBuilderFactory.java
b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/JpaEndpointBuilderFactory.java
index 32b3d2755f0..3cb420ee4ce 100644
---
a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/JpaEndpointBuilderFactory.java
+++
b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/JpaEndpointBuilderFactory.java
@@ -44,6 +44,36 @@ public interface JpaEndpointBuilderFactory {
default AdvancedJpaEndpointConsumerBuilder advanced() {
return (AdvancedJpaEndpointConsumerBuilder) this;
}
+ /**
+ * The EntityManagerFactory to use.
+ *
+ * The option is a:
+ * <code>jakarta.persistence.EntityManagerFactory</code> type.
+ *
+ * Group: common
+ *
+ * @param entityManagerFactory the value to set
+ * @return the dsl builder
+ */
+ default JpaEndpointConsumerBuilder
entityManagerFactory(jakarta.persistence.EntityManagerFactory
entityManagerFactory) {
+ doSetProperty("entityManagerFactory", entityManagerFactory);
+ return this;
+ }
+ /**
+ * The EntityManagerFactory to use.
+ *
+ * The option will be converted to a
+ * <code>jakarta.persistence.EntityManagerFactory</code> type.
+ *
+ * Group: common
+ *
+ * @param entityManagerFactory the value to set
+ * @return the dsl builder
+ */
+ default JpaEndpointConsumerBuilder entityManagerFactory(String
entityManagerFactory) {
+ doSetProperty("entityManagerFactory", entityManagerFactory);
+ return this;
+ }
/**
* The camel-jpa component will join transaction by default. You can
use
* this option to turn this off, for example, if you use LOCAL_RESOURCE
@@ -1255,6 +1285,36 @@ public interface JpaEndpointBuilderFactory {
return (AdvancedJpaEndpointProducerBuilder) this;
}
+ /**
+ * The EntityManagerFactory to use.
+ *
+ * The option is a:
+ * <code>jakarta.persistence.EntityManagerFactory</code> type.
+ *
+ * Group: common
+ *
+ * @param entityManagerFactory the value to set
+ * @return the dsl builder
+ */
+ default JpaEndpointProducerBuilder
entityManagerFactory(jakarta.persistence.EntityManagerFactory
entityManagerFactory) {
+ doSetProperty("entityManagerFactory", entityManagerFactory);
+ return this;
+ }
+ /**
+ * The EntityManagerFactory to use.
+ *
+ * The option will be converted to a
+ * <code>jakarta.persistence.EntityManagerFactory</code> type.
+ *
+ * Group: common
+ *
+ * @param entityManagerFactory the value to set
+ * @return the dsl builder
+ */
+ default JpaEndpointProducerBuilder entityManagerFactory(String
entityManagerFactory) {
+ doSetProperty("entityManagerFactory", entityManagerFactory);
+ return this;
+ }
/**
* The camel-jpa component will join transaction by default. You can
use
* this option to turn this off, for example, if you use LOCAL_RESOURCE
@@ -1837,6 +1897,36 @@ public interface JpaEndpointBuilderFactory {
return (AdvancedJpaEndpointBuilder) this;
}
+ /**
+ * The EntityManagerFactory to use.
+ *
+ * The option is a:
+ * <code>jakarta.persistence.EntityManagerFactory</code> type.
+ *
+ * Group: common
+ *
+ * @param entityManagerFactory the value to set
+ * @return the dsl builder
+ */
+ default JpaEndpointBuilder
entityManagerFactory(jakarta.persistence.EntityManagerFactory
entityManagerFactory) {
+ doSetProperty("entityManagerFactory", entityManagerFactory);
+ return this;
+ }
+ /**
+ * The EntityManagerFactory to use.
+ *
+ * The option will be converted to a
+ * <code>jakarta.persistence.EntityManagerFactory</code> type.
+ *
+ * Group: common
+ *
+ * @param entityManagerFactory the value to set
+ * @return the dsl builder
+ */
+ default JpaEndpointBuilder entityManagerFactory(String
entityManagerFactory) {
+ doSetProperty("entityManagerFactory", entityManagerFactory);
+ return this;
+ }
/**
* The camel-jpa component will join transaction by default. You can
use
* this option to turn this off, for example, if you use LOCAL_RESOURCE
