This is an automated email from the ASF dual-hosted git repository.
orpiske pushed a change to branch camel-master
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git.
from 087dfb5 [create-pull-request] automated change
new 9a156c3 Avoid creating everything from scratch for every Cassandra
sink test
new 95963aa Avoid blocking connector initialization on SSH tests as it
leads to failures on GH actions
new abc05f2 Give another run on test failures to rule out false negatives
due to slow CI environments
new dd5ce04 Rework the syslog integration tests to let JUnit handle
camel's lifecycle in the test
new 3b6f14b #873 initial cxf Source/Sink connectors test (#940)
new 09df84f Cleanup the check state logic on the
KafkaConnectEmbeddedService
new d3adf24 Set the port configuration to avoid the Jetty port error when
creating the connect instance
new ab56f43 Removed incorrect log message about connector initialization
new 2b0bda2 Delete the connector before deleting the test topics
new 56ddf9e Avoid spawning Jetty servers too quickly as they seem to
cause GH actions to fail
The 10 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.github/workflows/ci-build.yml | 1 +
.github/workflows/daily-java-next.yml | 1 +
Jenkinsfile.jdk11 | 2 +-
.../cassandra/sink/CamelSinkCassandraITCase.java | 13 +-
.../services/kafka/EmbeddedKafkaService.java | 2 +
.../kafkaconnect/KafkaConnectEmbedded.java | 17 +-
.../common/test/CamelSinkTestSupport.java | 25 +++
.../common/test/CamelSourceTestSupport.java | 2 -
tests/{itests-hdfs => itests-cxf}/pom.xml | 48 ++++--
.../cxf/sink/CamelSinkCXFITCase.java | 189 +++++++++++++++++++++
.../cxf/sink/CamelSinkCXFPropertyFactory.java} | 36 ++--
.../kafkaconnector/cxf/sink/GreeterImpl.java} | 13 +-
.../kafkaconnector/cxf/sink/HelloServiceImpl.java | 81 +++++++++
.../cxf/source/CamelSourceCXFITCase.java | 181 ++++++++++++++++++++
.../cxf/source/CamelSourceCXFPropertyFactory.java} | 44 +++--
.../kafkaconnector/cxf/source/HelloService.java} | 18 +-
.../ssh/sink/CamelSinkSshITCase.java | 2 +-
.../syslog/services/RouteConfigurator.java} | 9 +-
...slogService.java => SinkRouteConfigurator.java} | 41 ++---
.../syslog/services/SourceRouteConfigurator.java | 54 ++++++
.../syslog/services/SyslogService.java | 49 +++---
.../syslog/sink/CamelSinkSyslogITCase.java | 19 ++-
.../syslog/source/CamelSourceSyslogITCase.java | 64 +++----
23 files changed, 752 insertions(+), 159 deletions(-)
copy tests/{itests-hdfs => itests-cxf}/pom.xml (65%)
create mode 100644
tests/itests-cxf/src/test/java/org/apache/camel/kafkaconnector/cxf/sink/CamelSinkCXFITCase.java
copy
tests/{itests-http/src/test/java/org/apache/camel/kafkaconnector/http/sink/CamelHTTPPropertyFactory.java
=>
itests-cxf/src/test/java/org/apache/camel/kafkaconnector/cxf/sink/CamelSinkCXFPropertyFactory.java}
(56%)
copy
tests/{itests-ssh/src/test/java/org/apache/camel/kafkaconnector/ssh/common/SshProperties.java
=>
itests-cxf/src/test/java/org/apache/camel/kafkaconnector/cxf/sink/GreeterImpl.java}
(69%)
create mode 100644
tests/itests-cxf/src/test/java/org/apache/camel/kafkaconnector/cxf/sink/HelloServiceImpl.java
create mode 100644
tests/itests-cxf/src/test/java/org/apache/camel/kafkaconnector/cxf/source/CamelSourceCXFITCase.java
copy
tests/{itests-sjms2/src/test/java/org/apache/camel/kafkaconnector/sjms2/source/CamelJMSPropertyFactory.java
=>
itests-cxf/src/test/java/org/apache/camel/kafkaconnector/cxf/source/CamelSourceCXFPropertyFactory.java}
(50%)
copy
tests/{itests-common/src/test/java/org/apache/camel/kafkaconnector/common/test/TestMessageConsumer.java
=>
itests-cxf/src/test/java/org/apache/camel/kafkaconnector/cxf/source/HelloService.java}
(72%)
copy
tests/{itests-common/src/test/java/org/apache/camel/kafkaconnector/common/test/FunctionalTestMessageProducer.java
=>
itests-syslog/src/test/java/org/apache/camel/kafkaconnector/syslog/services/RouteConfigurator.java}
(80%)
copy
tests/itests-syslog/src/test/java/org/apache/camel/kafkaconnector/syslog/services/{SyslogService.java
=> SinkRouteConfigurator.java} (51%)
create mode 100644
tests/itests-syslog/src/test/java/org/apache/camel/kafkaconnector/syslog/services/SourceRouteConfigurator.java
