From 0af34009ae46ee6cfee82e91b9f979d1a91c4d80 Mon Sep 17 00:00:00 2001 From: Georgios Andrianakis Date: Mon, 24 May 2021 14:00:32 +0300 Subject: [PATCH] Add ChangeStreamDocument Mongo class for reflection Fixes: #17432 --- .../io/quarkus/mongodb/deployment/MongoClientProcessor.java | 2 ++ 1 file changed, 2 insertions(+) diff --git a/extensions/mongodb-client/deployment/src/main/java/io/quarkus/mongodb/deployment/MongoClientProcessor.java b/extensions/mongodb-client/deployment/src/main/java/io/quarkus/mongodb/deployment/MongoClientProcessor.java index 1678894060c11..7e1076053a72f 100644 --- a/extensions/mongodb-client/deployment/src/main/java/io/quarkus/mongodb/deployment/MongoClientProcessor.java +++ b/extensions/mongodb-client/deployment/src/main/java/io/quarkus/mongodb/deployment/MongoClientProcessor.java @@ -25,6 +25,7 @@ import org.jboss.jandex.IndexView; import com.mongodb.client.MongoClient; +import com.mongodb.client.model.changestream.ChangeStreamDocument; import com.mongodb.event.CommandListener; import com.mongodb.event.ConnectionPoolListener; @@ -116,6 +117,7 @@ List addExtensionPointsToNative(CodecProviderBuildItem reflectiveClassNames.addAll(propertyCodecProviders.getPropertyCodecProviderClassNames()); reflectiveClassNames.addAll(bsonDiscriminators.getBsonDiscriminatorClassNames()); reflectiveClassNames.addAll(commandListeners.getCommandListenerClassNames()); + reflectiveClassNames.add(ChangeStreamDocument.class.getName()); return reflectiveClassNames.stream() .map(s -> new ReflectiveClassBuildItem(true, true, false, s))