From 5e74e12a5601896d2d88700d5276ce62c0e9fe57 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Yoann=20Rodi=C3=A8re?= Date: Tue, 20 Jun 2023 16:47:01 +0200 Subject: [PATCH] Declare additional JPA model elements in relevant extensions --- .../deployment/pom.xml | 4 ++++ .../SmallRyeReactiveMessagingKafkaProcessor.java | 10 ++++++++++ 2 files changed, 14 insertions(+) diff --git a/extensions/smallrye-reactive-messaging-kafka/deployment/pom.xml b/extensions/smallrye-reactive-messaging-kafka/deployment/pom.xml index d474778d76ddd..e64d29a5e6e0b 100644 --- a/extensions/smallrye-reactive-messaging-kafka/deployment/pom.xml +++ b/extensions/smallrye-reactive-messaging-kafka/deployment/pom.xml @@ -42,6 +42,10 @@ io.quarkus quarkus-jackson-deployment + + io.quarkus + quarkus-hibernate-orm-deployment-spi + io.quarkus diff --git a/extensions/smallrye-reactive-messaging-kafka/deployment/src/main/java/io/quarkus/smallrye/reactivemessaging/kafka/deployment/SmallRyeReactiveMessagingKafkaProcessor.java b/extensions/smallrye-reactive-messaging-kafka/deployment/src/main/java/io/quarkus/smallrye/reactivemessaging/kafka/deployment/SmallRyeReactiveMessagingKafkaProcessor.java index d974580b1a610..1981a3ad43ff8 100644 --- a/extensions/smallrye-reactive-messaging-kafka/deployment/src/main/java/io/quarkus/smallrye/reactivemessaging/kafka/deployment/SmallRyeReactiveMessagingKafkaProcessor.java +++ b/extensions/smallrye-reactive-messaging-kafka/deployment/src/main/java/io/quarkus/smallrye/reactivemessaging/kafka/deployment/SmallRyeReactiveMessagingKafkaProcessor.java @@ -40,6 +40,7 @@ import io.quarkus.deployment.builditem.RuntimeConfigSetupCompleteBuildItem; import io.quarkus.deployment.builditem.nativeimage.ReflectiveClassBuildItem; import io.quarkus.deployment.logging.LogCleanupFilterBuildItem; +import io.quarkus.hibernate.orm.deployment.spi.AdditionalJpaModelBuildItem; import io.quarkus.smallrye.reactivemessaging.deployment.ReactiveMessagingDotNames; import io.quarkus.smallrye.reactivemessaging.deployment.items.ConnectorManagedChannelBuildItem; import io.quarkus.smallrye.reactivemessaging.kafka.DatabindProcessingStateCodec; @@ -58,6 +59,9 @@ public class SmallRyeReactiveMessagingKafkaProcessor { public static final String CHECKPOINT_STATE_STORE_MESSAGE = "Quarkus detected the use of `%s` for the" + " Kafka checkpoint commit strategy but the extension has not been added. Consider adding '%s'."; + private static final String CHECKPOINT_ENTITY_NAME = "io.quarkus.smallrye.reactivemessaging.kafka.CheckpointEntity"; + private static final String CHECKPOINT_ENTITY_ID_NAME = "io.quarkus.smallrye.reactivemessaging.kafka.CheckpointEntityId"; + @BuildStep FeatureBuildItem feature() { return new FeatureBuildItem(Feature.SMALLRYE_REACTIVE_MESSAGING_KAFKA); @@ -148,6 +152,12 @@ public void checkpointHibernateOrm(BuildProducer additi } } + @BuildStep + public void additionalJpaModel(BuildProducer additionalJpaModel) { + additionalJpaModel.produce(new AdditionalJpaModelBuildItem(CHECKPOINT_ENTITY_NAME)); + additionalJpaModel.produce(new AdditionalJpaModelBuildItem(CHECKPOINT_ENTITY_ID_NAME)); + } + /** * Handles the serializer/deserializer detection and whether the graceful shutdown should be used in dev mode. */