This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/main by this push:
new fb0283b3a4d Regen
fb0283b3a4d is described below
commit fb0283b3a4df8091b888928872e0fca7f568c4fa
Author: Claus Ibsen <[email protected]>
AuthorDate: Wed Aug 9 09:51:34 2023 +0200
Regen
---
.../java/org/apache/camel/component/file/azure/FilesConsumer.java | 3 ++-
.../camel/component/github/consumer/PullRequestConsumerTest.java | 3 ++-
.../org/apache/camel/component/jms/TwoConsumerOnSameQueueTest.java | 2 +-
.../apache/camel/component/jms/tx/ConditionalExceptionProcessor.java | 2 +-
.../consumer/integration/KubernetesConfigMapsConsumerIT.java | 2 +-
.../consumer/integration/KubernetesNamespacesConsumerIT.java | 2 +-
.../kubernetes/consumer/integration/KubernetesNodesConsumerIT.java | 2 +-
.../kubernetes/consumer/integration/KubernetesPodsConsumerIT.java | 2 +-
.../integration/KubernetesReplicationControllersConsumerIT.java | 2 +-
.../kubernetes/consumer/integration/KubernetesServicesConsumerIT.java | 2 +-
.../apache/camel/component/leveldb/LevelDBBigPayloadManualTest.java | 2 +-
.../src/main/java/org/apache/camel/component/mock/MockEndpoint.java | 4 +---
.../camel/component/platform/http/main/MainHttpFakeHealthCheck.java | 2 +-
.../apache/camel/component/platform/http/main/MainHttpServerTest.java | 2 +-
.../src/main/java/org/apache/camel/test/CamelRouteCoverageDumper.java | 1 -
.../java/org/apache/camel/test/junit5/patterns/AsyncSendMockTest.java | 1 -
.../apache/camel/component/zookeepermaster/CuratorFactoryBean.java | 2 +-
.../org/apache/camel/test/infra/common/services/TestServiceUtil.java | 1 -
.../apache/camel/test/infra/rocketmq/services/RocketMQContainer.java | 3 ++-
19 files changed, 19 insertions(+), 21 deletions(-)
diff --git
a/components/camel-azure/camel-azure-files/src/main/java/org/apache/camel/component/file/azure/FilesConsumer.java
b/components/camel-azure/camel-azure-files/src/main/java/org/apache/camel/component/file/azure/FilesConsumer.java
index 33efc3fcf9a..53214c9afbd 100644
---
a/components/camel-azure/camel-azure-files/src/main/java/org/apache/camel/component/file/azure/FilesConsumer.java
+++
b/components/camel-azure/camel-azure-files/src/main/java/org/apache/camel/component/file/azure/FilesConsumer.java
@@ -72,7 +72,8 @@ public class FilesConsumer extends
RemoteFileConsumer<ShareFileItem> {
operations.buildDirectory(endpointPath, true);
} catch (GenericFileOperationFailedException e) {
// log a WARN as we want to start the consumer.
- LOG.warn("Error auto creating directory: {} due to {}.
This exception is ignored.", endpointPath, e.getMessage(),
+ LOG.warn("Error auto creating directory: {} due to {}.
This exception is ignored.", endpointPath,
+ e.getMessage(),
e);
}
}
diff --git
a/components/camel-github/src/test/java/org/apache/camel/component/github/consumer/PullRequestConsumerTest.java
b/components/camel-github/src/test/java/org/apache/camel/component/github/consumer/PullRequestConsumerTest.java
index 864c2cbe400..244a870c1ae 100644
---
a/components/camel-github/src/test/java/org/apache/camel/component/github/consumer/PullRequestConsumerTest.java
+++
b/components/camel-github/src/test/java/org/apache/camel/component/github/consumer/PullRequestConsumerTest.java
@@ -65,7 +65,8 @@ public class PullRequestConsumerTest extends
GitHubComponentTestBase {
pullRequest.getHtmlUrl();
pullRequest.getUser().getLogin();
pullRequest.getUser().getHtmlUrl();
- LOG.debug("Got PullRequest {} [{}] From {}",
pullRequest.getHtmlUrl(), pullRequest.getTitle(), pullRequestUser.getLogin());
+ LOG.debug("Got PullRequest {} [{}] From {}",
pullRequest.getHtmlUrl(), pullRequest.getTitle(),
+ pullRequestUser.getLogin());
}
}
}
diff --git
a/components/camel-jms/src/test/java/org/apache/camel/component/jms/TwoConsumerOnSameQueueTest.java
b/components/camel-jms/src/test/java/org/apache/camel/component/jms/TwoConsumerOnSameQueueTest.java
index 9940d6a711b..a142011ae43 100644
---
a/components/camel-jms/src/test/java/org/apache/camel/component/jms/TwoConsumerOnSameQueueTest.java
+++
b/components/camel-jms/src/test/java/org/apache/camel/component/jms/TwoConsumerOnSameQueueTest.java
@@ -111,7 +111,7 @@ public class TwoConsumerOnSameQueueTest extends
AbstractPersistentJMSTest {
}
private static void assertExchange(Exchange exchange) {
- assertNotNull( exchange.getIn(), "There should be an in message");
+ assertNotNull(exchange.getIn(), "There should be an in message");
assertNotNull(exchange.getIn().getBody(), "There should be an in
body");
assertNotNull(exchange.getIn().getBody(String.class), "The in message
body should be of type String");
assertEquals("Hello World", exchange.getIn().getBody(), "The in
message body should be 'Hello World");
diff --git
a/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/ConditionalExceptionProcessor.java
b/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/ConditionalExceptionProcessor.java
index a798b9d91a4..0136dccb369 100644
---
a/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/ConditionalExceptionProcessor.java
+++
b/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/ConditionalExceptionProcessor.java
@@ -50,7 +50,7 @@ public class ConditionalExceptionProcessor implements
Processor {
}
// should be printed 2 times due to one re-delivery after one failure
- LOG.info("Exchange[{}][{}] = {}", getCount(), ((getCount() % 2 != 0)
? "Should rollback" : "Should succeed"), exchange);
+ LOG.info("Exchange[{}][{}] = {}", getCount(), ((getCount() % 2 != 0) ?
"Should rollback" : "Should succeed"), exchange);
// force rollback on every mod 2 attempt
if (getCount() % 2 != 0) {
diff --git
a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/consumer/integration/KubernetesConfigMapsConsumerIT.java
b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/consumer/integration/KubernetesConfigMapsConsumerIT.java
index 8f9d82c63cc..29638e6d52b 100644
---
a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/consumer/integration/KubernetesConfigMapsConsumerIT.java
+++
b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/consumer/integration/KubernetesConfigMapsConsumerIT.java
@@ -177,7 +177,7 @@ public class KubernetesConfigMapsConsumerIT extends
KubernetesTestSupport {
ConfigMap cm = exchange.getIn().getBody(ConfigMap.class);
log.info("Got event with configmap name: {} and action {}",
cm.getMetadata().getName(),
-
in.getHeader(KubernetesConstants.KUBERNETES_EVENT_ACTION));
+ in.getHeader(KubernetesConstants.KUBERNETES_EVENT_ACTION));
}
}
}
diff --git
a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/consumer/integration/KubernetesNamespacesConsumerIT.java
b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/consumer/integration/KubernetesNamespacesConsumerIT.java
index fb2166b74dd..87e683661b7 100644
---
a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/consumer/integration/KubernetesNamespacesConsumerIT.java
+++
b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/consumer/integration/KubernetesNamespacesConsumerIT.java
@@ -133,7 +133,7 @@ public class KubernetesNamespacesConsumerIT extends
KubernetesTestSupport {
public void process(Exchange exchange) {
Message in = exchange.getIn();
log.info("Got event with body: {} and action {}", in.getBody(),
-
in.getHeader(KubernetesConstants.KUBERNETES_EVENT_ACTION));
+ in.getHeader(KubernetesConstants.KUBERNETES_EVENT_ACTION));
}
}
}
diff --git
a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/consumer/integration/KubernetesNodesConsumerIT.java
b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/consumer/integration/KubernetesNodesConsumerIT.java
index 24468aebb3b..a1fbc3ea826 100644
---
a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/consumer/integration/KubernetesNodesConsumerIT.java
+++
b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/consumer/integration/KubernetesNodesConsumerIT.java
@@ -85,7 +85,7 @@ public class KubernetesNodesConsumerIT extends
KubernetesTestSupport {
Message in = exchange.getIn();
Node node = exchange.getIn().getBody(Node.class);
log.info("Got event with node name: {} and action {}",
node.getMetadata().getName(),
-
in.getHeader(KubernetesConstants.KUBERNETES_EVENT_ACTION));
+ in.getHeader(KubernetesConstants.KUBERNETES_EVENT_ACTION));
}
}
}
diff --git
a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/consumer/integration/KubernetesPodsConsumerIT.java
b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/consumer/integration/KubernetesPodsConsumerIT.java
index 73472e28299..09b66b51e5b 100644
---
a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/consumer/integration/KubernetesPodsConsumerIT.java
+++
b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/consumer/integration/KubernetesPodsConsumerIT.java
@@ -139,7 +139,7 @@ public class KubernetesPodsConsumerIT extends
KubernetesTestSupport {
Message in = exchange.getIn();
Pod pod = exchange.getIn().getBody(Pod.class);
log.info("Got event with pod name: {} and action {}",
pod.getMetadata().getName(),
-
in.getHeader(KubernetesConstants.KUBERNETES_EVENT_ACTION));
+ in.getHeader(KubernetesConstants.KUBERNETES_EVENT_ACTION));
}
}
}
diff --git
a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/consumer/integration/KubernetesReplicationControllersConsumerIT.java
b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/consumer/integration/KubernetesReplicationControllersConsumerIT.java
index cae785705b2..cd76c398ba7 100644
---
a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/consumer/integration/KubernetesReplicationControllersConsumerIT.java
+++
b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/consumer/integration/KubernetesReplicationControllersConsumerIT.java
@@ -128,7 +128,7 @@ public class KubernetesReplicationControllersConsumerIT
extends KubernetesTestSu
public void process(Exchange exchange) {
Message in = exchange.getIn();
log.info("Got event with body: {} and action {}", in.getBody(),
-
in.getHeader(KubernetesConstants.KUBERNETES_EVENT_ACTION));
+ in.getHeader(KubernetesConstants.KUBERNETES_EVENT_ACTION));
}
}
}
diff --git
a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/consumer/integration/KubernetesServicesConsumerIT.java
b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/consumer/integration/KubernetesServicesConsumerIT.java
index 3d3725c0a8c..74dc33415a1 100644
---
a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/consumer/integration/KubernetesServicesConsumerIT.java
+++
b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/consumer/integration/KubernetesServicesConsumerIT.java
@@ -127,7 +127,7 @@ public class KubernetesServicesConsumerIT extends
KubernetesTestSupport {
public void process(Exchange exchange) {
Message in = exchange.getIn();
log.info("Got event with body: {} and action {}", in.getBody(),
-
in.getHeader(KubernetesConstants.KUBERNETES_EVENT_ACTION));
+ in.getHeader(KubernetesConstants.KUBERNETES_EVENT_ACTION));
}
}
}
diff --git
a/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBBigPayloadManualTest.java
b/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBBigPayloadManualTest.java
index 490e7bdffee..5fd7b515d35 100644
---
a/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBBigPayloadManualTest.java
+++
b/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBBigPayloadManualTest.java
@@ -60,7 +60,7 @@ public class LevelDBBigPayloadManualTest extends
LevelDBTestSupport {
File file = new File("target/data/leveldb.dat");
assertTrue(file.exists(), file + " should exists");
long size = file.length();
- log.info( "{} size is {}", file, size);
+ log.info("{} size is {}", file, size);
// should be about 32mb, so we say 34 just in case
assertTrue(size < 34 * 1024 * 1024, file + " should not be so big in
size, was: " + size);
}
diff --git
a/components/camel-mock/src/main/java/org/apache/camel/component/mock/MockEndpoint.java
b/components/camel-mock/src/main/java/org/apache/camel/component/mock/MockEndpoint.java
index cc3f189a51b..3d8d84db169 100644
---
a/components/camel-mock/src/main/java/org/apache/camel/component/mock/MockEndpoint.java
+++
b/components/camel-mock/src/main/java/org/apache/camel/component/mock/MockEndpoint.java
@@ -1141,7 +1141,7 @@ public class MockEndpoint extends DefaultEndpoint
implements BrowsableEndpoint,
Exchange e1 = map.get(key);
if (e1 != null) {
fail("Duplicate message found on message " + i + " has value: " +
key + " for expression: " + expression
- + ". Exchanges: " + e1 + " and " + e2);
+ + ". Exchanges: " + e1 + " and " + e2);
} else {
map.put(key, e2);
}
@@ -1240,8 +1240,6 @@ public class MockEndpoint extends DefaultEndpoint
implements BrowsableEndpoint,
}
}
-
-
/**
* Adds the expectation which will be invoked when enough messages are
received
*/
diff --git
a/components/camel-platform-http-main/src/test/java/org/apache/camel/component/platform/http/main/MainHttpFakeHealthCheck.java
b/components/camel-platform-http-main/src/test/java/org/apache/camel/component/platform/http/main/MainHttpFakeHealthCheck.java
index 79d36207bdb..5165c1f0284 100644
---
a/components/camel-platform-http-main/src/test/java/org/apache/camel/component/platform/http/main/MainHttpFakeHealthCheck.java
+++
b/components/camel-platform-http-main/src/test/java/org/apache/camel/component/platform/http/main/MainHttpFakeHealthCheck.java
@@ -36,4 +36,4 @@ public class MainHttpFakeHealthCheck extends
AbstractHealthCheck {
public boolean isReadiness() {
return true;
}
-}
\ No newline at end of file
+}
diff --git
a/components/camel-platform-http-main/src/test/java/org/apache/camel/component/platform/http/main/MainHttpServerTest.java
b/components/camel-platform-http-main/src/test/java/org/apache/camel/component/platform/http/main/MainHttpServerTest.java
index 02e6d4544e7..054ca84855c 100644
---
a/components/camel-platform-http-main/src/test/java/org/apache/camel/component/platform/http/main/MainHttpServerTest.java
+++
b/components/camel-platform-http-main/src/test/java/org/apache/camel/component/platform/http/main/MainHttpServerTest.java
@@ -62,4 +62,4 @@ class MainHttpServerTest {
}
-}
\ No newline at end of file
+}
diff --git
a/components/camel-test/camel-test-junit5/src/main/java/org/apache/camel/test/CamelRouteCoverageDumper.java
b/components/camel-test/camel-test-junit5/src/main/java/org/apache/camel/test/CamelRouteCoverageDumper.java
index ad534686597..43410d76423 100644
---
a/components/camel-test/camel-test-junit5/src/main/java/org/apache/camel/test/CamelRouteCoverageDumper.java
+++
b/components/camel-test/camel-test-junit5/src/main/java/org/apache/camel/test/CamelRouteCoverageDumper.java
@@ -28,7 +28,6 @@ import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.Set;
-import java.util.stream.Collectors;
import javax.management.AttributeNotFoundException;
import javax.management.InstanceNotFoundException;
diff --git
a/components/camel-test/camel-test-junit5/src/test/java/org/apache/camel/test/junit5/patterns/AsyncSendMockTest.java
b/components/camel-test/camel-test-junit5/src/test/java/org/apache/camel/test/junit5/patterns/AsyncSendMockTest.java
index c2ee57c0a01..67e352f16fe 100644
---
a/components/camel-test/camel-test-junit5/src/test/java/org/apache/camel/test/junit5/patterns/AsyncSendMockTest.java
+++
b/components/camel-test/camel-test-junit5/src/test/java/org/apache/camel/test/junit5/patterns/AsyncSendMockTest.java
@@ -23,7 +23,6 @@ import org.junit.jupiter.api.Test;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-import static org.junit.jupiter.api.Assertions.assertTrue;
import static org.junit.jupiter.api.Assertions.fail;
public class AsyncSendMockTest extends CamelTestSupport {
diff --git
a/components/camel-zookeeper-master/src/test/java/org/apache/camel/component/zookeepermaster/CuratorFactoryBean.java
b/components/camel-zookeeper-master/src/test/java/org/apache/camel/component/zookeepermaster/CuratorFactoryBean.java
index fd9445144cc..65f84695bbd 100644
---
a/components/camel-zookeeper-master/src/test/java/org/apache/camel/component/zookeepermaster/CuratorFactoryBean.java
+++
b/components/camel-zookeeper-master/src/test/java/org/apache/camel/component/zookeepermaster/CuratorFactoryBean.java
@@ -55,7 +55,7 @@ public class CuratorFactoryBean implements
FactoryBean<CuratorFramework>, Dispos
//-------------------------------------------------------------------------
@Override
public CuratorFramework getObject() {
- LOG.debug("Connecting to ZooKeeper on {}", connectString);
+ LOG.debug("Connecting to ZooKeeper on {}", connectString);
CuratorFrameworkFactory.Builder builder =
CuratorFrameworkFactory.builder()
.connectString(connectString)
diff --git
a/test-infra/camel-test-infra-common/src/test/java/org/apache/camel/test/infra/common/services/TestServiceUtil.java
b/test-infra/camel-test-infra-common/src/test/java/org/apache/camel/test/infra/common/services/TestServiceUtil.java
index 8ab8fb781a0..de979691f9e 100644
---
a/test-infra/camel-test-infra-common/src/test/java/org/apache/camel/test/infra/common/services/TestServiceUtil.java
+++
b/test-infra/camel-test-infra-common/src/test/java/org/apache/camel/test/infra/common/services/TestServiceUtil.java
@@ -80,7 +80,6 @@ public final class TestServiceUtil {
extensionContext.getDisplayName());
}
-
throw exception;
}
}
diff --git
a/test-infra/camel-test-infra-rocketmq/src/test/java/org/apache/camel/test/infra/rocketmq/services/RocketMQContainer.java
b/test-infra/camel-test-infra-rocketmq/src/test/java/org/apache/camel/test/infra/rocketmq/services/RocketMQContainer.java
index b551a78e02c..c2dbce69739 100644
---
a/test-infra/camel-test-infra-rocketmq/src/test/java/org/apache/camel/test/infra/rocketmq/services/RocketMQContainer.java
+++
b/test-infra/camel-test-infra-rocketmq/src/test/java/org/apache/camel/test/infra/rocketmq/services/RocketMQContainer.java
@@ -92,7 +92,8 @@ public class RocketMQContainer implements RocketMQService,
ContainerService<Rock
"sh", "mqadmin", "updateTopic", "-n",
"nameserver:9876", "-t",
topic, "-c", "DefaultCluster");
- LOG.info("Exit code: {}. Stderr: {} Stdout: {} ",
execResult.getExitCode(), execResult.getStderr(), execResult.getStdout());
+ LOG.info("Exit code: {}. Stderr: {} Stdout: {} ",
execResult.getExitCode(), execResult.getStderr(),
+ execResult.getStdout());
return execResult.getStdout() != null &&
execResult.getStdout().contains("success");
});
