This is an automated email from the ASF dual-hosted git repository.
mikexue pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/eventmesh.git
from 19ed469c3 [ISSUE #4146] fix some code to pass checkstyle (#4147)
add 0d1069881 [ISSUE #4128] Add eventmesh-connector-rocketmq module (#4148)
No new revisions were added by this update.
Summary of changes:
.../build.gradle | 2 +-
.../gradle.properties | 0
.../rocketmq/config/RocketMQServerConfig.java} | 10 ++----
.../rocketmq/server/RocketMQConnectServer.java} | 29 ++++++++++++----
.../rocketmq/sink}/config/RocketMQSinkConfig.java | 4 +--
.../rocketmq/sink/config/SinkConnectorConfig.java} | 4 +--
.../sink}/connector/RocketMQSinkConnector.java | 4 +--
.../source}/config/RocketMQSourceConfig.java | 4 +--
.../source/config/SourceConnectorConfig.java} | 4 +--
.../source}/connector/RocketMQSourceConnector.java | 4 +--
.../src/main/resources/server-config.yml | 4 +--
.../src/main/resources/sink-config.yml} | 2 +-
.../src/main/resources/source-config.yml} | 2 +-
.../connector/rocketmq/RocketMQSinkWorker.java | 31 -----------------
.../source-connector-rocketmq/build.gradle | 40 ----------------------
.../source-connector-rocketmq/gradle.properties | 17 ---------
settings.gradle | 3 +-
17 files changed, 42 insertions(+), 122 deletions(-)
rename eventmesh-connectors/{sink-connector-rocketmq =>
eventmesh-connector-rocketmq}/build.gradle (99%)
rename eventmesh-connectors/{sink-connector-rocketmq =>
eventmesh-connector-rocketmq}/gradle.properties (100%)
copy
eventmesh-connectors/{eventmesh-connector-openfunction/src/main/java/org/apache/eventmesh/connector/openfunction/config/OpenFunctionServerConfig.java
=>
eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/config/RocketMQServerConfig.java}
(82%)
rename
eventmesh-connectors/{source-connector-rocketmq/src/main/java/org/apache/eventmesh/source/connector/rocketmq/RocketMQSourceWorker.java
=>
eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/server/RocketMQConnectServer.java}
(51%)
rename
eventmesh-connectors/{sink-connector-rocketmq/src/main/java/org/apache/eventmesh/sink/connector/rocketmq
=>
eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/sink}/config/RocketMQSinkConfig.java
(89%)
rename
eventmesh-connectors/{sink-connector-rocketmq/src/main/java/org/apache/eventmesh/sink/connector/rocketmq/config/ConnectorConfig.java
=>
eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/sink/config/SinkConnectorConfig.java}
(90%)
rename
eventmesh-connectors/{sink-connector-rocketmq/src/main/java/org/apache/eventmesh/sink/connector/rocketmq
=>
eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/sink}/connector/RocketMQSinkConnector.java
(96%)
rename
eventmesh-connectors/{source-connector-rocketmq/src/main/java/org/apache/eventmesh/source/connector/rocketmq
=>
eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/source}/config/RocketMQSourceConfig.java
(89%)
rename
eventmesh-connectors/{source-connector-rocketmq/src/main/java/org/apache/eventmesh/source/connector/rocketmq/config/ConnectorConfig.java
=>
eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/source/config/SourceConnectorConfig.java}
(90%)
rename
eventmesh-connectors/{source-connector-rocketmq/src/main/java/org/apache/eventmesh/source/connector/rocketmq
=>
eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/source}/connector/RocketMQSourceConnector.java
(96%)
copy eventmesh-trace-plugin/eventmesh-trace-jaeger/gradle.properties =>
eventmesh-connectors/eventmesh-connector-rocketmq/src/main/resources/server-config.yml
(95%)
rename
eventmesh-connectors/{sink-connector-rocketmq/src/main/resources/config.yml =>
eventmesh-connector-rocketmq/src/main/resources/sink-config.yml} (98%)
rename
eventmesh-connectors/{source-connector-rocketmq/src/main/resources/config.yml
=> eventmesh-connector-rocketmq/src/main/resources/source-config.yml} (97%)
delete mode 100644
eventmesh-connectors/sink-connector-rocketmq/src/main/java/org/apache/eventmesh/sink/connector/rocketmq/RocketMQSinkWorker.java
delete mode 100644 eventmesh-connectors/source-connector-rocketmq/build.gradle
delete mode 100644
eventmesh-connectors/source-connector-rocketmq/gradle.properties
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
