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

Class DefaultSchemaDiscoveryState

java.lang.Object

io.quarkus.smallrye.reactivemessaging.pulsar.deployment.DefaultSchemaDiscoveryState

class DefaultSchemaDiscoveryState
extends Object

Constructor Summary

Constructors

Constructor	Description
DefaultSchemaDiscoveryState(org.jboss.jandex.IndexView index)

Method Summary

Modifier and Type	Method	Description
(package private) List<org.jboss.jandex.AnnotationInstance>	findAnnotationsOnInjectionPoints(org.jboss.jandex.DotName annotation)
(package private) List<org.jboss.jandex.AnnotationInstance>	findAnnotationsOnMethods(org.jboss.jandex.DotName annotation)
(package private) List<org.jboss.jandex.ClassInfo>	findImplementedSchemaWithIdentifier(String identifier)
(package private) List<org.jboss.jandex.AnnotationInstance>	findProvidedSchemaWithIdentifier(String identifier)
(package private) List<org.jboss.jandex.AnnotationInstance>	findRepeatableAnnotationsOnMethods(org.jboss.jandex.DotName annotation)
(package private) org.eclipse.microprofile.config.Config	getConfig()
(package private) boolean	hasObjectMapperConfigSchema(org.jboss.jandex.Type type, String channelName, boolean incoming)
(package private) void	ifNotYetConfigured(String key, Runnable runnable)
(package private) boolean	isAvroGenerated(org.jboss.jandex.DotName className)
(package private) boolean	isProtobufGenerated(org.jboss.jandex.DotName className)
(package private) boolean	isPulsarConnector(List<io.quarkus.smallrye.reactivemessaging.deployment.items.ConnectorManagedChannelBuildItem> channelsManagedByConnectors, boolean incoming, String channelName)
(package private) boolean	shouldNotConfigure(String key)

Methods inherited from class java.lang.Object

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

Constructor Details

DefaultSchemaDiscoveryState

DefaultSchemaDiscoveryState(org.jboss.jandex.IndexView index)

Method Details

getConfig

org.eclipse.microprofile.config.Config getConfig()

isPulsarConnector

boolean isPulsarConnector(List<io.quarkus.smallrye.reactivemessaging.deployment.items.ConnectorManagedChannelBuildItem> channelsManagedByConnectors,
 boolean incoming,
 String channelName)

shouldNotConfigure

boolean shouldNotConfigure(String key)

ifNotYetConfigured

void ifNotYetConfigured(String key,
 Runnable runnable)

isAvroGenerated

boolean isAvroGenerated(org.jboss.jandex.DotName className)

isProtobufGenerated

boolean isProtobufGenerated(org.jboss.jandex.DotName className)

hasObjectMapperConfigSchema

boolean hasObjectMapperConfigSchema(org.jboss.jandex.Type type,
 String channelName,
 boolean incoming)

findAnnotationsOnMethods

List<org.jboss.jandex.AnnotationInstance> findAnnotationsOnMethods(org.jboss.jandex.DotName annotation)

findRepeatableAnnotationsOnMethods

List<org.jboss.jandex.AnnotationInstance> findRepeatableAnnotationsOnMethods(org.jboss.jandex.DotName annotation)

findAnnotationsOnInjectionPoints

List<org.jboss.jandex.AnnotationInstance> findAnnotationsOnInjectionPoints(org.jboss.jandex.DotName annotation)

findProvidedSchemaWithIdentifier

List<org.jboss.jandex.AnnotationInstance> findProvidedSchemaWithIdentifier(String identifier)

findImplementedSchemaWithIdentifier

List<org.jboss.jandex.ClassInfo> findImplementedSchemaWithIdentifier(String identifier)