Package io.quarkus.smallrye.reactivemessaging.kafka.deployment

Class SmallRyeReactiveMessagingKafkaProcessor

java.lang.Object
io.quarkus.smallrye.reactivemessaging.kafka.deployment.SmallRyeReactiveMessagingKafkaProcessor
public class SmallRyeReactiveMessagingKafkaProcessor extends Object

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    static final String
    CHECKPOINT_STATE_STORE_MESSAGE
     

  • Constructor Summary

    Constructors
    Constructor
    Description
    SmallRyeReactiveMessagingKafkaProcessor()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    additionalJpaModel(io.quarkus.deployment.annotations.BuildProducer<io.quarkus.hibernate.orm.deployment.spi.AdditionalJpaModelBuildItem> additionalJpaModel)
     
    void
    build(io.quarkus.deployment.annotations.BuildProducer<io.quarkus.deployment.builditem.nativeimage.ReflectiveClassBuildItem> reflectiveClass, io.quarkus.deployment.annotations.BuildProducer<io.quarkus.arc.deployment.AdditionalBeanBuildItem> additionalBean)
     
    void
    checkpointHibernateOrm(io.quarkus.deployment.annotations.BuildProducer<io.quarkus.arc.deployment.AdditionalBeanBuildItem> additionalBean, io.quarkus.deployment.Capabilities capabilities)
     
    void
    checkpointHibernateReactive(io.quarkus.deployment.annotations.BuildProducer<io.quarkus.arc.deployment.AdditionalBeanBuildItem> additionalBean, io.quarkus.deployment.Capabilities capabilities)
     
    void
    checkpointRedis(io.quarkus.deployment.annotations.BuildProducer<io.quarkus.arc.deployment.AdditionalBeanBuildItem> additionalBean, io.quarkus.deployment.annotations.BuildProducer<io.quarkus.deployment.builditem.nativeimage.ReflectiveClassBuildItem> reflectiveClass, io.quarkus.deployment.Capabilities capabilities)
     
    void
    defaultChannelConfiguration(io.quarkus.deployment.builditem.LaunchModeBuildItem launchMode, ReactiveMessagingKafkaBuildTimeConfig buildTimeConfig, io.quarkus.deployment.builditem.CombinedIndexBuildItem combinedIndex, List<io.quarkus.smallrye.reactivemessaging.deployment.items.ConnectorManagedChannelBuildItem> channelsManagedByConnectors, io.quarkus.deployment.annotations.BuildProducer<io.quarkus.deployment.builditem.RunTimeConfigurationDefaultBuildItem> defaultConfigProducer, io.quarkus.deployment.annotations.BuildProducer<io.quarkus.deployment.builditem.GeneratedClassBuildItem> generatedClass, io.quarkus.deployment.annotations.BuildProducer<io.quarkus.deployment.builditem.nativeimage.ReflectiveClassBuildItem> reflection)
    Handles the serializer/deserializer detection and whether the graceful shutdown should be used in dev mode.
    (package private) void
    disableGracefulShutdown(List<io.quarkus.smallrye.reactivemessaging.deployment.items.ConnectorManagedChannelBuildItem> channelsManagedByConnectors, io.quarkus.deployment.annotations.BuildProducer<io.quarkus.deployment.builditem.RunTimeConfigurationDefaultBuildItem> defaultConfigProducer, DefaultSerdeDiscoveryState discoveryState)
     
    (package private) void
    discoverDefaultSerdeConfig(DefaultSerdeDiscoveryState discovery, List<io.quarkus.smallrye.reactivemessaging.deployment.items.ConnectorManagedChannelBuildItem> channelsManagedByConnectors, io.quarkus.deployment.annotations.BuildProducer<io.quarkus.deployment.builditem.RunTimeConfigurationDefaultBuildItem> config, io.quarkus.deployment.annotations.BuildProducer<io.quarkus.deployment.builditem.GeneratedClassBuildItem> generatedClass, io.quarkus.deployment.annotations.BuildProducer<io.quarkus.deployment.builditem.nativeimage.ReflectiveClassBuildItem> reflection)
     
    (package private) io.quarkus.deployment.builditem.FeatureBuildItem
    feature()
     
    (package private) static boolean
    hasDLQConfig(String channelName, org.eclipse.microprofile.config.Config config)
     
    (package private) static boolean
    hasStateStoreConfig(String stateStoreName, org.eclipse.microprofile.config.Config config)
     
    void
    ignoreDuplicateJmxRegistrationInDevAndTestModes(io.quarkus.deployment.builditem.LaunchModeBuildItem launchMode, io.quarkus.deployment.annotations.BuildProducer<io.quarkus.deployment.logging.LogCleanupFilterBuildItem> log)
     
    (package private) void
    processIncomingChannelForReflectiveClassPayload(org.jboss.jandex.IndexView index, org.eclipse.microprofile.config.Config config, BiConsumer<org.jboss.jandex.AnnotationInstance,org.jboss.jandex.Type> annotationAcceptor)
     
    (package private) void
    processIncomingForReflectiveClassPayload(org.jboss.jandex.IndexView index, org.eclipse.microprofile.config.Config config, BiConsumer<org.jboss.jandex.AnnotationInstance,org.jboss.jandex.Type> annotationAcceptor)
     
    (package private) void
    processOutgoingChannelForReflectiveClassPayload(org.jboss.jandex.IndexView index, org.eclipse.microprofile.config.Config config, BiConsumer<org.jboss.jandex.AnnotationInstance,org.jboss.jandex.Type> annotationAcceptor)
     
    (package private) void
    processOutgoingForReflectiveClassPayload(org.jboss.jandex.IndexView index, org.eclipse.microprofile.config.Config config, BiConsumer<org.jboss.jandex.AnnotationInstance,org.jboss.jandex.Type> annotationAcceptor)
     
    (package private) void
    produceReflectiveClass(io.quarkus.deployment.annotations.BuildProducer<io.quarkus.deployment.builditem.nativeimage.ReflectiveClassBuildItem> reflectiveClass, org.jboss.jandex.Type type)
     
    void
    reflectiveValueSerializerPayload(io.quarkus.deployment.builditem.CombinedIndexBuildItem combinedIndex, io.quarkus.deployment.annotations.BuildProducer<io.quarkus.deployment.builditem.nativeimage.ReflectiveClassBuildItem> reflectiveClass)
     

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Field Details

  • Constructor Details

    • SmallRyeReactiveMessagingKafkaProcessor

      public SmallRyeReactiveMessagingKafkaProcessor()

  • Method Details

    • feature

      io.quarkus.deployment.builditem.FeatureBuildItem feature()

    • build

      public void build(io.quarkus.deployment.annotations.BuildProducer<io.quarkus.deployment.builditem.nativeimage.ReflectiveClassBuildItem> reflectiveClass, io.quarkus.deployment.annotations.BuildProducer<io.quarkus.arc.deployment.AdditionalBeanBuildItem> additionalBean)

    • ignoreDuplicateJmxRegistrationInDevAndTestModes

      public void ignoreDuplicateJmxRegistrationInDevAndTestModes(io.quarkus.deployment.builditem.LaunchModeBuildItem launchMode, io.quarkus.deployment.annotations.BuildProducer<io.quarkus.deployment.logging.LogCleanupFilterBuildItem> log)

    • hasStateStoreConfig

      static boolean hasStateStoreConfig(String stateStoreName, org.eclipse.microprofile.config.Config config)

    • hasDLQConfig

      static boolean hasDLQConfig(String channelName, org.eclipse.microprofile.config.Config config)

    • checkpointRedis

      public void checkpointRedis(io.quarkus.deployment.annotations.BuildProducer<io.quarkus.arc.deployment.AdditionalBeanBuildItem> additionalBean, io.quarkus.deployment.annotations.BuildProducer<io.quarkus.deployment.builditem.nativeimage.ReflectiveClassBuildItem> reflectiveClass, io.quarkus.deployment.Capabilities capabilities)

    • checkpointHibernateReactive

      public void checkpointHibernateReactive(io.quarkus.deployment.annotations.BuildProducer<io.quarkus.arc.deployment.AdditionalBeanBuildItem> additionalBean, io.quarkus.deployment.Capabilities capabilities)

    • checkpointHibernateOrm

      public void checkpointHibernateOrm(io.quarkus.deployment.annotations.BuildProducer<io.quarkus.arc.deployment.AdditionalBeanBuildItem> additionalBean, io.quarkus.deployment.Capabilities capabilities)

    • additionalJpaModel

      public void additionalJpaModel(io.quarkus.deployment.annotations.BuildProducer<io.quarkus.hibernate.orm.deployment.spi.AdditionalJpaModelBuildItem> additionalJpaModel)

    • defaultChannelConfiguration

      public void defaultChannelConfiguration(io.quarkus.deployment.builditem.LaunchModeBuildItem launchMode, ReactiveMessagingKafkaBuildTimeConfig buildTimeConfig, io.quarkus.deployment.builditem.CombinedIndexBuildItem combinedIndex, List<io.quarkus.smallrye.reactivemessaging.deployment.items.ConnectorManagedChannelBuildItem> channelsManagedByConnectors, io.quarkus.deployment.annotations.BuildProducer<io.quarkus.deployment.builditem.RunTimeConfigurationDefaultBuildItem> defaultConfigProducer, io.quarkus.deployment.annotations.BuildProducer<io.quarkus.deployment.builditem.GeneratedClassBuildItem> generatedClass, io.quarkus.deployment.annotations.BuildProducer<io.quarkus.deployment.builditem.nativeimage.ReflectiveClassBuildItem> reflection)
      Handles the serializer/deserializer detection and whether the graceful shutdown should be used in dev mode.

    • disableGracefulShutdown

      void disableGracefulShutdown(List<io.quarkus.smallrye.reactivemessaging.deployment.items.ConnectorManagedChannelBuildItem> channelsManagedByConnectors, io.quarkus.deployment.annotations.BuildProducer<io.quarkus.deployment.builditem.RunTimeConfigurationDefaultBuildItem> defaultConfigProducer, DefaultSerdeDiscoveryState discoveryState)

    • discoverDefaultSerdeConfig

      void discoverDefaultSerdeConfig(DefaultSerdeDiscoveryState discovery, List<io.quarkus.smallrye.reactivemessaging.deployment.items.ConnectorManagedChannelBuildItem> channelsManagedByConnectors, io.quarkus.deployment.annotations.BuildProducer<io.quarkus.deployment.builditem.RunTimeConfigurationDefaultBuildItem> config, io.quarkus.deployment.annotations.BuildProducer<io.quarkus.deployment.builditem.GeneratedClassBuildItem> generatedClass, io.quarkus.deployment.annotations.BuildProducer<io.quarkus.deployment.builditem.nativeimage.ReflectiveClassBuildItem> reflection)

    • reflectiveValueSerializerPayload

      public void reflectiveValueSerializerPayload(io.quarkus.deployment.builditem.CombinedIndexBuildItem combinedIndex, io.quarkus.deployment.annotations.BuildProducer<io.quarkus.deployment.builditem.nativeimage.ReflectiveClassBuildItem> reflectiveClass)

    • produceReflectiveClass

      void produceReflectiveClass(io.quarkus.deployment.annotations.BuildProducer<io.quarkus.deployment.builditem.nativeimage.ReflectiveClassBuildItem> reflectiveClass, org.jboss.jandex.Type type)

    • processOutgoingForReflectiveClassPayload

      void processOutgoingForReflectiveClassPayload(org.jboss.jandex.IndexView index, org.eclipse.microprofile.config.Config config, BiConsumer<org.jboss.jandex.AnnotationInstance,org.jboss.jandex.Type> annotationAcceptor)

    • processOutgoingChannelForReflectiveClassPayload

      void processOutgoingChannelForReflectiveClassPayload(org.jboss.jandex.IndexView index, org.eclipse.microprofile.config.Config config, BiConsumer<org.jboss.jandex.AnnotationInstance,org.jboss.jandex.Type> annotationAcceptor)

    • processIncomingForReflectiveClassPayload

      void processIncomingForReflectiveClassPayload(org.jboss.jandex.IndexView index, org.eclipse.microprofile.config.Config config, BiConsumer<org.jboss.jandex.AnnotationInstance,org.jboss.jandex.Type> annotationAcceptor)

    • processIncomingChannelForReflectiveClassPayload

      void processIncomingChannelForReflectiveClassPayload(org.jboss.jandex.IndexView index, org.eclipse.microprofile.config.Config config, BiConsumer<org.jboss.jandex.AnnotationInstance,org.jboss.jandex.Type> annotationAcceptor)