Package io.quarkus.smallrye.reactivemessaging.deployment

Class SmallRyeReactiveMessagingProcessor

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

  • Nested Class Summary

    Nested Classes
    Modifier and Type
    Class
    Description
    static final class 
    SmallRyeReactiveMessagingProcessor.CoroutineConfigurationBuildItem
     

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    (package private) static final String
    DEFAULT_VIRTUAL_THREADS_MAX_CONCURRENCY
     
    (package private) static final String
    INVOKER_SUFFIX
     

  • Constructor Summary

    Constructors
    Constructor
    Description
    SmallRyeReactiveMessagingProcessor()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    (package private) void
    beans(io.quarkus.deployment.annotations.BuildProducer<io.quarkus.arc.deployment.AdditionalBeanBuildItem> additionalBean, ReactiveMessagingBuildTimeConfig buildTimeConfig)
     
    void
    build(io.quarkus.smallrye.reactivemessaging.runtime.SmallRyeReactiveMessagingRecorder recorder, io.quarkus.deployment.builditem.LaunchModeBuildItem launchMode, io.quarkus.deployment.recording.RecorderContext recorderContext, io.quarkus.deployment.annotations.BuildProducer<io.quarkus.arc.deployment.SyntheticBeanBuildItem> syntheticBeans, List<MediatorBuildItem> mediatorMethods, List<ConnectorManagedChannelBuildItem> connectorManagedChannels, List<InjectedEmitterBuildItem> emitterFields, List<InjectedChannelBuildItem> channelFields, io.quarkus.deployment.annotations.BuildProducer<io.quarkus.deployment.builditem.GeneratedClassBuildItem> generatedClass, io.quarkus.deployment.annotations.BuildProducer<io.quarkus.deployment.builditem.nativeimage.ReflectiveClassBuildItem> reflectiveClass, io.quarkus.deployment.annotations.BuildProducer<io.quarkus.deployment.builditem.RunTimeConfigurationDefaultBuildItem> defaultConfig, io.quarkus.smallrye.reactivemessaging.runtime.ReactiveMessagingConfiguration conf)
     
    (package private) void
    configCustomizer(io.quarkus.deployment.annotations.BuildProducer<io.quarkus.deployment.builditem.nativeimage.ServiceProviderBuildItem> serviceProvider)
     
    (package private) boolean
    consumesFromConnector(org.jboss.jandex.MethodInfo methodInfo, Set<String> connectorManagedChannels)
     
    (package private) void
    devmodeSupport(io.quarkus.deployment.builditem.CombinedIndexBuildItem index, io.quarkus.deployment.annotations.BuildProducer<io.quarkus.arc.deployment.AdditionalBeanBuildItem> beans, io.quarkus.deployment.annotations.BuildProducer<io.quarkus.arc.deployment.AnnotationsTransformerBuildItem> transformations)
     
    void
    disableObservation(io.quarkus.deployment.annotations.BuildProducer<io.quarkus.deployment.builditem.RunTimeConfigurationDefaultBuildItem> runtimeConfigProducer)
     
    (package private) void
    duplicatedContextSupport(io.quarkus.deployment.builditem.CombinedIndexBuildItem index, io.quarkus.deployment.annotations.BuildProducer<io.quarkus.arc.deployment.AdditionalBeanBuildItem> beans, io.quarkus.deployment.annotations.BuildProducer<io.quarkus.arc.deployment.AnnotationsTransformerBuildItem> transformations)
     
    void
    enableHealth(ReactiveMessagingBuildTimeConfig buildTimeConfig, io.quarkus.deployment.annotations.BuildProducer<io.quarkus.smallrye.health.deployment.spi.HealthBuildItem> producer, io.quarkus.deployment.annotations.BuildProducer<io.quarkus.arc.deployment.AdditionalBeanBuildItem> beans, io.quarkus.deployment.annotations.BuildProducer<io.quarkus.arc.deployment.AnnotationsTransformerBuildItem> transformations)
     
    io.quarkus.arc.deployment.AnnotationsTransformerBuildItem
    enableMetrics(Optional<io.quarkus.deployment.metrics.MetricsCapabilityBuildItem> metricsCapability, io.quarkus.smallrye.reactivemessaging.runtime.ReactiveMessagingConfiguration configuration)
     
    (package private) io.quarkus.deployment.builditem.FeatureBuildItem
    feature()
     
    (package private) void
    produceCoroutineScope(SmallRyeReactiveMessagingProcessor.CoroutineConfigurationBuildItem coroutineConfigurationBuildItem, io.quarkus.deployment.annotations.BuildProducer<io.quarkus.arc.deployment.AdditionalBeanBuildItem> buildItemBuildProducer)
     
    (package private) SmallRyeReactiveMessagingProcessor.CoroutineConfigurationBuildItem
    producesCoroutineConfiguration()
     
    List<io.quarkus.arc.deployment.UnremovableBeanBuildItem>
    removalExclusions()
     
    (package private) io.quarkus.arc.deployment.AnnotationsTransformerBuildItem
    transformBeanScope(io.quarkus.arc.deployment.BeanArchiveIndexBuildItem index, io.quarkus.arc.deployment.CustomScopeAnnotationsBuildItem scopes)
     

    Methods inherited from class java.lang.Object

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

  • Field Details

  • Constructor Details

    • SmallRyeReactiveMessagingProcessor

      public SmallRyeReactiveMessagingProcessor()

  • Method Details

    • feature

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

    • beans

      void beans(io.quarkus.deployment.annotations.BuildProducer<io.quarkus.arc.deployment.AdditionalBeanBuildItem> additionalBean, ReactiveMessagingBuildTimeConfig buildTimeConfig)

    • transformBeanScope

      io.quarkus.arc.deployment.AnnotationsTransformerBuildItem transformBeanScope(io.quarkus.arc.deployment.BeanArchiveIndexBuildItem index, io.quarkus.arc.deployment.CustomScopeAnnotationsBuildItem scopes)

    • removalExclusions

      public List<io.quarkus.arc.deployment.UnremovableBeanBuildItem> removalExclusions()

    • enableMetrics

      public io.quarkus.arc.deployment.AnnotationsTransformerBuildItem enableMetrics(Optional<io.quarkus.deployment.metrics.MetricsCapabilityBuildItem> metricsCapability, io.quarkus.smallrye.reactivemessaging.runtime.ReactiveMessagingConfiguration configuration)

    • disableObservation

      public void disableObservation(io.quarkus.deployment.annotations.BuildProducer<io.quarkus.deployment.builditem.RunTimeConfigurationDefaultBuildItem> runtimeConfigProducer)

    • enableHealth

      public void enableHealth(ReactiveMessagingBuildTimeConfig buildTimeConfig, io.quarkus.deployment.annotations.BuildProducer<io.quarkus.smallrye.health.deployment.spi.HealthBuildItem> producer, io.quarkus.deployment.annotations.BuildProducer<io.quarkus.arc.deployment.AdditionalBeanBuildItem> beans, io.quarkus.deployment.annotations.BuildProducer<io.quarkus.arc.deployment.AnnotationsTransformerBuildItem> transformations)

    • build

      public void build(io.quarkus.smallrye.reactivemessaging.runtime.SmallRyeReactiveMessagingRecorder recorder, io.quarkus.deployment.builditem.LaunchModeBuildItem launchMode, io.quarkus.deployment.recording.RecorderContext recorderContext, io.quarkus.deployment.annotations.BuildProducer<io.quarkus.arc.deployment.SyntheticBeanBuildItem> syntheticBeans, List<MediatorBuildItem> mediatorMethods, List<ConnectorManagedChannelBuildItem> connectorManagedChannels, List<InjectedEmitterBuildItem> emitterFields, List<InjectedChannelBuildItem> channelFields, io.quarkus.deployment.annotations.BuildProducer<io.quarkus.deployment.builditem.GeneratedClassBuildItem> generatedClass, io.quarkus.deployment.annotations.BuildProducer<io.quarkus.deployment.builditem.nativeimage.ReflectiveClassBuildItem> reflectiveClass, io.quarkus.deployment.annotations.BuildProducer<io.quarkus.deployment.builditem.RunTimeConfigurationDefaultBuildItem> defaultConfig, io.quarkus.smallrye.reactivemessaging.runtime.ReactiveMessagingConfiguration conf)

    • devmodeSupport

      void devmodeSupport(io.quarkus.deployment.builditem.CombinedIndexBuildItem index, io.quarkus.deployment.annotations.BuildProducer<io.quarkus.arc.deployment.AdditionalBeanBuildItem> beans, io.quarkus.deployment.annotations.BuildProducer<io.quarkus.arc.deployment.AnnotationsTransformerBuildItem> transformations)

    • producesCoroutineConfiguration

      SmallRyeReactiveMessagingProcessor.CoroutineConfigurationBuildItem producesCoroutineConfiguration()

    • produceCoroutineScope

      void produceCoroutineScope(SmallRyeReactiveMessagingProcessor.CoroutineConfigurationBuildItem coroutineConfigurationBuildItem, io.quarkus.deployment.annotations.BuildProducer<io.quarkus.arc.deployment.AdditionalBeanBuildItem> buildItemBuildProducer)

    • configCustomizer

      void configCustomizer(io.quarkus.deployment.annotations.BuildProducer<io.quarkus.deployment.builditem.nativeimage.ServiceProviderBuildItem> serviceProvider)

    • duplicatedContextSupport

      void duplicatedContextSupport(io.quarkus.deployment.builditem.CombinedIndexBuildItem index, io.quarkus.deployment.annotations.BuildProducer<io.quarkus.arc.deployment.AdditionalBeanBuildItem> beans, io.quarkus.deployment.annotations.BuildProducer<io.quarkus.arc.deployment.AnnotationsTransformerBuildItem> transformations)

    • consumesFromConnector

      boolean consumesFromConnector(org.jboss.jandex.MethodInfo methodInfo, Set<String> connectorManagedChannels)