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/incubator-eventmesh.git
from adbe5ee64 Merge pull request #3274 from epiao55/dev_fix_3273
add 1c86ce91c add mongodb connector config
add c3a8a6100 add license header
add 46c4bf516 add license header
add 687013aaa Merge pull request #2590 from
mroccyen/mongodb-connector-config-new1
add c62612cc7 add mongodb consumer
add 60f558c85 add license header
add e85ad116b Merge pull request #2627 from
mroccyen/mongodb-connector-consumer
add 2a04c247b [ISSUE #2495] mongodb connector producer
add 29ae5c350 [ISSUE #2495] Add mongodb index
add da5cf2031 [ISSUE #2495] Add @slf4j
add d028de291 Merge pull request #3328 from
mroccyen/mongodb-connector-producer
add 26e3f4747 Merge remote-tracking branch 'upstream/master' into
mongodb-connector-upstream
add e37bfb3ce mongodb move to storage module
add 8b8287ec6 mongodb move to storage module
add 67a106962 Merge pull request #3449 from
mroccyen/mongodb-connector-storage
new 1c18672f9 Merge pull request #3452 from apache/mongodb-connector
The 1 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:
.../build.gradle | 19 ++-
.../gradle.properties | 2 +-
.../mongodb/client/MongodbClientManager.java | 31 ++--
.../storage/mongodb/config/ConfigKey.java} | 16 +-
.../mongodb/config/ConfigurationHolder.java | 24 +--
.../mongodb/constant/MongodbConstants.java} | 21 +--
.../storage/mongodb/consumer/MongodbConsumer.java} | 32 ++--
.../consumer/MongodbReplicaSetConsumer.java | 140 ++++++++++++++++
.../consumer/MongodbStandaloneConsumer.java | 178 +++++++++++++++++++++
.../exception/MongodbStorageException.java} | 8 +-
.../storage/mongodb/producer/MongodbProducer.java | 68 ++++----
.../producer/MongodbReplicaSetProducer.java} | 96 +++++------
.../producer/MongodbStandaloneProducer.java | 157 ++++++++++++++++++
.../storage/MongodbStorageResourceService.java} | 5 +-
.../mongodb/utils/MongodbCloudEventUtil.java | 72 +++++++++
.../storage/mongodb/utils/MongodbSequenceUtil.java | 54 +++++++
.../org.apache.eventmesh.api.consumer.Consumer | 2 +-
.../org.apache.eventmesh.api.producer.Producer | 2 +-
...he.eventmesh.api.storage.StorageResourceService | 2 +-
.../src/main/resources/mongodb-client.properties} | 24 ++-
.../storage/mongodb/MongodbConnectorTest.java} | 42 ++---
.../eventmesh/storage/mongodb/MongodbServer.java | 62 +++++++
.../storage/mongodb/MongodbServerTest.java | 71 ++++++++
.../src/test/resources/mongodb-client.properties} | 24 ++-
settings.gradle | 1 +
tools/dependency-check/known-dependencies.txt | 3 +
26 files changed, 946 insertions(+), 210 deletions(-)
copy eventmesh-storage/{eventmesh-storage-rabbitmq =>
eventmesh-storage-mongodb}/build.gradle (78%)
copy eventmesh-storage/{eventmesh-storage-pulsar =>
eventmesh-storage-mongodb}/gradle.properties (97%)
copy
eventmesh-connector-plugin/eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector/rabbitmq/connector/RabbitmqConnectorResourceService.java
=>
eventmesh-storage/eventmesh-storage-mongodb/src/main/java/org/apache/eventmesh/storage/mongodb/client/MongodbClientManager.java
(52%)
copy
eventmesh-storage/{eventmesh-storage-redis/src/main/java/org/apache/eventmesh/storage/redis/storage/RedisStorageResourceService.java
=>
eventmesh-storage-mongodb/src/main/java/org/apache/eventmesh/storage/mongodb/config/ConfigKey.java}
(71%)
copy
eventmesh-connector-plugin/eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector/rabbitmq/connector/RabbitmqConnectorResourceService.java
=>
eventmesh-storage/eventmesh-storage-mongodb/src/main/java/org/apache/eventmesh/storage/mongodb/config/ConfigurationHolder.java
(58%)
copy
eventmesh-storage/{eventmesh-storage-rabbitmq/src/main/java/org/apache/eventmesh/storage/rabbitmq/storage/RabbitmqStorageResourceService.java
=>
eventmesh-storage-mongodb/src/main/java/org/apache/eventmesh/storage/mongodb/constant/MongodbConstants.java}
(64%)
copy
eventmesh-storage/{eventmesh-storage-standalone/src/main/java/org/apache/eventmesh/storage/standalone/consumer/StandaloneConsumerAdaptor.java
=>
eventmesh-storage-mongodb/src/main/java/org/apache/eventmesh/storage/mongodb/consumer/MongodbConsumer.java}
(59%)
create mode 100644
eventmesh-storage/eventmesh-storage-mongodb/src/main/java/org/apache/eventmesh/storage/mongodb/consumer/MongodbReplicaSetConsumer.java
create mode 100644
eventmesh-storage/eventmesh-storage-mongodb/src/main/java/org/apache/eventmesh/storage/mongodb/consumer/MongodbStandaloneConsumer.java
copy
eventmesh-storage/{eventmesh-storage-pravega/src/main/java/org/apache/eventmesh/storage/pravega/exception/PravegaStorageException.java
=>
eventmesh-storage-mongodb/src/main/java/org/apache/eventmesh/storage/mongodb/exception/MongodbStorageException.java}
(80%)
copy
eventmesh-connector-plugin/eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector/pulsar/producer/PulsarProducerImpl.java
=>
eventmesh-storage/eventmesh-storage-mongodb/src/main/java/org/apache/eventmesh/storage/mongodb/producer/MongodbProducer.java
(55%)
copy
eventmesh-storage/{eventmesh-storage-redis/src/main/java/org/apache/eventmesh/storage/redis/producer/RedisProducer.java
=>
eventmesh-storage-mongodb/src/main/java/org/apache/eventmesh/storage/mongodb/producer/MongodbReplicaSetProducer.java}
(50%)
create mode 100644
eventmesh-storage/eventmesh-storage-mongodb/src/main/java/org/apache/eventmesh/storage/mongodb/producer/MongodbStandaloneProducer.java
copy
eventmesh-storage/{eventmesh-storage-redis/src/main/java/org/apache/eventmesh/storage/redis/storage/RedisStorageResourceService.java
=>
eventmesh-storage-mongodb/src/main/java/org/apache/eventmesh/storage/mongodb/storage/MongodbStorageResourceService.java}
(88%)
create mode 100644
eventmesh-storage/eventmesh-storage-mongodb/src/main/java/org/apache/eventmesh/storage/mongodb/utils/MongodbCloudEventUtil.java
create mode 100644
eventmesh-storage/eventmesh-storage-mongodb/src/main/java/org/apache/eventmesh/storage/mongodb/utils/MongodbSequenceUtil.java
copy {eventmesh-connector-plugin/eventmesh-connector-pravega =>
eventmesh-storage/eventmesh-storage-mongodb}/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.consumer.Consumer
(91%)
copy {eventmesh-connector-plugin/eventmesh-connector-pravega =>
eventmesh-storage/eventmesh-storage-mongodb}/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.producer.Producer
(91%)
copy eventmesh-storage/{eventmesh-storage-kafka =>
eventmesh-storage-mongodb}/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.storage.StorageResourceService
(90%)
copy
eventmesh-storage/{eventmesh-storage-rabbitmq/src/main/resources/rabbitmq-client.properties
=> eventmesh-storage-mongodb/src/main/resources/mongodb-client.properties}
(57%)
copy
eventmesh-storage/{eventmesh-storage-rabbitmq/src/test/java/org/apache/eventmesh/storage/rabbitmq/consumer/RabbitmqConsumerTest.java
=>
eventmesh-storage-mongodb/src/test/java/org/apache/eventmesh/storage/mongodb/MongodbConnectorTest.java}
(68%)
create mode 100644
eventmesh-storage/eventmesh-storage-mongodb/src/test/java/org/apache/eventmesh/storage/mongodb/MongodbServer.java
create mode 100644
eventmesh-storage/eventmesh-storage-mongodb/src/test/java/org/apache/eventmesh/storage/mongodb/MongodbServerTest.java
copy
eventmesh-storage/{eventmesh-storage-rabbitmq/src/main/resources/rabbitmq-client.properties
=> eventmesh-storage-mongodb/src/test/resources/mongodb-client.properties}
(57%)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
