feat(client): allow to access the pojo codec repository of a collection

loicmathieu · Jan 17, 2020 · 32de1d4 · 32de1d4
1 parent 3ab105c
commit 32de1d4
Show file tree

Hide file tree

Showing 2 changed files with 14 additions and 0 deletions.
diff --git a/...ions/mongodb-client/runtime/src/main/java/io/quarkus/mongodb/ReactiveMongoCollection.java b/...ions/mongodb-client/runtime/src/main/java/io/quarkus/mongodb/ReactiveMongoCollection.java
@@ -4,6 +4,7 @@
 import java.util.concurrent.CompletionStage;
 
 import org.bson.Document;
+import org.bson.codecs.configuration.CodecRegistry;
 import org.bson.conversions.Bson;
 import org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder;
 
@@ -30,6 +31,13 @@ public interface ReactiveMongoCollection<T> {
      */
     MongoNamespace getNamespace();
 
+    /**
+     * Gets the codec registry of this collection.
+     *
+     * @return the codec registry
+     */
+    CodecRegistry getCodecRegistry();
+
     /**
      * Get the class of documents stored in this collection.
      *

diff --git a/...odb-client/runtime/src/main/java/io/quarkus/mongodb/impl/ReactiveMongoCollectionImpl.java b/...odb-client/runtime/src/main/java/io/quarkus/mongodb/impl/ReactiveMongoCollectionImpl.java
@@ -4,6 +4,7 @@
 import java.util.concurrent.CompletionStage;
 
 import org.bson.Document;
+import org.bson.codecs.configuration.CodecRegistry;
 import org.bson.conversions.Bson;
 import org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder;
 import org.eclipse.microprofile.reactive.streams.operators.ReactiveStreams;
@@ -59,6 +60,11 @@ public MongoNamespace getNamespace() {
         return collection.getNamespace();
     }
 
+    @Override
+    public CodecRegistry getCodecRegistry() {
+        return collection.getCodecRegistry();
+    }
+
     @Override
     public Class<T> getDocumentClass() {
         return collection.getDocumentClass();