You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@eventmesh.apache.org by mi...@apache.org on 2023/06/25 03:13:45 UTC
[eventmesh] branch master updated (19ed469c3 -> 0d1069881)

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: commits-unsubscribe@eventmesh.apache.org
For additional commands, e-mail: commits-help@eventmesh.apache.org