This is an automated email from the ASF dual-hosted git repository.
mikexue pushed a change to branch mongodb-connector
in repository https://gitbox.apache.org/repos/asf/incubator-eventmesh.git
from e85ad116b Merge pull request #2627 from
mroccyen/mongodb-connector-consumer
new 2a04c247b [ISSUE #2495] mongodb connector producer
new 29ae5c350 [ISSUE #2495] Add mongodb index
new da5cf2031 [ISSUE #2495] Add @slf4j
new d028de291 Merge pull request #3328 from
mroccyen/mongodb-connector-producer
The 2809 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:
.../eventmesh-connector-mongodb/build.gradle | 2 +-
.../consumer/MongodbReplicaSetConsumer.java | 9 +-
.../consumer/MongodbStandaloneConsumer.java | 15 +-
.../mongodb/producer/MongodbProducer.java} | 57 +++++---
.../producer/MongodbReplicaSetProducer.java} | 94 ++++++------
.../producer/MongodbStandaloneProducer.java | 157 +++++++++++++++++++++
...ventmesh.api.connector.ConnectorResourceService | 2 +-
.../org.apache.eventmesh.api.consumer.Consumer | 2 +-
.../org.apache.eventmesh.api.producer.Producer | 2 +-
.../src/main/resources/mongodb-client.properties | 25 ++--
.../connector/mongodb/MongodbConnectorTest.java} | 25 +---
.../eventmesh/connector/mongodb/MongodbServer.java | 58 ++++++++
.../connector/mongodb/MongodbServerTest.java | 71 ++++++++++
.../src/test/resources/mongodb-client.properties | 25 ++--
14 files changed, 414 insertions(+), 130 deletions(-)
copy
eventmesh-connector-plugin/{eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector/pulsar/producer/PulsarProducerImpl.java
=>
eventmesh-connector-mongodb/src/main/java/org/apache/eventmesh/connector/mongodb/producer/MongodbProducer.java}
(54%)
copy
eventmesh-connector-plugin/{eventmesh-connector-redis/src/main/java/org/apache/eventmesh/connector/redis/producer/RedisProducer.java
=>
eventmesh-connector-mongodb/src/main/java/org/apache/eventmesh/connector/mongodb/producer/MongodbReplicaSetProducer.java}
(53%)
create mode 100644
eventmesh-connector-plugin/eventmesh-connector-mongodb/src/main/java/org/apache/eventmesh/connector/mongodb/producer/MongodbStandaloneProducer.java
copy
eventmesh-connector-plugin/{eventmesh-connector-pravega/src/main/resources/META-INF/eventmesh
=>
eventmesh-connector-mongodb/src/main/resources/META-INF.eventmesh}/org.apache.eventmesh.api.connector.ConnectorResourceService
(89%)
copy
eventmesh-connector-plugin/{eventmesh-connector-pravega/src/main/resources/META-INF/eventmesh
=>
eventmesh-connector-mongodb/src/main/resources/META-INF.eventmesh}/org.apache.eventmesh.api.consumer.Consumer
(91%)
copy
eventmesh-connector-plugin/{eventmesh-connector-pravega/src/main/resources/META-INF/eventmesh
=>
eventmesh-connector-mongodb/src/main/resources/META-INF.eventmesh}/org.apache.eventmesh.api.producer.Producer
(91%)
copy
eventmesh-registry-plugin/eventmesh-registry-zookeeper/src/test/resources/log4j.properties
=>
eventmesh-connector-plugin/eventmesh-connector-mongodb/src/main/resources/mongodb-client.properties
(57%)
copy
eventmesh-connector-plugin/{eventmesh-connector-rabbitmq/src/test/java/org/apache/eventmesh/connector/rabbitmq/consumer/RabbitmqConsumerTest.java
=>
eventmesh-connector-mongodb/src/test/java/org/apache/eventmesh/connector/mongodb/MongodbConnectorTest.java}
(80%)
create mode 100644
eventmesh-connector-plugin/eventmesh-connector-mongodb/src/test/java/org/apache/eventmesh/connector/mongodb/MongodbServer.java
create mode 100644
eventmesh-connector-plugin/eventmesh-connector-mongodb/src/test/java/org/apache/eventmesh/connector/mongodb/MongodbServerTest.java
copy
eventmesh-registry-plugin/eventmesh-registry-zookeeper/src/test/resources/log4j.properties
=>
eventmesh-connector-plugin/eventmesh-connector-mongodb/src/test/resources/mongodb-client.properties
(57%)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
