This is an automated email from the ASF dual-hosted git repository.
chenguangsheng pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/eventmesh.git
from 95ec17362 [ISSUE #4388] Improve the rocketmq source connector offset
ack (#4389)
new 8f137844e feat: refactor with rabbitmq plugin.
new 32e11dd63 feat: refactor with rabbitmq plugin.
new beb2e57a5 feat: refactor with rabbitmq plugin.
new 403ae9ca7 feat: refactor with rabbitmq plugin.
new a5639bff8 feat: refactor with rabbitmq plugin.
new d37bd9e52 feat: refactor with rabbitmq plugin.
new 3cd567016 Merge branch 'apache:master' into rabbitmq_plugin
new a53d6b342 Merge remote-tracking branch 'origin/rabbitmq_plugin' into
rabbitmq_plugin
new d7bd58131 feat: refactor with rabbitmq plugin.
new 47d88a06f feat: refactor with rabbitmq plugin.
new ac4c5cb88 feat: refactor with rabbitmq plugin.
new 1b717a382 Merge branch 'apache:master' into rabbitmq_plugin
new ce4c8bb52 Merge remote-tracking branch 'origin/rabbitmq_plugin' into
rabbitmq_plugin
new 3f1783f6a feat: refactor with rabbitmq plugin.
new fd1102ac0 Merge pull request #4393 from fabian4/rabbitmq_plugin
The 4434 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:
.../sink/connector/MongodbSinkConnector.java | 34 +---
.../source/connector/MongodbSourceConnector.java | 17 +-
.../build.gradle | 14 +-
.../gradle.properties | 2 +-
.../connector}/rabbitmq/client/RabbitmqClient.java | 2 +-
.../rabbitmq/client/RabbitmqConnectionFactory.java | 2 +-
.../rabbitmq/cloudevent/RabbitmqCloudEvent.java | 10 +-
.../cloudevent/RabbitmqCloudEventWriter.java | 2 +-
.../rabbitmq/config/RabbitMQServerConfig.java} | 4 +-
.../exception/RabbitmqConnectorException.java | 10 +-
.../rabbitmq/server/RabbitMQConnectorServer.java} | 21 ++-
.../rabbitmq/sink/config/RabbitMQSinkConfig.java} | 4 +-
.../rabbitmq}/sink/config/SinkConnectorConfig.java | 24 ++-
.../sink/connector/RabbitMQSinkConnector.java | 128 ++++++++++++++
.../source/config/RabbitMQSourceConfig.java} | 4 +-
.../source/config/SourceConnectorConfig.java | 23 ++-
.../source/connector/RabbitMQSourceConnector.java | 188 +++++++++++++++++++++
.../connector}/rabbitmq/utils/ByteArrayUtils.java | 2 +-
.../src/main/resources/server-config.yml | 0
.../src/main/resources/sink-config.yml | 20 ++-
.../src/main/resources/source-config.yml | 27 +--
.../redis/sink/connector/RedisSinkConnector.java | 34 +---
.../source/connector/RedisSourceConnector.java | 16 +-
.../apache/eventmesh/openconnect/SinkWorker.java | 15 +-
.../eventmesh/openconnect/util/CloudEventUtil.java | 77 +++++++++
settings.gradle | 1 +
26 files changed, 513 insertions(+), 168 deletions(-)
copy eventmesh-connectors/{eventmesh-connector-mongodb =>
eventmesh-connector-rabbitmq}/build.gradle (77%)
copy eventmesh-connectors/{eventmesh-connector-kafka =>
eventmesh-connector-rabbitmq}/gradle.properties (97%)
copy
{eventmesh-storage-plugin/eventmesh-storage-rabbitmq/src/main/java/org/apache/eventmesh/storage
=>
eventmesh-connectors/eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector}/rabbitmq/client/RabbitmqClient.java
(98%)
copy
{eventmesh-storage-plugin/eventmesh-storage-rabbitmq/src/main/java/org/apache/eventmesh/storage
=>
eventmesh-connectors/eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector}/rabbitmq/client/RabbitmqConnectionFactory.java
(96%)
copy
{eventmesh-storage-plugin/eventmesh-storage-rabbitmq/src/main/java/org/apache/eventmesh/storage
=>
eventmesh-connectors/eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector}/rabbitmq/cloudevent/RabbitmqCloudEvent.java
(87%)
copy
{eventmesh-storage-plugin/eventmesh-storage-rabbitmq/src/main/java/org/apache/eventmesh/storage
=>
eventmesh-connectors/eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector}/rabbitmq/cloudevent/RabbitmqCloudEventWriter.java
(97%)
copy
eventmesh-connectors/{eventmesh-connector-mongodb/src/main/java/org/apache/eventmesh/connector/mongodb/config/MongodbServerConfig.java
=>
eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector/rabbitmq/config/RabbitMQServerConfig.java}
(90%)
copy
eventmesh-trace-plugin/eventmesh-trace-api/src/main/java/org/apache/eventmesh/trace/api/exception/TraceException.java
=>
eventmesh-connectors/eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector/rabbitmq/exception/RabbitmqConnectorException.java
(76%)
copy
eventmesh-connectors/{eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/server/RocketMQConnectServer.java
=>
eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector/rabbitmq/server/RabbitMQConnectorServer.java}
(62%)
copy
eventmesh-connectors/{eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/sink/config/RocketMQSinkConfig.java
=>
eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector/rabbitmq/sink/config/RabbitMQSinkConfig.java}
(89%)
copy
eventmesh-connectors/{eventmesh-connector-mongodb/src/main/java/org/apache/eventmesh/connector/mongodb
=>
eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector/rabbitmq}/sink/config/SinkConnectorConfig.java
(68%)
create mode 100644
eventmesh-connectors/eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector/rabbitmq/sink/connector/RabbitMQSinkConnector.java
copy
eventmesh-connectors/{eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/source/config/RocketMQSourceConfig.java
=>
eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector/rabbitmq/source/config/RabbitMQSourceConfig.java}
(89%)
copy
eventmesh-connectors/{eventmesh-connector-mongodb/src/main/java/org/apache/eventmesh/connector/mongodb
=>
eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector/rabbitmq}/source/config/SourceConnectorConfig.java
(68%)
create mode 100644
eventmesh-connectors/eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector/rabbitmq/source/connector/RabbitMQSourceConnector.java
copy
{eventmesh-storage-plugin/eventmesh-storage-rabbitmq/src/main/java/org/apache/eventmesh/storage
=>
eventmesh-connectors/eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector}/rabbitmq/utils/ByteArrayUtils.java
(96%)
copy eventmesh-connectors/{eventmesh-connector-mongodb =>
eventmesh-connector-rabbitmq}/src/main/resources/server-config.yml (100%)
copy eventmesh-connectors/{eventmesh-connector-rocketmq =>
eventmesh-connector-rabbitmq}/src/main/resources/sink-config.yml (76%)
copy eventmesh-connectors/{eventmesh-connector-rocketmq =>
eventmesh-connector-rabbitmq}/src/main/resources/source-config.yml (72%)
create mode 100644
eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect/util/CloudEventUtil.java
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
