This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/main by this push: new f5ef1d9762f Regen for commit d2c6776451f9e1b0a4f3dedf6658a08a52bf28f2 f5ef1d9762f is described below commit f5ef1d9762f7739f4353675eeb37ab8411ce39be Author: davsclaus <davscl...@users.noreply.github.com> AuthorDate: Mon Apr 10 14:30:56 2023 +0000 Regen for commit d2c6776451f9e1b0a4f3dedf6658a08a52bf28f2 Signed-off-by: GitHub <nore...@github.com> --- .../aggregate/jdbc/ClusteredJdbcAggregationRepository.java | 3 ++- .../processor/aggregate/jdbc/JdbcAggregationRepository.java | 6 ++++-- .../org/apache/camel/component/zeebe/model/JobRequest.java | 12 ++++++------ .../apache/camel/component/zeebe/model/MessageRequest.java | 10 +++++----- .../apache/camel/component/zeebe/model/MessageResponse.java | 4 ++-- .../apache/camel/component/zeebe/model/ProcessResponse.java | 8 ++++---- 6 files changed, 23 insertions(+), 20 deletions(-) diff --git a/components/camel-sql/src/main/java/org/apache/camel/processor/aggregate/jdbc/ClusteredJdbcAggregationRepository.java b/components/camel-sql/src/main/java/org/apache/camel/processor/aggregate/jdbc/ClusteredJdbcAggregationRepository.java index b9bb40b3485..9a82899c60d 100644 --- a/components/camel-sql/src/main/java/org/apache/camel/processor/aggregate/jdbc/ClusteredJdbcAggregationRepository.java +++ b/components/camel-sql/src/main/java/org/apache/camel/processor/aggregate/jdbc/ClusteredJdbcAggregationRepository.java @@ -81,7 +81,8 @@ public class ClusteredJdbcAggregationRepository extends JdbcAggregationRepositor insert(camelContext, confirmKey, exchange, getRepositoryNameCompleted(), version, true); } catch (Exception e) { - throw new RuntimeException("Error removing key " + correlationId + " from repository " + getRepositoryName(), e); + throw new RuntimeException( + "Error removing key " + correlationId + " from repository " + getRepositoryName(), e); } } }); diff --git a/components/camel-sql/src/main/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregationRepository.java b/components/camel-sql/src/main/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregationRepository.java index db41a7fed26..2bbbef4143b 100644 --- a/components/camel-sql/src/main/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregationRepository.java +++ b/components/camel-sql/src/main/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregationRepository.java @@ -159,7 +159,8 @@ public class JdbcAggregationRepository extends ServiceSupport LOG.debug("Adding exchange with key {}", correlationId); boolean present = jdbcTemplate.queryForObject( - "SELECT COUNT(1) FROM " + getRepositoryName() + " WHERE " + ID + " = ?", Integer.class, correlationId) != 0; + "SELECT COUNT(1) FROM " + getRepositoryName() + " WHERE " + ID + " = ?", Integer.class, + correlationId) != 0; // Recover existing exchange with that ID if (isReturnOldExchange() && present) { @@ -182,7 +183,8 @@ public class JdbcAggregationRepository extends ServiceSupport } } catch (Exception e) { - throw new RuntimeException("Error adding to repository " + repositoryName + " with key " + correlationId, e); + throw new RuntimeException( + "Error adding to repository " + repositoryName + " with key " + correlationId, e); } return result; diff --git a/components/camel-zeebe/src/main/java/org/apache/camel/component/zeebe/model/JobRequest.java b/components/camel-zeebe/src/main/java/org/apache/camel/component/zeebe/model/JobRequest.java index ef626d745ee..495db67008d 100644 --- a/components/camel-zeebe/src/main/java/org/apache/camel/component/zeebe/model/JobRequest.java +++ b/components/camel-zeebe/src/main/java/org/apache/camel/component/zeebe/model/JobRequest.java @@ -114,11 +114,11 @@ public class JobRequest implements ZeebeMessage { @Override public String toString() { return "JobRequest{" + "jobKey=" + jobKey + - ", variables=" + variables + - ", retries=" + retries + - ", failMessage='" + failMessage + '\'' + - ", errorMessage='" + errorMessage + '\'' + - ", errorCode='" + errorCode + '\'' + - '}'; + ", variables=" + variables + + ", retries=" + retries + + ", failMessage='" + failMessage + '\'' + + ", errorMessage='" + errorMessage + '\'' + + ", errorCode='" + errorCode + '\'' + + '}'; } } diff --git a/components/camel-zeebe/src/main/java/org/apache/camel/component/zeebe/model/MessageRequest.java b/components/camel-zeebe/src/main/java/org/apache/camel/component/zeebe/model/MessageRequest.java index 7a357c2220c..dbe15835b2e 100644 --- a/components/camel-zeebe/src/main/java/org/apache/camel/component/zeebe/model/MessageRequest.java +++ b/components/camel-zeebe/src/main/java/org/apache/camel/component/zeebe/model/MessageRequest.java @@ -85,11 +85,11 @@ public class MessageRequest implements ZeebeMessage { @Override public String toString() { return "MessageRequest{" + "name='" + name + '\'' + - ", correlationKey='" + correlationKey + '\'' + - ", timeToLive=" + timeToLive + - ", messageId='" + messageId + '\'' + - ", variables=" + variables + - '}'; + ", correlationKey='" + correlationKey + '\'' + + ", timeToLive=" + timeToLive + + ", messageId='" + messageId + '\'' + + ", variables=" + variables + + '}'; } @Override diff --git a/components/camel-zeebe/src/main/java/org/apache/camel/component/zeebe/model/MessageResponse.java b/components/camel-zeebe/src/main/java/org/apache/camel/component/zeebe/model/MessageResponse.java index 3c49c82dcf8..5aada22a16b 100644 --- a/components/camel-zeebe/src/main/java/org/apache/camel/component/zeebe/model/MessageResponse.java +++ b/components/camel-zeebe/src/main/java/org/apache/camel/component/zeebe/model/MessageResponse.java @@ -49,8 +49,8 @@ public class MessageResponse extends AbstractZeebeResponse { @Override public String toString() { return "MessageResponse{" + "correlationKey='" + correlationKey + '\'' + - ", messageKey=" + messageKey + - '}'; + ", messageKey=" + messageKey + + '}'; } @Override diff --git a/components/camel-zeebe/src/main/java/org/apache/camel/component/zeebe/model/ProcessResponse.java b/components/camel-zeebe/src/main/java/org/apache/camel/component/zeebe/model/ProcessResponse.java index bb5abb37d76..fe621575cd1 100644 --- a/components/camel-zeebe/src/main/java/org/apache/camel/component/zeebe/model/ProcessResponse.java +++ b/components/camel-zeebe/src/main/java/org/apache/camel/component/zeebe/model/ProcessResponse.java @@ -71,10 +71,10 @@ public class ProcessResponse extends AbstractZeebeResponse { @Override public String toString() { return "ProcessResponse{" + "processId='" + processId + '\'' + - ", processInstanceKey=" + processInstanceKey + - ", processVersion=" + processVersion + - ", processKey=" + processKey + - '}'; + ", processInstanceKey=" + processInstanceKey + + ", processVersion=" + processVersion + + ", processKey=" + processKey + + '}'; } @Override