Package io.quarkus.smallrye.reactivemessaging.pulsar.deployment

Class PulsarSchemaDiscoveryProcessor

java.lang.Object
io.quarkus.smallrye.reactivemessaging.pulsar.deployment.PulsarSchemaDiscoveryProcessor
public class PulsarSchemaDiscoveryProcessor extends Object

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    (package private) static org.jboss.logging.Logger
    log
     

  • Constructor Summary

    Constructors
    Constructor
    Description
    PulsarSchemaDiscoveryProcessor()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    defaultChannelConfiguration(ReactiveMessagingPulsarBuildTimeConfig 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.arc.deployment.SyntheticBeanBuildItem> syntheticBean, io.quarkus.deployment.recording.RecorderContext recorderContext, io.quarkus.pulsar.SchemaProviderRecorder recorder)
    Handles the serializer/deserializer detection and whether the graceful shutdown should be used in dev mode.
    (package private) void
    discoverDefaultSerdeConfig(DefaultSchemaDiscoveryState discovery, List<io.quarkus.smallrye.reactivemessaging.deployment.items.ConnectorManagedChannelBuildItem> channelsManagedByConnectors, io.quarkus.deployment.annotations.BuildProducer<io.quarkus.deployment.builditem.RunTimeConfigurationDefaultBuildItem> config, SyntheticBeanBuilder syntheticBean)
     

    Methods inherited from class java.lang.Object

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

  • Field Details

    • log

      static org.jboss.logging.Logger log

  • Constructor Details

    • PulsarSchemaDiscoveryProcessor

      public PulsarSchemaDiscoveryProcessor()

  • Method Details

    • defaultChannelConfiguration

      public void defaultChannelConfiguration(ReactiveMessagingPulsarBuildTimeConfig 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.arc.deployment.SyntheticBeanBuildItem> syntheticBean, io.quarkus.deployment.recording.RecorderContext recorderContext, io.quarkus.pulsar.SchemaProviderRecorder recorder)
      Handles the serializer/deserializer detection and whether the graceful shutdown should be used in dev mode.

    • discoverDefaultSerdeConfig

      void discoverDefaultSerdeConfig(DefaultSchemaDiscoveryState discovery, List<io.quarkus.smallrye.reactivemessaging.deployment.items.ConnectorManagedChannelBuildItem> channelsManagedByConnectors, io.quarkus.deployment.annotations.BuildProducer<io.quarkus.deployment.builditem.RunTimeConfigurationDefaultBuildItem> config, SyntheticBeanBuilder syntheticBean)