This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch camel-4.4.x
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 13cae7f94db2803f43903b0115577f331fa7732c
Author: Claus Ibsen <claus.ib...@gmail.com>
AuthorDate: Thu Apr 18 20:33:55 2024 +0200
Regen
---
.../apache/camel/component/avro/AvroComponent.java | 4 +-
.../camel/component/avro/AvroConfiguration.java | 8 +--
.../aws/config/AWSConfigConfiguration.java | 8 +--
.../SecretsManagerConfiguration.java | 7 ++-
.../aws2/athena/Athena2Configuration.java | 4 +-
.../camel/component/aws2/cw/Cw2Configuration.java | 8 +--
.../component/aws2/ec2/AWS2EC2Configuration.java | 4 +-
.../component/aws2/ecs/ECS2Configuration.java | 4 +-
.../component/aws2/eks/EKS2Configuration.java | 4 +-
.../aws2/eventbridge/EventbridgeConfiguration.java | 13 ++--
.../component/aws2/iam/IAM2Configuration.java | 4 +-
.../component/aws2/kms/KMS2Configuration.java | 4 +-
.../aws2/lambda/Lambda2Configuration.java | 8 +--
.../camel/component/aws2/mq/MQ2Configuration.java | 8 +--
.../component/aws2/msk/MSK2Configuration.java | 4 +-
.../redshift/data/RedshiftData2Configuration.java | 4 +-
.../component/aws2/s3/AWS2S3Configuration.java | 29 +++++----
.../component/aws2/ses/Ses2Configuration.java | 4 +-
.../component/aws2/sns/Sns2Configuration.java | 10 ++--
.../component/aws2/sqs/Sqs2Configuration.java | 10 ++--
.../stepfunctions/StepFunctions2Configuration.java | 4 +-
.../component/aws2/sts/STS2Configuration.java | 4 +-
.../aws2/timestream/Timestream2Configuration.java | 8 +--
.../aws2/translate/Translate2Configuration.java | 8 +--
.../azure/servicebus/ServiceBusProducer.java | 4 +-
.../camel/component/dataset/DataSetEndpoint.java | 3 +-
.../apache/camel/component/file/FileEndpoint.java | 1 -
.../camel/component/jms/JmsConfiguration.java | 69 +++++++++++-----------
.../JsonPathSplitSingleListOptionTest.java | 3 +-
.../camel/component/kafka/KafkaConfiguration.java | 55 ++++++++---------
.../batching/KafkaRecordBatchingProcessor.java | 7 ++-
.../component/micrometer/MicrometerEndpoint.java | 3 +-
.../camel/component/mustache/MustacheEndpoint.java | 3 +-
.../internal/processor/RawProcessor.java | 3 +-
.../component/scheduler/SchedulerEndpoint.java | 3 +-
.../apache/camel/component/sjms/SjmsProducer.java | 2 +-
.../sjms/consumer/EndpointMessageListener.java | 5 +-
.../camel/component/sql/DefaultSqlEndpoint.java | 22 +++----
.../apache/camel/component/stub/StubConsole.java | 2 +-
.../java/org/apache/camel/spi/BacklogDebugger.java | 3 +-
40 files changed, 185 insertions(+), 176 deletions(-)
diff --git
a/components/camel-avro-rpc/camel-avro-rpc-component/src/main/java/org/apache/camel/component/avro/AvroComponent.java
b/components/camel-avro-rpc/camel-avro-rpc-component/src/main/java/org/apache/camel/component/avro/AvroComponent.java
index c0f2f26d144..12364f50202 100644
---
a/components/camel-avro-rpc/camel-avro-rpc-component/src/main/java/org/apache/camel/component/avro/AvroComponent.java
+++
b/components/camel-avro-rpc/camel-avro-rpc-component/src/main/java/org/apache/camel/component/avro/AvroComponent.java
@@ -95,8 +95,8 @@ public class AvroComponent extends DefaultComponent {
}
/**
- * Calls unregister of consumer by the appropriate message name.
- * In case if all consumers are unregistered, then it removes responder
from the registry.
+ * Calls unregister of consumer by the appropriate message name. In case
if all consumers are unregistered, then it
+ * removes responder from the registry.
*
* @param uri URI of the endpoint without message name
* @param messageName message name
diff --git
a/components/camel-avro-rpc/camel-avro-rpc-component/src/main/java/org/apache/camel/component/avro/AvroConfiguration.java
b/components/camel-avro-rpc/camel-avro-rpc-component/src/main/java/org/apache/camel/component/avro/AvroConfiguration.java
index 5bafefa750c..db6a3b1af24 100644
---
a/components/camel-avro-rpc/camel-avro-rpc-component/src/main/java/org/apache/camel/component/avro/AvroConfiguration.java
+++
b/components/camel-avro-rpc/camel-avro-rpc-component/src/main/java/org/apache/camel/component/avro/AvroConfiguration.java
@@ -182,8 +182,8 @@ public class AvroConfiguration implements Cloneable {
}
/**
- * If the protocol object provided is reflection protocol.
- * Should be used only with protocol parameter because for
protocolClassName protocol type will be auto-detected
+ * If the protocol object provided is reflection protocol. Should be used
only with protocol parameter because for
+ * protocolClassName protocol type will be auto-detected
*/
public void setReflectionProtocol(boolean isReflectionProtocol) {
this.reflectionProtocol = isReflectionProtocol;
@@ -194,8 +194,8 @@ public class AvroConfiguration implements Cloneable {
}
/**
- * If true, consumer parameter won't be wrapped into an array.
- * Will fail if protocol specifies more than one parameter for the message
+ * If true, consumer parameter won't be wrapped into an array. Will fail
if protocol specifies more than one
+ * parameter for the message
*/
public void setSingleParameter(boolean singleParameter) {
this.singleParameter = singleParameter;
diff --git
a/components/camel-aws/camel-aws-config/src/main/java/org/apache/camel/component/aws/config/AWSConfigConfiguration.java
b/components/camel-aws/camel-aws-config/src/main/java/org/apache/camel/component/aws/config/AWSConfigConfiguration.java
index a1ba2166956..00d00fcaf3b 100644
---
a/components/camel-aws/camel-aws-config/src/main/java/org/apache/camel/component/aws/config/AWSConfigConfiguration.java
+++
b/components/camel-aws/camel-aws-config/src/main/java/org/apache/camel/component/aws/config/AWSConfigConfiguration.java
@@ -194,8 +194,8 @@ public class AWSConfigConfiguration implements Cloneable {
}
/**
- * Set the need for overriding the endpoint. This option needs to be used
in combination with the uriEndpointOverride
- * option
+ * Set the need for overriding the endpoint. This option needs to be used
in combination with the
+ * uriEndpointOverride option
*/
public void setOverrideEndpoint(boolean overrideEndpoint) {
this.overrideEndpoint = overrideEndpoint;
@@ -240,8 +240,8 @@ public class AWSConfigConfiguration implements Cloneable {
}
/**
- * Set whether the Config client should expect to use Session Credentials.
This is useful in a situation in which the
- * user needs to assume an IAM role for doing operations in Config.
+ * Set whether the Config client should expect to use Session Credentials.
This is useful in a situation in which
+ * the user needs to assume an IAM role for doing operations in Config.
*/
public void setUseSessionCredentials(boolean useSessionCredentials) {
this.useSessionCredentials = useSessionCredentials;
diff --git
a/components/camel-aws/camel-aws-secrets-manager/src/main/java/org/apache/camel/component/aws/secretsmanager/SecretsManagerConfiguration.java
b/components/camel-aws/camel-aws-secrets-manager/src/main/java/org/apache/camel/component/aws/secretsmanager/SecretsManagerConfiguration.java
index 6683bbddbb0..40e5a924999 100644
---
a/components/camel-aws/camel-aws-secrets-manager/src/main/java/org/apache/camel/component/aws/secretsmanager/SecretsManagerConfiguration.java
+++
b/components/camel-aws/camel-aws-secrets-manager/src/main/java/org/apache/camel/component/aws/secretsmanager/SecretsManagerConfiguration.java
@@ -167,7 +167,8 @@ public class SecretsManagerConfiguration implements
Cloneable {
/**
* The region in which a Secrets Manager client needs to work. When using
this parameter, the configuration will
- * expect the lowercase name of the region (for example, ap-east-1) You'll
need to use the name Region.EU_WEST_1.id()
+ * expect the lowercase name of the region (for example, ap-east-1) You'll
need to use the name
+ * Region.EU_WEST_1.id()
*/
public void setRegion(String region) {
this.region = region;
@@ -200,8 +201,8 @@ public class SecretsManagerConfiguration implements
Cloneable {
}
/**
- * Set the need for overriding the endpoint. This option needs to be used
in combination with the uriEndpointOverride
- * option
+ * Set the need for overriding the endpoint. This option needs to be used
in combination with the
+ * uriEndpointOverride option
*/
public void setOverrideEndpoint(boolean overrideEndpoint) {
this.overrideEndpoint = overrideEndpoint;
diff --git
a/components/camel-aws/camel-aws2-athena/src/main/java/org/apache/camel/component/aws2/athena/Athena2Configuration.java
b/components/camel-aws/camel-aws2-athena/src/main/java/org/apache/camel/component/aws2/athena/Athena2Configuration.java
index 5dd4327bc3b..9fb4896e5b5 100644
---
a/components/camel-aws/camel-aws2-athena/src/main/java/org/apache/camel/component/aws2/athena/Athena2Configuration.java
+++
b/components/camel-aws/camel-aws2-athena/src/main/java/org/apache/camel/component/aws2/athena/Athena2Configuration.java
@@ -478,8 +478,8 @@ public class Athena2Configuration implements Cloneable {
}
/**
- * Set whether the Athena client should expect to use Session Credentials.
This is useful in a situation in which the
- * user needs to assume a IAM role for doing operations in Athena.
+ * Set whether the Athena client should expect to use Session Credentials.
This is useful in a situation in which
+ * the user needs to assume a IAM role for doing operations in Athena.
*/
public void setUseSessionCredentials(boolean useSessionCredentials) {
this.useSessionCredentials = useSessionCredentials;
diff --git
a/components/camel-aws/camel-aws2-cw/src/main/java/org/apache/camel/component/aws2/cw/Cw2Configuration.java
b/components/camel-aws/camel-aws2-cw/src/main/java/org/apache/camel/component/aws2/cw/Cw2Configuration.java
index 9b2ad670b06..2d880abcbf5 100644
---
a/components/camel-aws/camel-aws2-cw/src/main/java/org/apache/camel/component/aws2/cw/Cw2Configuration.java
+++
b/components/camel-aws/camel-aws2-cw/src/main/java/org/apache/camel/component/aws2/cw/Cw2Configuration.java
@@ -232,8 +232,8 @@ public class Cw2Configuration implements Cloneable {
}
/**
- * Set the need for overriding the endpoint. This option needs to be used
in combination with the uriEndpointOverride
- * option
+ * Set the need for overriding the endpoint. This option needs to be used
in combination with the
+ * uriEndpointOverride option
*/
public void setOverrideEndpoint(boolean overrideEndpoint) {
this.overrideEndpoint = overrideEndpoint;
@@ -278,8 +278,8 @@ public class Cw2Configuration implements Cloneable {
}
/**
- * Set whether the CloudWatch client should expect to use Session
Credentials. This is useful in a situation in which
- * the user needs to assume an IAM role for doing operations in CloudWatch.
+ * Set whether the CloudWatch client should expect to use Session
Credentials. This is useful in a situation in
+ * which the user needs to assume an IAM role for doing operations in
CloudWatch.
*/
public void setUseSessionCredentials(boolean useSessionCredentials) {
this.useSessionCredentials = useSessionCredentials;
diff --git
a/components/camel-aws/camel-aws2-ec2/src/main/java/org/apache/camel/component/aws2/ec2/AWS2EC2Configuration.java
b/components/camel-aws/camel-aws2-ec2/src/main/java/org/apache/camel/component/aws2/ec2/AWS2EC2Configuration.java
index 8b7f153956d..8825faff329 100644
---
a/components/camel-aws/camel-aws2-ec2/src/main/java/org/apache/camel/component/aws2/ec2/AWS2EC2Configuration.java
+++
b/components/camel-aws/camel-aws2-ec2/src/main/java/org/apache/camel/component/aws2/ec2/AWS2EC2Configuration.java
@@ -196,8 +196,8 @@ public class AWS2EC2Configuration implements Cloneable {
}
/**
- * Set the need for overriding the endpoint. This option needs to be used
in combination with the uriEndpointOverride
- * option
+ * Set the need for overriding the endpoint. This option needs to be used
in combination with the
+ * uriEndpointOverride option
*/
public void setOverrideEndpoint(boolean overrideEndpoint) {
this.overrideEndpoint = overrideEndpoint;
diff --git
a/components/camel-aws/camel-aws2-ecs/src/main/java/org/apache/camel/component/aws2/ecs/ECS2Configuration.java
b/components/camel-aws/camel-aws2-ecs/src/main/java/org/apache/camel/component/aws2/ecs/ECS2Configuration.java
index 82de17213d7..1bd5b012d92 100644
---
a/components/camel-aws/camel-aws2-ecs/src/main/java/org/apache/camel/component/aws2/ecs/ECS2Configuration.java
+++
b/components/camel-aws/camel-aws2-ecs/src/main/java/org/apache/camel/component/aws2/ecs/ECS2Configuration.java
@@ -195,8 +195,8 @@ public class ECS2Configuration implements Cloneable {
}
/**
- * Set the need for overriding the endpoint. This option needs to be used
in combination with the uriEndpointOverride
- * option
+ * Set the need for overriding the endpoint. This option needs to be used
in combination with the
+ * uriEndpointOverride option
*/
public void setOverrideEndpoint(boolean overrideEndpoint) {
this.overrideEndpoint = overrideEndpoint;
diff --git
a/components/camel-aws/camel-aws2-eks/src/main/java/org/apache/camel/component/aws2/eks/EKS2Configuration.java
b/components/camel-aws/camel-aws2-eks/src/main/java/org/apache/camel/component/aws2/eks/EKS2Configuration.java
index 63fb7882a93..849c3e73b73 100644
---
a/components/camel-aws/camel-aws2-eks/src/main/java/org/apache/camel/component/aws2/eks/EKS2Configuration.java
+++
b/components/camel-aws/camel-aws2-eks/src/main/java/org/apache/camel/component/aws2/eks/EKS2Configuration.java
@@ -194,8 +194,8 @@ public class EKS2Configuration implements Cloneable {
}
/**
- * Set the need for overriding the endpoint. This option needs to be used
in combination with the uriEndpointOverride
- * option
+ * Set the need for overriding the endpoint. This option needs to be used
in combination with the
+ * uriEndpointOverride option
*/
public void setOverrideEndpoint(boolean overrideEndpoint) {
this.overrideEndpoint = overrideEndpoint;
diff --git
a/components/camel-aws/camel-aws2-eventbridge/src/main/java/org/apache/camel/component/aws2/eventbridge/EventbridgeConfiguration.java
b/components/camel-aws/camel-aws2-eventbridge/src/main/java/org/apache/camel/component/aws2/eventbridge/EventbridgeConfiguration.java
index 590619cd26d..c7eb0253bbd 100644
---
a/components/camel-aws/camel-aws2-eventbridge/src/main/java/org/apache/camel/component/aws2/eventbridge/EventbridgeConfiguration.java
+++
b/components/camel-aws/camel-aws2-eventbridge/src/main/java/org/apache/camel/component/aws2/eventbridge/EventbridgeConfiguration.java
@@ -160,8 +160,9 @@ public class EventbridgeConfiguration implements Cloneable {
}
/**
- * The region in which the Eventbridge client needs to work. When using
this parameter, the configuration will expect
- * the lowercase name of the region (for example, ap-east-1) You'll need
to use the name Region.EU_WEST_1.id()
+ * The region in which the Eventbridge client needs to work. When using
this parameter, the configuration will
+ * expect the lowercase name of the region (for example, ap-east-1) You'll
need to use the name
+ * Region.EU_WEST_1.id()
*/
public void setRegion(String region) {
this.region = region;
@@ -216,8 +217,8 @@ public class EventbridgeConfiguration implements Cloneable {
}
/**
- * Set the need for overriding the endpoint. This option needs to be used
in combination with the uriEndpointOverride
- * option
+ * Set the need for overriding the endpoint. This option needs to be used
in combination with the
+ * uriEndpointOverride option
*/
public void setOverrideEndpoint(boolean overrideEndpoint) {
this.overrideEndpoint = overrideEndpoint;
@@ -262,8 +263,8 @@ public class EventbridgeConfiguration implements Cloneable {
}
/**
- * Set whether the Eventbridge client should expect to use Session
Credentials. This is useful in a situation in which
- * the user needs to assume an IAM role for doing operations in
Eventbridge.
+ * Set whether the Eventbridge client should expect to use Session
Credentials. This is useful in a situation in
+ * which the user needs to assume an IAM role for doing operations in
Eventbridge.
*/
public void setUseSessionCredentials(boolean useSessionCredentials) {
this.useSessionCredentials = useSessionCredentials;
diff --git
a/components/camel-aws/camel-aws2-iam/src/main/java/org/apache/camel/component/aws2/iam/IAM2Configuration.java
b/components/camel-aws/camel-aws2-iam/src/main/java/org/apache/camel/component/aws2/iam/IAM2Configuration.java
index 9db6bb23a1b..386398198f4 100644
---
a/components/camel-aws/camel-aws2-iam/src/main/java/org/apache/camel/component/aws2/iam/IAM2Configuration.java
+++
b/components/camel-aws/camel-aws2-iam/src/main/java/org/apache/camel/component/aws2/iam/IAM2Configuration.java
@@ -198,8 +198,8 @@ public class IAM2Configuration implements Cloneable {
}
/**
- * Set the need for overriding the endpoint. This option needs to be used
in combination with the uriEndpointOverride
- * option
+ * Set the need for overriding the endpoint. This option needs to be used
in combination with the
+ * uriEndpointOverride option
*/
public void setOverrideEndpoint(boolean overrideEndpoint) {
this.overrideEndpoint = overrideEndpoint;
diff --git
a/components/camel-aws/camel-aws2-kms/src/main/java/org/apache/camel/component/aws2/kms/KMS2Configuration.java
b/components/camel-aws/camel-aws2-kms/src/main/java/org/apache/camel/component/aws2/kms/KMS2Configuration.java
index 9437a45b5cf..08c47dbe742 100644
---
a/components/camel-aws/camel-aws2-kms/src/main/java/org/apache/camel/component/aws2/kms/KMS2Configuration.java
+++
b/components/camel-aws/camel-aws2-kms/src/main/java/org/apache/camel/component/aws2/kms/KMS2Configuration.java
@@ -194,8 +194,8 @@ public class KMS2Configuration implements Cloneable {
}
/**
- * Set the need for overriding the endpoint. This option needs to be used
in combination with the uriEndpointOverride
- * option
+ * Set the need for overriding the endpoint. This option needs to be used
in combination with the
+ * uriEndpointOverride option
*/
public void setOverrideEndpoint(boolean overrideEndpoint) {
this.overrideEndpoint = overrideEndpoint;
diff --git
a/components/camel-aws/camel-aws2-lambda/src/main/java/org/apache/camel/component/aws2/lambda/Lambda2Configuration.java
b/components/camel-aws/camel-aws2-lambda/src/main/java/org/apache/camel/component/aws2/lambda/Lambda2Configuration.java
index e5cc5eeeb73..97bf07b3d18 100644
---
a/components/camel-aws/camel-aws2-lambda/src/main/java/org/apache/camel/component/aws2/lambda/Lambda2Configuration.java
+++
b/components/camel-aws/camel-aws2-lambda/src/main/java/org/apache/camel/component/aws2/lambda/Lambda2Configuration.java
@@ -189,8 +189,8 @@ public class Lambda2Configuration implements Cloneable {
}
/**
- * Set the need for overriding the endpoint. This option needs to be used
in combination with the uriEndpointOverride
- * option
+ * Set the need for overriding the endpoint. This option needs to be used
in combination with the
+ * uriEndpointOverride option
*/
public void setOverrideEndpoint(boolean overrideEndpoint) {
this.overrideEndpoint = overrideEndpoint;
@@ -235,8 +235,8 @@ public class Lambda2Configuration implements Cloneable {
}
/**
- * Set whether the Lambda client should expect to use Session Credentials.
This is useful in a situation in which the
- * user needs to assume an IAM role for doing operations in Lambda.
+ * Set whether the Lambda client should expect to use Session Credentials.
This is useful in a situation in which
+ * the user needs to assume an IAM role for doing operations in Lambda.
*/
public void setUseSessionCredentials(boolean useSessionCredentials) {
this.useSessionCredentials = useSessionCredentials;
diff --git
a/components/camel-aws/camel-aws2-mq/src/main/java/org/apache/camel/component/aws2/mq/MQ2Configuration.java
b/components/camel-aws/camel-aws2-mq/src/main/java/org/apache/camel/component/aws2/mq/MQ2Configuration.java
index 806f8353590..ff00c166f00 100644
---
a/components/camel-aws/camel-aws2-mq/src/main/java/org/apache/camel/component/aws2/mq/MQ2Configuration.java
+++
b/components/camel-aws/camel-aws2-mq/src/main/java/org/apache/camel/component/aws2/mq/MQ2Configuration.java
@@ -195,8 +195,8 @@ public class MQ2Configuration implements Cloneable {
}
/**
- * Set the need for overriding the endpoint. This option needs to be used
in combination with the uriEndpointOverride
- * option
+ * Set the need for overriding the endpoint. This option needs to be used
in combination with the
+ * uriEndpointOverride option
*/
public void setOverrideEndpoint(boolean overrideEndpoint) {
this.overrideEndpoint = overrideEndpoint;
@@ -241,8 +241,8 @@ public class MQ2Configuration implements Cloneable {
}
/**
- * Set whether the MQ client should expect to use Session Credentials.
This is useful in a situation in which the user
- * needs to assume an IAM role for doing operations in MQ.
+ * Set whether the MQ client should expect to use Session Credentials.
This is useful in a situation in which the
+ * user needs to assume an IAM role for doing operations in MQ.
*/
public void setUseSessionCredentials(boolean useSessionCredentials) {
this.useSessionCredentials = useSessionCredentials;
diff --git
a/components/camel-aws/camel-aws2-msk/src/main/java/org/apache/camel/component/aws2/msk/MSK2Configuration.java
b/components/camel-aws/camel-aws2-msk/src/main/java/org/apache/camel/component/aws2/msk/MSK2Configuration.java
index 5a646987fcc..e6c745b5566 100644
---
a/components/camel-aws/camel-aws2-msk/src/main/java/org/apache/camel/component/aws2/msk/MSK2Configuration.java
+++
b/components/camel-aws/camel-aws2-msk/src/main/java/org/apache/camel/component/aws2/msk/MSK2Configuration.java
@@ -195,8 +195,8 @@ public class MSK2Configuration implements Cloneable {
}
/**
- * Set the need for overriding the endpoint. This option needs to be used
in combination with the uriEndpointOverride
- * option
+ * Set the need for overriding the endpoint. This option needs to be used
in combination with the
+ * uriEndpointOverride option
*/
public void setOverrideEndpoint(boolean overrideEndpoint) {
this.overrideEndpoint = overrideEndpoint;
diff --git
a/components/camel-aws/camel-aws2-redshift/src/main/java/org/apache/camel/component/aws2/redshift/data/RedshiftData2Configuration.java
b/components/camel-aws/camel-aws2-redshift/src/main/java/org/apache/camel/component/aws2/redshift/data/RedshiftData2Configuration.java
index 2d66661cb95..ec7c47e6e78 100644
---
a/components/camel-aws/camel-aws2-redshift/src/main/java/org/apache/camel/component/aws2/redshift/data/RedshiftData2Configuration.java
+++
b/components/camel-aws/camel-aws2-redshift/src/main/java/org/apache/camel/component/aws2/redshift/data/RedshiftData2Configuration.java
@@ -195,8 +195,8 @@ public class RedshiftData2Configuration implements
Cloneable {
}
/**
- * Set the need for overriding the endpoint. This option needs to be used
in combination with the uriEndpointOverride
- * option
+ * Set the need for overriding the endpoint. This option needs to be used
in combination with the
+ * uriEndpointOverride option
*/
public void setOverrideEndpoint(boolean overrideEndpoint) {
this.overrideEndpoint = overrideEndpoint;
diff --git
a/components/camel-aws/camel-aws2-s3/src/main/java/org/apache/camel/component/aws2/s3/AWS2S3Configuration.java
b/components/camel-aws/camel-aws2-s3/src/main/java/org/apache/camel/component/aws2/s3/AWS2S3Configuration.java
index 4ea6671ad4d..82f4b482997 100644
---
a/components/camel-aws/camel-aws2-s3/src/main/java/org/apache/camel/component/aws2/s3/AWS2S3Configuration.java
+++
b/components/camel-aws/camel-aws2-s3/src/main/java/org/apache/camel/component/aws2/s3/AWS2S3Configuration.java
@@ -160,8 +160,7 @@ public class AWS2S3Configuration implements Cloneable {
}
/**
- * If it is true, camel will upload the file with multipart format. The
part size is decided by the partSize
- * option.
+ * If it is true, camel will upload the file with multipart format. The
part size is decided by the partSize option.
*
* Camel will only do multipart uploads for files that are larger than the
part-size thresholds. Files that are
* smaller will be uploaded in a single operation.
@@ -298,10 +297,10 @@ public class AWS2S3Configuration implements Cloneable {
/**
* If it is true, the S3Object exchange will be consumed and put into the
body and closed. If false, the S3Object
* stream will be put raw into the body and the headers will be set with
the S3 object metadata. This option is
- * strongly related to the autocloseBody option. In case of setting
includeBody to true because the S3Object stream will
- * be consumed then it will also be closed, while in case of includeBody
false then it will be up to the caller to
- * close the S3Object stream. However, setting autocloseBody to true when
includeBody is false it will schedule to
- * close the S3Object stream automatically on exchange completion.
+ * strongly related to the autocloseBody option. In case of setting
includeBody to true because the S3Object stream
+ * will be consumed then it will also be closed, while in case of
includeBody false then it will be up to the caller
+ * to close the S3Object stream. However, setting autocloseBody to true
when includeBody is false it will schedule
+ * to close the S3Object stream automatically on exchange completion.
*/
public void setIncludeBody(boolean includeBody) {
this.includeBody = includeBody;
@@ -328,8 +327,8 @@ public class AWS2S3Configuration implements Cloneable {
}
/**
- * Delete objects from S3 after they have been retrieved. The deleting is
only performed if the Exchange is committed.
- * If a rollback occurs, the object is not deleted.
+ * Delete objects from S3 after they have been retrieved. The deleting is
only performed if the Exchange is
+ * committed. If a rollback occurs, the object is not deleted.
* <p/>
* If this option is false, then the same objects will be retrieved over
and over again in the polls. Therefore, you
* need to use the Idempotent Consumer EIP in the route to filter out
duplicates. You can filter using the
@@ -345,9 +344,9 @@ public class AWS2S3Configuration implements Cloneable {
}
/**
- * Move objects from S3 bucket to a different bucket after they have been
retrieved. To accomplish the operation, the
- * destinationBucket option must be set. The copy bucket operation is only
performed if the Exchange is committed.
- * If a rollback occurs, the object is not moved.
+ * Move objects from S3 bucket to a different bucket after they have been
retrieved. To accomplish the operation,
+ * the destinationBucket option must be set. The copy bucket operation is
only performed if the Exchange is
+ * committed. If a rollback occurs, the object is not moved.
*/
public void setMoveAfterRead(boolean moveAfterRead) {
this.moveAfterRead = moveAfterRead;
@@ -581,8 +580,8 @@ public class AWS2S3Configuration implements Cloneable {
}
/**
- * Set whether the S3 client should expect to use Session Credentials.
This is useful in a situation in which the user
- * needs to assume an IAM role for doing operations in S3.
+ * Set whether the S3 client should expect to use Session Credentials.
This is useful in a situation in which the
+ * user needs to assume an IAM role for doing operations in S3.
*/
public void setUseSessionCredentials(boolean useSessionCredentials) {
this.useSessionCredentials = useSessionCredentials;
@@ -616,8 +615,8 @@ public class AWS2S3Configuration implements Cloneable {
}
/**
- * Set the need for overriding the endpoint. This option needs to be used
in combination with the uriEndpointOverride
- * option
+ * Set the need for overriding the endpoint. This option needs to be used
in combination with the
+ * uriEndpointOverride option
*/
public void setOverrideEndpoint(boolean overrideEndpoint) {
this.overrideEndpoint = overrideEndpoint;
diff --git
a/components/camel-aws/camel-aws2-ses/src/main/java/org/apache/camel/component/aws2/ses/Ses2Configuration.java
b/components/camel-aws/camel-aws2-ses/src/main/java/org/apache/camel/component/aws2/ses/Ses2Configuration.java
index 1813fdf3599..609467b0fab 100644
---
a/components/camel-aws/camel-aws2-ses/src/main/java/org/apache/camel/component/aws2/ses/Ses2Configuration.java
+++
b/components/camel-aws/camel-aws2-ses/src/main/java/org/apache/camel/component/aws2/ses/Ses2Configuration.java
@@ -263,8 +263,8 @@ public class Ses2Configuration implements Cloneable {
}
/**
- * Set the need for overriding the endpoint. This option needs to be used
in combination with the uriEndpointOverride
- * option
+ * Set the need for overriding the endpoint. This option needs to be used
in combination with the
+ * uriEndpointOverride option
*/
public void setOverrideEndpoint(boolean overrideEndpoint) {
this.overrideEndpoint = overrideEndpoint;
diff --git
a/components/camel-aws/camel-aws2-sns/src/main/java/org/apache/camel/component/aws2/sns/Sns2Configuration.java
b/components/camel-aws/camel-aws2-sns/src/main/java/org/apache/camel/component/aws2/sns/Sns2Configuration.java
index ada38f5daeb..eac8bb5d231 100644
---
a/components/camel-aws/camel-aws2-sns/src/main/java/org/apache/camel/component/aws2/sns/Sns2Configuration.java
+++
b/components/camel-aws/camel-aws2-sns/src/main/java/org/apache/camel/component/aws2/sns/Sns2Configuration.java
@@ -374,9 +374,9 @@ public class Sns2Configuration implements Cloneable {
}
/**
- * Only for FIFO Topic. Strategy for setting the messageDeduplicationId on
the message. It can be one of the following
- * options: *useExchangeId*, *useContentBasedDeduplication*. For the
*useContentBasedDeduplication* option, no
- * messageDeduplicationId will be set on the message.
+ * Only for FIFO Topic. Strategy for setting the messageDeduplicationId on
the message. It can be one of the
+ * following options: *useExchangeId*, *useContentBasedDeduplication*. For
the *useContentBasedDeduplication*
+ * option, no messageDeduplicationId will be set on the message.
*/
public void setMessageDeduplicationIdStrategy(String strategy) {
if ("useExchangeId".equalsIgnoreCase(strategy)) {
@@ -397,8 +397,8 @@ public class Sns2Configuration implements Cloneable {
}
/**
- * Set the need for overriding the endpoint. This option needs to be used
in combination with the uriEndpointOverride
- * option
+ * Set the need for overriding the endpoint. This option needs to be used
in combination with the
+ * uriEndpointOverride option
*/
public void setOverrideEndpoint(boolean overrideEndpoint) {
this.overrideEndpoint = overrideEndpoint;
diff --git
a/components/camel-aws/camel-aws2-sqs/src/main/java/org/apache/camel/component/aws2/sqs/Sqs2Configuration.java
b/components/camel-aws/camel-aws2-sqs/src/main/java/org/apache/camel/component/aws2/sqs/Sqs2Configuration.java
index 799c06c3cb2..9303360007a 100644
---
a/components/camel-aws/camel-aws2-sqs/src/main/java/org/apache/camel/component/aws2/sqs/Sqs2Configuration.java
+++
b/components/camel-aws/camel-aws2-sqs/src/main/java/org/apache/camel/component/aws2/sqs/Sqs2Configuration.java
@@ -524,9 +524,9 @@ public class Sqs2Configuration implements Cloneable {
}
/**
- * Only for FIFO queues. Strategy for setting the messageDeduplicationId
on the message. It can be one of the following
- * options: *useExchangeId*, *useContentBasedDeduplication*. For the
*useContentBasedDeduplication* option, no
- * messageDeduplicationId will be set on the message.
+ * Only for FIFO queues. Strategy for setting the messageDeduplicationId
on the message. It can be one of the
+ * following options: *useExchangeId*, *useContentBasedDeduplication*. For
the *useContentBasedDeduplication*
+ * option, no messageDeduplicationId will be set on the message.
*/
public void setMessageDeduplicationIdStrategy(String strategy) {
if ("useExchangeId".equalsIgnoreCase(strategy)) {
@@ -654,8 +654,8 @@ public class Sqs2Configuration implements Cloneable {
}
/**
- * Set the need for overriding the endpoint. This option needs to be used
in combination with the uriEndpointOverride
- * option
+ * Set the need for overriding the endpoint. This option needs to be used
in combination with the
+ * uriEndpointOverride option
*/
public void setOverrideEndpoint(boolean overrideEndpoint) {
this.overrideEndpoint = overrideEndpoint;
diff --git
a/components/camel-aws/camel-aws2-step-functions/src/main/java/org/apache/camel/component/aws2/stepfunctions/StepFunctions2Configuration.java
b/components/camel-aws/camel-aws2-step-functions/src/main/java/org/apache/camel/component/aws2/stepfunctions/StepFunctions2Configuration.java
index b488e4373f6..e3bc8b1b66f 100644
---
a/components/camel-aws/camel-aws2-step-functions/src/main/java/org/apache/camel/component/aws2/stepfunctions/StepFunctions2Configuration.java
+++
b/components/camel-aws/camel-aws2-step-functions/src/main/java/org/apache/camel/component/aws2/stepfunctions/StepFunctions2Configuration.java
@@ -195,8 +195,8 @@ public class StepFunctions2Configuration implements
Cloneable {
}
/**
- * Set the need for overriding the endpoint. This option needs to be used
in combination with the uriEndpointOverride
- * option
+ * Set the need for overriding the endpoint. This option needs to be used
in combination with the
+ * uriEndpointOverride option
*/
public void setOverrideEndpoint(boolean overrideEndpoint) {
this.overrideEndpoint = overrideEndpoint;
diff --git
a/components/camel-aws/camel-aws2-sts/src/main/java/org/apache/camel/component/aws2/sts/STS2Configuration.java
b/components/camel-aws/camel-aws2-sts/src/main/java/org/apache/camel/component/aws2/sts/STS2Configuration.java
index 2644922188d..e3c0505b057 100644
---
a/components/camel-aws/camel-aws2-sts/src/main/java/org/apache/camel/component/aws2/sts/STS2Configuration.java
+++
b/components/camel-aws/camel-aws2-sts/src/main/java/org/apache/camel/component/aws2/sts/STS2Configuration.java
@@ -181,8 +181,8 @@ public class STS2Configuration implements Cloneable {
}
/**
- * Set the need for overriding the endpoint. This option needs to be used
in combination with the uriEndpointOverride
- * option
+ * Set the need for overriding the endpoint. This option needs to be used
in combination with the
+ * uriEndpointOverride option
*/
public void setOverrideEndpoint(boolean overrideEndpoint) {
this.overrideEndpoint = overrideEndpoint;
diff --git
a/components/camel-aws/camel-aws2-timestream/src/main/java/org/apache/camel/component/aws2/timestream/Timestream2Configuration.java
b/components/camel-aws/camel-aws2-timestream/src/main/java/org/apache/camel/component/aws2/timestream/Timestream2Configuration.java
index 4836d016925..2a9b94b9462 100644
---
a/components/camel-aws/camel-aws2-timestream/src/main/java/org/apache/camel/component/aws2/timestream/Timestream2Configuration.java
+++
b/components/camel-aws/camel-aws2-timestream/src/main/java/org/apache/camel/component/aws2/timestream/Timestream2Configuration.java
@@ -123,8 +123,8 @@ public class Timestream2Configuration implements Cloneable {
}
/**
- * The region in which the Timestream client needs to work. When using
this parameter, the configuration will expect the
- * lowercase name of the region (for example, ap-east-1) You'll need to
use the name Region.EU_WEST_1.id()
+ * The region in which the Timestream client needs to work. When using
this parameter, the configuration will expect
+ * the lowercase name of the region (for example, ap-east-1) You'll need
to use the name Region.EU_WEST_1.id()
*/
public void setRegion(String region) {
this.region = region;
@@ -205,8 +205,8 @@ public class Timestream2Configuration implements Cloneable {
}
/**
- * Set the need for overriding the endpoint. This option needs to be used
in combination with the uriEndpointOverride
- * option
+ * Set the need for overriding the endpoint. This option needs to be used
in combination with the
+ * uriEndpointOverride option
*/
public void setOverrideEndpoint(boolean overrideEndpoint) {
this.overrideEndpoint = overrideEndpoint;
diff --git
a/components/camel-aws/camel-aws2-translate/src/main/java/org/apache/camel/component/aws2/translate/Translate2Configuration.java
b/components/camel-aws/camel-aws2-translate/src/main/java/org/apache/camel/component/aws2/translate/Translate2Configuration.java
index bf76d64f32e..df76df737a0 100644
---
a/components/camel-aws/camel-aws2-translate/src/main/java/org/apache/camel/component/aws2/translate/Translate2Configuration.java
+++
b/components/camel-aws/camel-aws2-translate/src/main/java/org/apache/camel/component/aws2/translate/Translate2Configuration.java
@@ -166,8 +166,8 @@ public class Translate2Configuration implements Cloneable {
}
/**
- * The region in which the Translate client needs to work. When using this
parameter, the configuration will expect the
- * lowercase name of the region (for example, ap-east-1) You'll need to
use the name Region.EU_WEST_1.id()
+ * The region in which the Translate client needs to work. When using this
parameter, the configuration will expect
+ * the lowercase name of the region (for example, ap-east-1) You'll need
to use the name Region.EU_WEST_1.id()
*/
public void setRegion(String region) {
this.region = region;
@@ -233,8 +233,8 @@ public class Translate2Configuration implements Cloneable {
}
/**
- * Set the need for overriding the endpoint. This option needs to be used
in combination with the uriEndpointOverride
- * option
+ * Set the need for overriding the endpoint. This option needs to be used
in combination with the
+ * uriEndpointOverride option
*/
public void setOverrideEndpoint(boolean overrideEndpoint) {
this.overrideEndpoint = overrideEndpoint;
diff --git
a/components/camel-azure/camel-azure-servicebus/src/main/java/org/apache/camel/component/azure/servicebus/ServiceBusProducer.java
b/components/camel-azure/camel-azure-servicebus/src/main/java/org/apache/camel/component/azure/servicebus/ServiceBusProducer.java
index af387c3d22e..f13ff00abbf 100644
---
a/components/camel-azure/camel-azure-servicebus/src/main/java/org/apache/camel/component/azure/servicebus/ServiceBusProducer.java
+++
b/components/camel-azure/camel-azure-servicebus/src/main/java/org/apache/camel/component/azure/servicebus/ServiceBusProducer.java
@@ -148,7 +148,7 @@ public class ServiceBusProducer extends
DefaultAsyncProducer {
return (exchange, callback) -> {
final Object inputBody = exchange.getMessage().getBody();
Map<String, Object> applicationProperties
- =
exchange.getMessage().getHeader(ServiceBusConstants.APPLICATION_PROPERTIES,
Map.class);
+ =
exchange.getMessage().getHeader(ServiceBusConstants.APPLICATION_PROPERTIES,
Map.class);
if (applicationProperties == null) {
applicationProperties = new HashMap<>();
}
@@ -182,7 +182,7 @@ public class ServiceBusProducer extends
DefaultAsyncProducer {
return (exchange, callback) -> {
final Object inputBody = exchange.getMessage().getBody();
Map<String, Object> applicationProperties
- =
exchange.getMessage().getHeader(ServiceBusConstants.APPLICATION_PROPERTIES,
Map.class);
+ =
exchange.getMessage().getHeader(ServiceBusConstants.APPLICATION_PROPERTIES,
Map.class);
if (applicationProperties == null) {
applicationProperties = new HashMap<>();
}
diff --git
a/components/camel-dataset/src/main/java/org/apache/camel/component/dataset/DataSetEndpoint.java
b/components/camel-dataset/src/main/java/org/apache/camel/component/dataset/DataSetEndpoint.java
index 8015856beab..e1d43813377 100644
---
a/components/camel-dataset/src/main/java/org/apache/camel/component/dataset/DataSetEndpoint.java
+++
b/components/camel-dataset/src/main/java/org/apache/camel/component/dataset/DataSetEndpoint.java
@@ -46,7 +46,8 @@ import org.slf4j.LoggerFactory;
* data set is received. Camel will use the throughput logger when sending
dataset's.
*/
@UriEndpoint(firstVersion = "1.3.0", scheme = "dataset", title = "Dataset",
syntax = "dataset:name",
- remote = false, category = { Category.CORE, Category.TESTING },
lenientProperties = true, headersClass = DataSetConstants.class)
+ remote = false, category = { Category.CORE, Category.TESTING },
lenientProperties = true,
+ headersClass = DataSetConstants.class)
public class DataSetEndpoint extends MockEndpoint implements Service {
private final transient Logger log;
private final AtomicInteger receivedCounter = new AtomicInteger();
diff --git
a/components/camel-file/src/main/java/org/apache/camel/component/file/FileEndpoint.java
b/components/camel-file/src/main/java/org/apache/camel/component/file/FileEndpoint.java
index 2b48db194f1..4de58f0d6cc 100644
---
a/components/camel-file/src/main/java/org/apache/camel/component/file/FileEndpoint.java
+++
b/components/camel-file/src/main/java/org/apache/camel/component/file/FileEndpoint.java
@@ -60,7 +60,6 @@ public class FileEndpoint extends GenericFileEndpoint<File> {
private final FileOperations operations = new FileOperations(this);
-
@UriPath(name = "directoryName")
@Metadata(required = true)
private File file;
diff --git
a/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsConfiguration.java
b/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsConfiguration.java
index b6c866ac134..23897aff95c 100644
---
a/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsConfiguration.java
+++
b/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsConfiguration.java
@@ -945,9 +945,9 @@ public class JmsConfiguration implements Cloneable {
/**
* Specifies whether the consumer accepts messages while it is stopping.
You may consider enabling this option if
* you start and stop JMS routes at runtime, while there are still
messages enqueued in the queue. If this option is
- * false, and you stop the JMS route, then messages may be rejected. In
this case, the JMS broker would have to attempt
- * redeliveries, which yet again may be rejected, and eventually the
message may be moved at a dead letter queue on
- * the JMS broker. To avoid this, it's recommended to enable this option.
+ * false, and you stop the JMS route, then messages may be rejected. In
this case, the JMS broker would have to
+ * attempt redeliveries, which yet again may be rejected, and eventually
the message may be moved at a dead letter
+ * queue on the JMS broker. To avoid this, it's recommended to enable this
option.
*/
public void setAcceptMessagesWhileStopping(boolean
acceptMessagesWhileStopping) {
this.acceptMessagesWhileStopping = acceptMessagesWhileStopping;
@@ -957,8 +957,8 @@ public class JmsConfiguration implements Cloneable {
* Whether the {@link DefaultMessageListenerContainer} used in the reply
managers for request-reply messaging allow
* the {@link DefaultMessageListenerContainer#runningAllowed()} flag to
quick stop in case
* {@link JmsConfiguration#isAcceptMessagesWhileStopping()} is enabled,
and {@link org.apache.camel.CamelContext} is
- * currently being stopped. This quick stop ability is enabled by default
in the regular JMS consumers, but to enable
- * for reply managers, you must enable this flag.
+ * currently being stopped. This quick stop ability is enabled by default
in the regular JMS consumers, but to
+ * enable for reply managers, you must enable this flag.
*/
public boolean isAllowReplyManagerQuickStop() {
return allowReplyManagerQuickStop;
@@ -1155,8 +1155,8 @@ public class JmsConfiguration implements Cloneable {
}
/**
- * Specifies the interval between recovery attempts, i.e., when a
connection is being refreshed, in milliseconds. The
- * default is 5000 ms, that is, 5 seconds.
+ * Specifies the interval between recovery attempts, i.e., when a
connection is being refreshed, in milliseconds.
+ * The default is 5000 ms, that is, 5 seconds.
*/
public void setRecoveryInterval(long recoveryInterval) {
this.recoveryInterval = recoveryInterval;
@@ -1218,9 +1218,10 @@ public class JmsConfiguration implements Cloneable {
}
/**
- * Specifies the limit for idle executions of a receiving task, not having
received any message within its execution.
- * If this limit is reached, the task will shut down and leave receiving
to other executing tasks (in the case of
- * dynamic scheduling; see the maxConcurrentConsumers setting). There is
additional doc available from Spring.
+ * Specifies the limit for idle executions of a receiving task, not having
received any message within its
+ * execution. If this limit is reached, the task will shut down and leave
receiving to other executing tasks (in the
+ * case of dynamic scheduling; see the maxConcurrentConsumers setting).
There is additional doc available from
+ * Spring.
*/
public void setIdleTaskExecutionLimit(int idleTaskExecutionLimit) {
this.idleTaskExecutionLimit = idleTaskExecutionLimit;
@@ -1467,8 +1468,8 @@ public class JmsConfiguration implements Cloneable {
* on these values. Analogously, these parameters are not taken into
account within a locally managed transaction
* either, since Spring JMS operates on an existing JMS Session in this
case.
* <p>
- * Setting this flag to true will use a short local JMS transaction when
running outside a managed transaction,
- * and a synchronized local JMS transaction in case of a managed
transaction (other than an XA transaction) being
+ * Setting this flag to true will use a short local JMS transaction when
running outside a managed transaction, and
+ * a synchronized local JMS transaction in case of a managed transaction
(other than an XA transaction) being
* present. This has the effect of a local JMS transaction being managed
alongside the main transaction (which might
* be a native JDBC transaction), with the JMS transaction committing
right after the main transaction.
*/
@@ -1522,9 +1523,9 @@ public class JmsConfiguration implements Cloneable {
/**
* Specifies whether Camel ignores the JMSReplyTo header in messages. If
true, Camel does not send a reply back to
* the destination specified in the JMSReplyTo header. You can use this
option if you want Camel to consume from a
- * route, and you do not want Camel to automatically send back a reply
message because another component in your code
- * handles the reply message. You can also use this option if you want to
use Camel as a proxy between different
- * message brokers, and you want to route messages from one system to
another.
+ * route, and you do not want Camel to automatically send back a reply
message because another component in your
+ * code handles the reply message. You can also use this option if you
want to use Camel as a proxy between
+ * different message brokers, and you want to route messages from one
system to another.
*/
public void setDisableReplyTo(boolean disableReplyTo) {
this.disableReplyTo = disableReplyTo;
@@ -1848,8 +1849,8 @@ public class JmsConfiguration implements Cloneable {
}
/**
- * Sets the JMS Selector using the fixed name to be used, so you can
filter out your own replies from the others when
- * using a shared queue (that is, if you are not using a temporary reply
queue).
+ * Sets the JMS Selector using the fixed name to be used, so you can
filter out your own replies from the others
+ * when using a shared queue (that is, if you are not using a temporary
reply queue).
*/
public void setReplyToDestinationSelectorName(String
replyToDestinationSelectorName) {
this.replyToDestinationSelectorName = replyToDestinationSelectorName;
@@ -1920,8 +1921,8 @@ public class JmsConfiguration implements Cloneable {
/**
* Pluggable strategy for encoding and decoding JMS keys, so they can be
compliant with the JMS specification. Camel
* provides two implementations out of the box: default and passthrough.
The default strategy will safely marshal
- * dots and hyphens (. and -). The passthrough strategy leaves the key as
is. It Can be used for JMS brokers which do
- * not care whether JMS header keys contain illegal characters. You can
provide your own implementation of the
+ * dots and hyphens (. and -). The passthrough strategy leaves the key as
is. It Can be used for JMS brokers which
+ * do not care whether JMS header keys contain illegal characters. You can
provide your own implementation of the
* org.apache.camel.component.jms.JmsKeyFormatStrategy and refer to it
using the # notation.
*/
public void setJmsKeyFormatStrategy(JmsKeyFormatStrategy
jmsKeyFormatStrategy) {
@@ -1950,9 +1951,9 @@ public class JmsConfiguration implements Cloneable {
}
/**
- * Controls whether to include serialized headers. Applies only when
{@link #isTransferExchange()} is
- * {@code true}. This requires that the objects are serializable. Camel
will exclude any non-serializable objects
- * and log it at WARN level.
+ * Controls whether to include serialized headers. Applies only when
{@link #isTransferExchange()} is {@code true}.
+ * This requires that the objects are serializable. Camel will exclude any
non-serializable objects and log it at
+ * WARN level.
*/
public void setAllowSerializedHeaders(boolean allowSerializedHeaders) {
this.allowSerializedHeaders = allowSerializedHeaders;
@@ -1983,8 +1984,8 @@ public class JmsConfiguration implements Cloneable {
/**
* Whether to start up the JmsConsumer message listener asynchronously,
when starting a route. For example, if a
* JmsConsumer cannot get a connection to a remote JMS broker, then it may
block while retrying and/or failover.
- * This will cause Camel to block while starting routes. By setting this
option to true, you will let routes
- * start up, while the JmsConsumer connects to the JMS broker using a
dedicated thread in asynchronous mode. If this
+ * This will cause Camel to block while starting routes. By setting this
option to true, you will let routes start
+ * up, while the JmsConsumer connects to the JMS broker using a dedicated
thread in asynchronous mode. If this
* option is used, then beware that if the connection could not be
established, then an exception is logged at WARN
* level, and the consumer will not be able to receive messages; You can
then restart the route to retry.
*/
@@ -2010,8 +2011,8 @@ public class JmsConfiguration implements Cloneable {
/**
* Specifies whether to test the connection on startup. This ensures that
when Camel starts that all the JMS
* consumers have a valid connection to the JMS broker. If a connection
cannot be granted, then Camel throws an
- * exception on startup. This ensures that Camel is not started with
failed connections. The JMS producers are tested
- * as well.
+ * exception on startup. This ensures that Camel is not started with
failed connections. The JMS producers are
+ * tested as well.
*/
public void setTestConnectionOnStartup(boolean testConnectionOnStartup) {
this.testConnectionOnStartup = testConnectionOnStartup;
@@ -2051,8 +2052,8 @@ public class JmsConfiguration implements Cloneable {
/**
* Allows for explicitly specifying which kind of strategy to use for
replyTo queues when doing request/reply over
- * JMS. Possible values are Temporary, Shared, or Exclusive. By default,
Camel will use temporary queues. However, if
- * replyTo has been configured, then Shared is used by default. This
option allows you to use exclusive queues
+ * JMS. Possible values are Temporary, Shared, or Exclusive. By default,
Camel will use temporary queues. However,
+ * if replyTo has been configured, then Shared is used by default. This
option allows you to use exclusive queues
* instead of shared ones. See Camel JMS documentation for more details,
and especially the notes about the
* implications if running in a clustered environment, and the fact that
Shared reply queues has lower performance
* than its alternatives Temporary and Exclusive.
@@ -2185,8 +2186,8 @@ public class JmsConfiguration implements Cloneable {
/**
* Use this JMS property to correlate messages in InOut exchange pattern
(request-reply) instead of JMSCorrelationID
* property. This allows you to exchange messages with systems that do not
correlate messages using JMSCorrelationID
- * JMS property. If used, JMSCorrelationID will not be used or set by
Camel. The value of here named property will be
- * generated if not supplied in the header of the message under the same
name.
+ * JMS property. If used, JMSCorrelationID will not be used or set by
Camel. The value of here named property will
+ * be generated if not supplied in the header of the message under the
same name.
*/
public void setCorrelationProperty(final String correlationProperty) {
this.correlationProperty = correlationProperty;
@@ -2274,10 +2275,10 @@ public class JmsConfiguration implements Cloneable {
/**
* Sets whether StreamMessage type is enabled or not. Message payloads of
streaming kind such as files, InputStream,
- * and others, will either be sent as BytesMessage or StreamMessage. This
option controls which kind will be used. By
- * default, BytesMessage is used which enforces the entire message payload
to be read into memory. By enabling this
- * option, the message payload is read into memory in chunks, and each
chunk is then written to the StreamMessage
- * until no more data.
+ * and others, will either be sent as BytesMessage or StreamMessage. This
option controls which kind will be used.
+ * By default, BytesMessage is used which enforces the entire message
payload to be read into memory. By enabling
+ * this option, the message payload is read into memory in chunks, and
each chunk is then written to the
+ * StreamMessage until no more data.
*/
public void setStreamMessageTypeEnabled(boolean streamMessageTypeEnabled) {
this.streamMessageTypeEnabled = streamMessageTypeEnabled;
diff --git
a/components/camel-jsonpath/src/test/java/org/apache/camel/jsonpath/JsonPathSplitSingleListOptionTest.java
b/components/camel-jsonpath/src/test/java/org/apache/camel/jsonpath/JsonPathSplitSingleListOptionTest.java
index 822560d23ee..c337e837c30 100644
---
a/components/camel-jsonpath/src/test/java/org/apache/camel/jsonpath/JsonPathSplitSingleListOptionTest.java
+++
b/components/camel-jsonpath/src/test/java/org/apache/camel/jsonpath/JsonPathSplitSingleListOptionTest.java
@@ -37,7 +37,8 @@ public class JsonPathSplitSingleListOptionTest extends
CamelTestSupport {
@Override
public void configure() {
// use option to force returning a list even for a single
element selected
- var jsonpath =
expression().jsonpath().option(Option.ALWAYS_RETURN_LIST.name()).expression("$.store.book[0]").end();
+ var jsonpath
+ =
expression().jsonpath().option(Option.ALWAYS_RETURN_LIST.name()).expression("$.store.book[0]").end();
from("direct:start")
.split(jsonpath)
diff --git
a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConfiguration.java
b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConfiguration.java
index 0cceaaafecc..0e9b05e9f50 100755
---
a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConfiguration.java
+++
b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConfiguration.java
@@ -793,8 +793,8 @@ public class KafkaConfiguration implements Cloneable,
HeaderFilterStrategyAware
}
/**
- * The offset repository to use to locally store the offset of each
partition of the topic. Defining one
- * will disable the autocommit.
+ * The offset repository to use to locally store the offset of each
partition of the topic. Defining one will
+ * disable the autocommit.
*/
public void setOffsetRepository(StateRepository<String, String>
offsetRepository) {
this.offsetRepository = offsetRepository;
@@ -877,8 +877,8 @@ public class KafkaConfiguration implements Cloneable,
HeaderFilterStrategyAware
*
* Using either the SyncCommitManager or the AsyncCommitManager, the
consumer will seek back to the offset of the
* message that caused a failure, and then re-attempt to process this
message. However, this can lead to endless
- * processing of the same message if it's bound to fail every time, e.g.,
a poison message. Therefore, it's recommended to
- * deal with that, for example, by using Camel's error handler.
+ * processing of the same message if it's bound to fail every time, e.g.,
a poison message. Therefore, it's
+ * recommended to deal with that, for example, by using Camel's error
handler.
*/
public void setBreakOnFirstError(boolean breakOnFirstError) {
this.breakOnFirstError = breakOnFirstError;
@@ -1071,8 +1071,8 @@ public class KafkaConfiguration implements Cloneable,
HeaderFilterStrategyAware
* A list of rules for mapping from principal names to short names
(typically operating system usernames). The rules
* are evaluated in order, and the first rule that matches a principal
name is used to map it to a short name. Any
* later rules in the list are ignored. By default, principal names of the
form {username}/{hostname}@{REALM} are
- * mapped to {username}. For more details on the format, please see the
Security Authorization and ACLs documentation
- * (at the Apache Kafka project website).
+ * mapped to {username}. For more details on the format, please see the
Security Authorization and ACLs
+ * documentation (at the Apache Kafka project website).
* <p/>
* Multiple values can be separated by comma
*/
@@ -1284,8 +1284,8 @@ public class KafkaConfiguration implements Cloneable,
HeaderFilterStrategyAware
}
/**
- * The store password for the key store file. This is optional for the
client and only needed if
- * sslKeystoreLocation is configured. Key store password is not supported
for PEM format.
+ * The store password for the key store file. This is optional for the
client and only needed if sslKeystoreLocation
+ * is configured. Key store password is not supported for PEM format.
*/
public void setSslKeystorePassword(String sslKeystorePassword) {
this.sslKeystorePassword = sslKeystorePassword;
@@ -1364,10 +1364,10 @@ public class KafkaConfiguration implements Cloneable,
HeaderFilterStrategyAware
*
* acks=0 If set to zero, then the producer will not wait for any
acknowledgment from the server at all. The record
* will be immediately added to the socket buffer and considered sent. No
guarantee can be made that the server has
- * received the record in this case, and the retry configuration will not
take effect (as the client won't
- * generally know of any failures). The offset given back for each record
will always be set to -1. acks=1 This will
- * mean the leader will write the record to its local log but will respond
without awaiting full acknowledgment
- * from all followers. In this case should the leader fail immediately
after acknowledging the record, but before the
+ * received the record in this case, and the retry configuration will not
take effect (as the client won't generally
+ * know of any failures). The offset given back for each record will
always be set to -1. acks=1 This will mean the
+ * leader will write the record to its local log but will respond without
awaiting full acknowledgment from all
+ * followers. In this case should the leader fail immediately after
acknowledging the record, but before the
* followers have replicated it, then the record will be lost. acks=all
This means the leader will wait for the full
* set of in-sync replicas to acknowledge the record. This guarantees that
the record will not be lost as long as at
* least one in-sync replica remains alive. This is the strongest
available guarantee. This is equivalent to the
@@ -1383,11 +1383,11 @@ public class KafkaConfiguration implements Cloneable,
HeaderFilterStrategyAware
}
/**
- * Setting a value greater than zero will cause the client to resend any
record that has failed to be sent due to a potentially
- * transient error. Note that this retry is no different from if the
client re-sending the record upon receiving the
- * error. Produce requests will be failed before the number of retries has
been exhausted if the timeout configured
- * by delivery.timeout.ms expires first before successful acknowledgement.
Users should generally prefer to leave
- * this config unset and instead use delivery.timeout.ms to control retry
behavior.
+ * Setting a value greater than zero will cause the client to resend any
record that has failed to be sent due to a
+ * potentially transient error. Note that this retry is no different from
if the client re-sending the record upon
+ * receiving the error. Produce requests will be failed before the number
of retries has been exhausted if the
+ * timeout configured by delivery.timeout.ms expires first before
successful acknowledgement. Users should generally
+ * prefer to leave this config unset and instead use delivery.timeout.ms
to control retry behavior.
*
* Enabling idempotence requires this config value to be greater than 0.
If conflicting configurations are set and
* idempotence is not explicitly enabled, idempotence is disabled.
@@ -1451,13 +1451,13 @@ public class KafkaConfiguration implements Cloneable,
HeaderFilterStrategyAware
* request. Normally, this occurs only under load when records arrive
faster than they can be sent out. However, in
* some circumstances, the client may want to reduce the number of
requests even under a moderate load. This setting
* accomplishes this by adding a small amount of artificial delay. That
is, rather than immediately sending out a
- * record, the producer will wait for up to the given delay to allow
other records to be sent so that they can be
+ * record, the producer will wait for up to the given delay to allow other
records to be sent so that they can be
* batched together. This can be thought of as analogous to Nagle's
algorithm in TCP. This setting gives the upper
* bound on the delay for batching: once we get batch.size worth of
records for a partition, it will be sent
* immediately regardless of this setting, however, if we have fewer than
this many bytes accumulated for this
- * partition, we will 'linger' for the specified time waiting for more
records to show up. This setting defaults to 0
- * (i.e., no delay). Setting linger.ms=5, for example, would have the
effect of reducing the number of requests sent
- * but would add up to 5ms of latency to records sent in the absence of
load.
+ * partition, we will 'linger' for the specified time waiting for more
records to show up. This setting defaults to
+ * 0 (i.e., no delay). Setting linger.ms=5, for example, would have the
effect of reducing the number of requests
+ * sent but would add up to 5ms of latency to records sent in the absence
of load.
*/
public void setLingerMs(Integer lingerMs) {
this.lingerMs = lingerMs;
@@ -1644,8 +1644,8 @@ public class KafkaConfiguration implements Cloneable,
HeaderFilterStrategyAware
/**
* The maximum delay between invocations of poll() when using consumer
group management. This places an upper bound
* on the amount of time that the consumer can be idle before fetching
more records. If poll() is not called before
- * expiration of this timeout, then the consumer is considered failed, and
the group will re-balance to
- * reassign the partitions to another member.
+ * expiration of this timeout, then the consumer is considered failed, and
the group will re-balance to reassign the
+ * partitions to another member.
*/
public void setMaxPollIntervalMs(Integer maxPollIntervalMs) {
this.maxPollIntervalMs = maxPollIntervalMs;
@@ -1892,10 +1892,11 @@ public class KafkaConfiguration implements Cloneable,
HeaderFilterStrategyAware
* Will by default use the value from the component configuration unless
an explicit value has been configured on
* the endpoint level.
*
- * DISCARD will discard the message and continue to poll the next message.
ERROR_HANDLER will use Camel's error handler
- * to process the exception, and afterwards continue to poll the next
message. RECONNECT will re-connect the consumer
- * and try polling the message again. RETRY will let the consumer retry
poll the same message again. STOP will stop
- * the consumer (it has to be manually started/restarted if the consumer
should be able to consume messages again)
+ * DISCARD will discard the message and continue to poll the next message.
ERROR_HANDLER will use Camel's error
+ * handler to process the exception, and afterwards continue to poll the
next message. RECONNECT will re-connect the
+ * consumer and try polling the message again. RETRY will let the consumer
retry poll the same message again. STOP
+ * will stop the consumer (it has to be manually started/restarted if the
consumer should be able to consume
+ * messages again)
*/
public void setPollOnError(PollOnError pollOnError) {
this.pollOnError = pollOnError;
diff --git
a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/support/batching/KafkaRecordBatchingProcessor.java
b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/support/batching/KafkaRecordBatchingProcessor.java
index d9f00d86db4..b6bf0a6e2e8 100644
---
a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/support/batching/KafkaRecordBatchingProcessor.java
+++
b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/support/batching/KafkaRecordBatchingProcessor.java
@@ -47,7 +47,6 @@ final class KafkaRecordBatchingProcessor extends
KafkaRecordProcessor {
private final StopWatch watch = new StopWatch();
private List<Exchange> exchangeList;
-
private final class CommitSynchronization implements Synchronization {
private final ExceptionHandler exceptionHandler;
private ProcessingResult result;
@@ -111,7 +110,8 @@ final class KafkaRecordBatchingProcessor extends
KafkaRecordProcessor {
}
public ProcessingResult processExchange(KafkaConsumer camelKafkaConsumer,
ConsumerRecords<Object, Object> consumerRecords) {
- LOG.debug("There's {} records to process ... max poll is set to {}",
consumerRecords.count(), configuration.getMaxPollRecords());
+ LOG.debug("There's {} records to process ... max poll is set to {}",
consumerRecords.count(),
+ configuration.getMaxPollRecords());
// Aggregate all consumer records in a single exchange
if (exchangeList == null) {
exchangeList = new ArrayList<>(configuration.getMaxPollRecords());
@@ -119,7 +119,8 @@ final class KafkaRecordBatchingProcessor extends
KafkaRecordProcessor {
}
if (hasExpiredRecords(consumerRecords)) {
- LOG.debug("The polling timeout has expired with {} records in
cache. Dispatching the incomplete batch for processing",
+ LOG.debug(
+ "The polling timeout has expired with {} records in cache.
Dispatching the incomplete batch for processing",
exchangeList.size());
// poll timeout has elapsed, so check for expired records
diff --git
a/components/camel-micrometer/src/main/java/org/apache/camel/component/micrometer/MicrometerEndpoint.java
b/components/camel-micrometer/src/main/java/org/apache/camel/component/micrometer/MicrometerEndpoint.java
index be610ada5c1..7aeb4f3825d 100644
---
a/components/camel-micrometer/src/main/java/org/apache/camel/component/micrometer/MicrometerEndpoint.java
+++
b/components/camel-micrometer/src/main/java/org/apache/camel/component/micrometer/MicrometerEndpoint.java
@@ -34,7 +34,8 @@ import org.apache.camel.support.DefaultEndpoint;
* Collect various metrics directly from Camel routes using the Micrometer
library.
*/
@UriEndpoint(firstVersion = "2.22.0", scheme = "micrometer", title =
"Micrometer",
- remote = false, syntax = "micrometer:metricsType:metricsName",
producerOnly = true, category = { Category.MONITORING },
+ remote = false, syntax = "micrometer:metricsType:metricsName",
producerOnly = true,
+ category = { Category.MONITORING },
headersClass = MicrometerConstants.class)
public class MicrometerEndpoint extends DefaultEndpoint {
diff --git
a/components/camel-mustache/src/main/java/org/apache/camel/component/mustache/MustacheEndpoint.java
b/components/camel-mustache/src/main/java/org/apache/camel/component/mustache/MustacheEndpoint.java
index 422e7c45bab..8d226570326 100644
---
a/components/camel-mustache/src/main/java/org/apache/camel/component/mustache/MustacheEndpoint.java
+++
b/components/camel-mustache/src/main/java/org/apache/camel/component/mustache/MustacheEndpoint.java
@@ -43,7 +43,8 @@ import static
org.apache.camel.component.mustache.MustacheConstants.MUSTACHE_TEM
* Transform messages using a Mustache template.
*/
@UriEndpoint(firstVersion = "2.12.0", scheme = "mustache", title = "Mustache",
syntax = "mustache:resourceUri",
- remote = false, producerOnly = true, category = {
Category.TRANSFORMATION }, headersClass = MustacheConstants.class)
+ remote = false, producerOnly = true, category = {
Category.TRANSFORMATION },
+ headersClass = MustacheConstants.class)
public class MustacheEndpoint extends ResourceEndpoint {
private MustacheFactory mustacheFactory;
diff --git
a/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/internal/processor/RawProcessor.java
b/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/internal/processor/RawProcessor.java
index 87097b9eef1..12606445051 100644
---
a/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/internal/processor/RawProcessor.java
+++
b/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/internal/processor/RawProcessor.java
@@ -80,8 +80,7 @@ public class RawProcessor extends AbstractSalesforceProcessor
{
if (exchange.getIn().getHeader(p) == null) {
throw new SalesforceException(
- String.format("Missing header with key: %s", p)
- );
+ String.format("Missing header with key: %s",
p));
}
path.append(urlEncode(exchange.getIn().getHeader(p).toString()));
}
diff --git
a/components/camel-scheduler/src/main/java/org/apache/camel/component/scheduler/SchedulerEndpoint.java
b/components/camel-scheduler/src/main/java/org/apache/camel/component/scheduler/SchedulerEndpoint.java
index ef2234e2f47..7a958ae6483 100644
---
a/components/camel-scheduler/src/main/java/org/apache/camel/component/scheduler/SchedulerEndpoint.java
+++
b/components/camel-scheduler/src/main/java/org/apache/camel/component/scheduler/SchedulerEndpoint.java
@@ -35,7 +35,8 @@ import org.apache.camel.support.ScheduledPollEndpoint;
* component uses JDK ScheduledExecutorService. Where as the timer uses a JDK
Timer.
*/
@UriEndpoint(firstVersion = "2.15.0", scheme = "scheduler", title =
"Scheduler", syntax = "scheduler:name",
- remote = false, consumerOnly = true, category = { Category.CORE,
Category.SCHEDULING }, headersClass = SchedulerConstants.class)
+ remote = false, consumerOnly = true, category = { Category.CORE,
Category.SCHEDULING },
+ headersClass = SchedulerConstants.class)
public class SchedulerEndpoint extends ScheduledPollEndpoint {
@UriPath
diff --git
a/components/camel-sjms/src/main/java/org/apache/camel/component/sjms/SjmsProducer.java
b/components/camel-sjms/src/main/java/org/apache/camel/component/sjms/SjmsProducer.java
index 2a1b4874b01..9f71a770abd 100644
---
a/components/camel-sjms/src/main/java/org/apache/camel/component/sjms/SjmsProducer.java
+++
b/components/camel-sjms/src/main/java/org/apache/camel/component/sjms/SjmsProducer.java
@@ -199,7 +199,7 @@ public class SjmsProducer extends DefaultAsyncProducer {
private ExecutorService createReplyManagerExecutor(ReplyManager
temporaryQueueReplyManager, String name) {
int max = doGetMax();
return
getEndpoint().getCamelContext().getExecutorServiceManager().newThreadPool(temporaryQueueReplyManager,
name, 0,
- max);
+ max);
}
private int doGetMax() {
diff --git
a/components/camel-sjms/src/main/java/org/apache/camel/component/sjms/consumer/EndpointMessageListener.java
b/components/camel-sjms/src/main/java/org/apache/camel/component/sjms/consumer/EndpointMessageListener.java
index 482fae34fa7..3aa5eb35349 100644
---
a/components/camel-sjms/src/main/java/org/apache/camel/component/sjms/consumer/EndpointMessageListener.java
+++
b/components/camel-sjms/src/main/java/org/apache/camel/component/sjms/consumer/EndpointMessageListener.java
@@ -289,8 +289,9 @@ public class EndpointMessageListener implements
SessionMessageListener {
MessageProducer create(Session session, Endpoint endpoint, T
replyDestination) throws Exception;
}
- private <T> SessionCallback createSessionCallback(T replyDestination,
Message message, Exchange exchange, org.apache.camel.Message out, Exception
cause,
-
MessageProducerCreator<T> messageProducerCreator) {
+ private <T> SessionCallback createSessionCallback(
+ T replyDestination, Message message, Exchange exchange,
org.apache.camel.Message out, Exception cause,
+ MessageProducerCreator<T> messageProducerCreator) {
return new SessionCallback() {
@Override
public Object doInJms(Session session) throws Exception {
diff --git
a/components/camel-sql/src/main/java/org/apache/camel/component/sql/DefaultSqlEndpoint.java
b/components/camel-sql/src/main/java/org/apache/camel/component/sql/DefaultSqlEndpoint.java
index 2b4df0738de..82b1c0b0d1f 100644
---
a/components/camel-sql/src/main/java/org/apache/camel/component/sql/DefaultSqlEndpoint.java
+++
b/components/camel-sql/src/main/java/org/apache/camel/component/sql/DefaultSqlEndpoint.java
@@ -195,8 +195,8 @@ public abstract class DefaultSqlEndpoint extends
DefaultPollingEndpoint {
}
/**
- * Allows plugging in a custom
org.apache.camel.component.sql.SqlPrepareStatementStrategy to control
- * preparation of the query and prepared statement.
+ * Allows plugging in a custom
org.apache.camel.component.sql.SqlPrepareStatementStrategy to control
preparation of
+ * the query and prepared statement.
*/
public void setPrepareStatementStrategy(SqlPrepareStatementStrategy
prepareStatementStrategy) {
this.prepareStatementStrategy = prepareStatementStrategy;
@@ -219,8 +219,8 @@ public abstract class DefaultSqlEndpoint extends
DefaultPollingEndpoint {
}
/**
- * After processing each row, then this query can be executed, if the
Exchange failed, for example, to mark the row as
- * failed. The query can have parameter.
+ * After processing each row, then this query can be executed, if the
Exchange failed, for example, to mark the row
+ * as failed. The query can have parameter.
*/
public void setOnConsumeFailed(String onConsumeFailed) {
this.onConsumeFailed = onConsumeFailed;
@@ -256,8 +256,8 @@ public abstract class DefaultSqlEndpoint extends
DefaultPollingEndpoint {
/**
* If enabled, then the populateStatement method from
org.apache.camel.component.sql.SqlPrepareStatementStrategy is
* always invoked, also if there are no expected parameters to be
prepared. When this is false, then the
- * populateStatement is only invoked if there are one or more expected
parameters to be set; for example, this avoids
- * reading the message body/headers for SQL queries with no parameters.
+ * populateStatement is only invoked if there are one or more expected
parameters to be set; for example, this
+ * avoids reading the message body/headers for SQL queries with no
parameters.
*/
public void setAlwaysPopulateStatement(boolean alwaysPopulateStatement) {
this.alwaysPopulateStatement = alwaysPopulateStatement;
@@ -283,9 +283,9 @@ public abstract class DefaultSqlEndpoint extends
DefaultPollingEndpoint {
/**
* Make the output of consumer or producer to SelectList as List of Map,
or SelectOne as a single Java object in the
- * following way: a) If the query has only a single column, then that JDBC
Column object is returned. (such as SELECT
- * COUNT( * ) FROM PROJECT will return a Long object. b) If the query has
more than one column, then it will return
- * a Map of that result. c) If the outputClass is set, then it will
convert the query result into a Java bean
+ * following way: a) If the query has only a single column, then that JDBC
Column object is returned. (such as
+ * SELECT COUNT( * ) FROM PROJECT will return a Long object. b) If the
query has more than one column, then it will
+ * return a Map of that result. c) If the outputClass is set, then it will
convert the query result into a Java bean
* object by calling all the setters that match the column names. It will
assume your class has a default
* constructor to create instance with. d) If the query resulted in more
than one rows, it throws a non-unique
* result exception.
@@ -311,8 +311,8 @@ public abstract class DefaultSqlEndpoint extends
DefaultPollingEndpoint {
/**
* If set greater than zero, then Camel will use this count value of
parameters to replace instead of querying via
- * JDBC metadata API. This is useful if the JDBC vendor could not return
the correct parameters count, then the user may
- * override instead.
+ * JDBC metadata API. This is useful if the JDBC vendor could not return
the correct parameters count, then the user
+ * may override instead.
*/
public void setParametersCount(int parametersCount) {
this.parametersCount = parametersCount;
diff --git
a/components/camel-stub/src/main/java/org/apache/camel/component/stub/StubConsole.java
b/components/camel-stub/src/main/java/org/apache/camel/component/stub/StubConsole.java
index 841dbd2c67f..8a645f414b1 100644
---
a/components/camel-stub/src/main/java/org/apache/camel/component/stub/StubConsole.java
+++
b/components/camel-stub/src/main/java/org/apache/camel/component/stub/StubConsole.java
@@ -165,7 +165,7 @@ public class StubConsole extends AbstractDevConsole {
for (Exchange exchange : copy) {
try {
JsonObject msg
- =
MessageHelper.dumpAsJSonObject(exchange.getMessage(), false, true, true,true,
false, true,
+ =
MessageHelper.dumpAsJSonObject(exchange.getMessage(), false, true, true, true,
false, true,
128 * 1024);
arr.add(msg);
} catch (Exception e) {
diff --git
a/core/camel-api/src/main/java/org/apache/camel/spi/BacklogDebugger.java
b/core/camel-api/src/main/java/org/apache/camel/spi/BacklogDebugger.java
index 5ce38acaeb5..8515fc5e5db 100644
--- a/core/camel-api/src/main/java/org/apache/camel/spi/BacklogDebugger.java
+++ b/core/camel-api/src/main/java/org/apache/camel/spi/BacklogDebugger.java
@@ -230,7 +230,8 @@ public interface BacklogDebugger extends StatefulService {
void removeExchangePropertyOnBreakpoint(String nodeId, String
exchangePropertyName);
/**
- * Updates/adds the variable (uses same type as old variableName value) on
the suspended breakpoint at the given node id
+ * Updates/adds the variable (uses same type as old variableName value) on
the suspended breakpoint at the given
+ * node id
*/
void setExchangeVariableOnBreakpoint(String nodeId, String variableName,
Object value)
throws NoTypeConversionAvailableException;
