A B C D E F G H I J K L M N O P R S T U V W
All Classes All Packages

A

AbstractMediator - Class in io.smallrye.reactive.messaging

AbstractMediator(MediatorConfiguration) - Constructor for class io.smallrye.reactive.messaging.AbstractMediator

accept(MultiEmitter<? super Message<?>>) - Method in class io.smallrye.reactive.messaging.gcp.pubsub.PubSubSource

ack() - Method in class io.smallrye.reactive.messaging.amqp.AmqpMessage

ack() - Method in class io.smallrye.reactive.messaging.amqp.OutgoingAmqpMessage

ack() - Method in class io.smallrye.reactive.messaging.aws.sns.SnsMessage

ack() - Method in class io.smallrye.reactive.messaging.eventbus.EventBusMessage

ack() - Method in class io.smallrye.reactive.messaging.gcp.pubsub.PubSubMessage

ack() - Method in class io.smallrye.reactive.messaging.http.HttpMessage

ack() - Method in class io.smallrye.reactive.messaging.jms.IncomingJmsMessage

ack() - Method in class io.smallrye.reactive.messaging.kafka.IncomingKafkaRecord

ack() - Method in class io.smallrye.reactive.messaging.kafka.OutgoingKafkaRecord

ack() - Method in class io.smallrye.reactive.messaging.mqtt.SendingMqttMessage

ack() - Method in class io.smallrye.reactive.messaging.mqtt.server.MqttMessage

ack() - Method in interface org.eclipse.microprofile.reactive.messaging.Message

Acknowledge this message.

Acknowledgment - Annotation Type in org.eclipse.microprofile.reactive.messaging

Configure the acknowledgement policy for the given @Incoming.

Acknowledgment.Strategy - Enum in org.eclipse.microprofile.reactive.messaging

acme - package acme

add(int[], int) - Static method in class io.smallrye.reactive.messaging.helpers.TypeUtils

addAnalyzed(Collection<? extends MediatorConfiguration>) - Method in class io.smallrye.reactive.messaging.extension.MediatorManager

addMetadata(Object) - Method in interface org.eclipse.microprofile.reactive.messaging.Message

Creates a new instance of Message with the current metadata, plus the given one.

alias() - Method in annotation type io.smallrye.reactive.messaging.annotations.ConnectorAttribute

AmqpConfiguration - Class in acme

AmqpConfiguration() - Constructor for class acme.AmqpConfiguration

AmqpConnector - Class in io.smallrye.reactive.messaging.amqp

AmqpConnectorCommonConfiguration - Class in io.smallrye.reactive.messaging.amqp

Extracts the common configuration for the smallrye-amqp connector.

AmqpConnectorCommonConfiguration(Config) - Constructor for class io.smallrye.reactive.messaging.amqp.AmqpConnectorCommonConfiguration

Creates a new AmqpConnectorCommonConfiguration.

AmqpConnectorIncomingConfiguration - Class in io.smallrye.reactive.messaging.amqp

Extract the incoming configuration for the smallrye-amqp connector.

AmqpConnectorIncomingConfiguration(Config) - Constructor for class io.smallrye.reactive.messaging.amqp.AmqpConnectorIncomingConfiguration

Creates a new AmqpConnectorIncomingConfiguration.

AmqpConnectorOutgoingConfiguration - Class in io.smallrye.reactive.messaging.amqp

Extract the outgoing configuration for the smallrye-amqp connector.

AmqpConnectorOutgoingConfiguration(Config) - Constructor for class io.smallrye.reactive.messaging.amqp.AmqpConnectorOutgoingConfiguration

Creates a new AmqpConnectorOutgoingConfiguration.

AmqpMessage<T> - Class in io.smallrye.reactive.messaging.amqp

AmqpMessage(AmqpMessage) - Constructor for class io.smallrye.reactive.messaging.amqp.AmqpMessage

AmqpMessage(AmqpMessage) - Constructor for class io.smallrye.reactive.messaging.amqp.AmqpMessage

AmqpMessageBuilder<T> - Class in io.smallrye.reactive.messaging.amqp

amqpMetadata - Variable in class io.smallrye.reactive.messaging.amqp.AmqpMessage

analyze(Class<?>, Bean<T>) - Method in class io.smallrye.reactive.messaging.extension.MediatorManager

analyze(AnnotatedType<T>, Bean<T>) - Method in class io.smallrye.reactive.messaging.extension.MediatorManager

analyzeWorker(AnnotatedType<T>) - Method in class io.smallrye.reactive.messaging.connectors.WorkerPoolRegistry

anOutgoingAmqpMetadata() - Static method in class io.smallrye.reactive.messaging.amqp.OutgoingAmqpMetadata.OutgoingAmqpMetadataBuilder

APPLICATION_JSON - Static variable in class io.smallrye.reactive.messaging.amqp.AmqpMessage

apply(Message) - Method in interface io.smallrye.reactive.messaging.jms.impl.JmsTask

apply(Message) - Method in class io.smallrye.reactive.messaging.jms.JmsPropertiesBuilder.Property

asJsonObject(Config) - Static method in class io.smallrye.reactive.messaging.http.JsonHelper

asJsonObject(Config) - Static method in class io.smallrye.reactive.messaging.kafka.impl.JsonHelper

Assignable - io.smallrye.reactive.messaging.MediatorConfigurationSupport.GenericTypeAssignable.Result

awssns - package awssns

B

BeanUsingAnEmitter - Class in acme

BeanUsingAnEmitter - Class in awssns

BeanUsingAnEmitter - Class in gcp.pubsub

BeanUsingAnEmitter() - Constructor for class acme.BeanUsingAnEmitter

BeanUsingAnEmitter() - Constructor for class awssns.BeanUsingAnEmitter

BeanUsingAnEmitter() - Constructor for class gcp.pubsub.BeanUsingAnEmitter

Blocking - Annotation Type in io.smallrye.reactive.messaging.annotations

Identifies that a particular method performs blocking operations, and as such should be executed on separate worker.

Broadcast - Annotation Type in io.smallrye.reactive.messaging.annotations

Configure if the annotated publisher should dispatch the messages to several subscribers.

BUFFER - io.smallrye.reactive.messaging.annotations.OnOverflow.Strategy

Deprecated.

Buffers all values until the downstream consumes it.

BUFFER - org.eclipse.microprofile.reactive.messaging.OnOverflow.Strategy

Buffers all values until the downstream consumes it.

BufferSerializer - Class in io.smallrye.reactive.messaging.http.converters

BufferSerializer() - Constructor for class io.smallrye.reactive.messaging.http.converters.BufferSerializer

bufferSize() - Method in annotation type io.smallrye.reactive.messaging.annotations.OnOverflow

Deprecated.

bufferSize() - Method in annotation type org.eclipse.microprofile.reactive.messaging.OnOverflow

build() - Method in class io.smallrye.reactive.messaging.amqp.AmqpMessageBuilder

build() - Method in class io.smallrye.reactive.messaging.amqp.OutgoingAmqpMetadata.OutgoingAmqpMetadataBuilder

build() - Method in class io.smallrye.reactive.messaging.cloudevents.CloudEventMessageBuilder

build() - Method in class io.smallrye.reactive.messaging.http.HttpMessage.HttpMessageBuilder

build() - Method in class io.smallrye.reactive.messaging.http.HttpResponseMetadata.HttpResponseMetadataBuilder

build() - Method in class io.smallrye.reactive.messaging.jms.JmsPropertiesBuilder

build() - Method in class io.smallrye.reactive.messaging.jms.OutgoingJmsMessageMetadata.OutgoingJmsMessageMetadataBuilder

build() - Method in class io.smallrye.reactive.messaging.kafka.OutgoingKafkaRecordMetadata.OutgoingKafkaRecordMetadataBuilder

build(T, AttributesImpl, Collection<ExtensionFormat>) - Method in class io.smallrye.reactive.messaging.cloudevents.CloudEventMessageBuilder

builder() - Static method in class io.smallrye.reactive.messaging.amqp.AmqpMessage

builder() - Static method in class io.smallrye.reactive.messaging.amqp.OutgoingAmqpMetadata

builder() - Static method in class io.smallrye.reactive.messaging.http.HttpMessage

builder() - Static method in class io.smallrye.reactive.messaging.http.HttpResponseMetadata

builder() - Static method in interface io.smallrye.reactive.messaging.jms.JmsProperties

Creates a builder object to create JMS Properties

builder() - Static method in class io.smallrye.reactive.messaging.jms.OutgoingJmsMessageMetadata

builder() - Static method in class io.smallrye.reactive.messaging.kafka.OutgoingKafkaRecordMetadata

ByteArraySerializer - Class in io.smallrye.reactive.messaging.http.converters

ByteArraySerializer() - Constructor for class io.smallrye.reactive.messaging.http.converters.ByteArraySerializer

ByteBufferSerializer - Class in io.smallrye.reactive.messaging.http.converters

ByteBufferSerializer() - Constructor for class io.smallrye.reactive.messaging.http.converters.ByteBufferSerializer

C

CamelConnector - Class in io.smallrye.reactive.messaging.camel

CamelConnector() - Constructor for class io.smallrye.reactive.messaging.camel.CamelConnector

CamelConnectorCommonConfiguration - Class in io.smallrye.reactive.messaging.camel

Extracts the common configuration for the smallrye-camel connector.

CamelConnectorCommonConfiguration(Config) - Constructor for class io.smallrye.reactive.messaging.camel.CamelConnectorCommonConfiguration

Creates a new CamelConnectorCommonConfiguration.

CamelConnectorIncomingConfiguration - Class in io.smallrye.reactive.messaging.camel

Extract the incoming configuration for the smallrye-camel connector.

CamelConnectorIncomingConfiguration(Config) - Constructor for class io.smallrye.reactive.messaging.camel.CamelConnectorIncomingConfiguration

Creates a new CamelConnectorIncomingConfiguration.

CamelConnectorOutgoingConfiguration - Class in io.smallrye.reactive.messaging.camel

Extract the outgoing configuration for the smallrye-camel connector.

CamelConnectorOutgoingConfiguration(Config) - Constructor for class io.smallrye.reactive.messaging.camel.CamelConnectorOutgoingConfiguration

Creates a new CamelConnectorOutgoingConfiguration.

CamelMessage<T> - Class in io.smallrye.reactive.messaging.camel

CamelMessage(Exchange) - Constructor for class io.smallrye.reactive.messaging.camel.CamelMessage

Channel - Annotation Type in io.smallrye.reactive.messaging.annotations

Deprecated.

Use Channel instead.

Channel - Annotation Type in org.eclipse.microprofile.reactive.messaging

This qualifier indicates which channel should be injected / populated.

CHANNEL_NAME_ATTRIBUTE - Static variable in interface org.eclipse.microprofile.reactive.messaging.spi.ConnectorFactory

The channel-name attribute name.

ChannelProducer - Class in io.smallrye.reactive.messaging.extension

This component computes the right object to be injected into injection point using Channel and the deprecated Channel.

ChannelProducer() - Constructor for class io.smallrye.reactive.messaging.extension.ChannelProducer

ChannelRegistar - Interface in io.smallrye.reactive.messaging

ChannelRegistry - Interface in io.smallrye.reactive.messaging

check(Class<?>, int) - Method in interface io.smallrye.reactive.messaging.MediatorConfigurationSupport.GenericTypeAssignable

ClassUtils - Class in io.smallrye.reactive.messaging.helpers

Allows checking if a class can be assigned to a variable from another class.

ClassWriter - Class in io.smallrye.reactive.messaging.connector

cleanup() - Method in class io.smallrye.reactive.messaging.jms.JmsConnector

clear() - Static method in class io.smallrye.reactive.messaging.connectors.InMemoryConnector

Switch back the channel to their original connector.

clear() - Method in interface io.smallrye.reactive.messaging.connectors.InMemorySink

Clears the list of received messages.

closeQuietly() - Method in class io.smallrye.reactive.messaging.kafka.impl.KafkaSink

closeQuietly() - Method in class io.smallrye.reactive.messaging.kafka.impl.KafkaSource

CloudEventMessage<T> - Interface in io.smallrye.reactive.messaging.cloudevents

Message extending Cloud Events.

CloudEventMessageBuilder<T> - Class in io.smallrye.reactive.messaging.cloudevents

CloudEventMessageBuilder() - Constructor for class io.smallrye.reactive.messaging.cloudevents.CloudEventMessageBuilder

CloudEventSerializer - Class in io.smallrye.reactive.messaging.http.converters

CloudEventSerializer() - Constructor for class io.smallrye.reactive.messaging.http.converters.CloudEventSerializer

CommonConfigurationClassWriter - Class in io.smallrye.reactive.messaging.connector

Generates the parent class used by the incoming and outgoing configuration classes.

CommonConfigurationClassWriter(ProcessingEnvironment) - Constructor for class io.smallrye.reactive.messaging.connector.CommonConfigurationClassWriter

complete() - Method in interface io.smallrye.reactive.messaging.annotations.Emitter

Deprecated.

Completes the stream.

complete() - Method in interface io.smallrye.reactive.messaging.connectors.InMemorySource

Sends the completion event.

complete() - Method in class io.smallrye.reactive.messaging.extension.EmitterImpl

complete() - Method in class io.smallrye.reactive.messaging.extension.LegacyEmitterImpl

complete() - Method in interface org.eclipse.microprofile.reactive.messaging.Emitter

Sends the completion event to the channel indicating that no other events will be sent afterward.

COMPLETION_STAGE_OF_MESSAGE - io.smallrye.reactive.messaging.MediatorConfiguration.Production

COMPLETION_STAGE_OF_PAYLOAD - io.smallrye.reactive.messaging.MediatorConfiguration.Production

compute(Incomings, Outgoing, Blocking) - Method in class io.smallrye.reactive.messaging.DefaultMediatorConfiguration

compute(List<Incoming>, Outgoing, Blocking) - Method in class io.smallrye.reactive.messaging.DefaultMediatorConfiguration

CONCAT - io.smallrye.reactive.messaging.annotations.Merge.Mode

Concat the sources.

config - Variable in class io.smallrye.reactive.messaging.amqp.AmqpConnectorCommonConfiguration

config - Variable in class io.smallrye.reactive.messaging.aws.sns.SnsConnectorCommonConfiguration

config - Variable in class io.smallrye.reactive.messaging.camel.CamelConnectorCommonConfiguration

config - Variable in class io.smallrye.reactive.messaging.eventbus.VertxEventBusConnectorCommonConfiguration

config - Variable in class io.smallrye.reactive.messaging.http.HttpConnectorCommonConfiguration

config - Variable in class io.smallrye.reactive.messaging.impl.ConfiguredChannelFactory

config - Variable in class io.smallrye.reactive.messaging.jms.JmsConnectorCommonConfiguration

config - Variable in class io.smallrye.reactive.messaging.kafka.KafkaConnectorCommonConfiguration

config - Variable in class io.smallrye.reactive.messaging.mqtt.MqttConnectorCommonConfiguration

config - Variable in class io.smallrye.reactive.messaging.mqtt.server.MqttServerConnectorCommonConfiguration

config() - Method in class io.smallrye.reactive.messaging.amqp.AmqpConnectorCommonConfiguration

config() - Method in class io.smallrye.reactive.messaging.aws.sns.SnsConnectorCommonConfiguration

config() - Method in class io.smallrye.reactive.messaging.camel.CamelConnectorCommonConfiguration

config() - Method in class io.smallrye.reactive.messaging.eventbus.VertxEventBusConnectorCommonConfiguration

config() - Method in class io.smallrye.reactive.messaging.http.HttpConnectorCommonConfiguration

config() - Method in class io.smallrye.reactive.messaging.jms.JmsConnectorCommonConfiguration

config() - Method in class io.smallrye.reactive.messaging.kafka.KafkaConnectorCommonConfiguration

config() - Method in class io.smallrye.reactive.messaging.mqtt.MqttConnectorCommonConfiguration

config() - Method in class io.smallrye.reactive.messaging.mqtt.server.MqttServerConnectorCommonConfiguration

configuration - Variable in class io.smallrye.reactive.messaging.AbstractMediator

configuration() - Method in class io.smallrye.reactive.messaging.AbstractMediator

ConfigurationClassWriter - Class in io.smallrye.reactive.messaging.connector

ConfigurationClassWriter(ProcessingEnvironment) - Constructor for class io.smallrye.reactive.messaging.connector.ConfigurationClassWriter

ConfigurationDocWriter - Class in io.smallrye.reactive.messaging.connector

ConfigurationDocWriter(ProcessingEnvironment) - Constructor for class io.smallrye.reactive.messaging.connector.ConfigurationDocWriter

ConfiguredChannelFactory - Class in io.smallrye.reactive.messaging.impl

Look for stream factories and get instances.

ConfiguredChannelFactory() - Constructor for class io.smallrye.reactive.messaging.impl.ConfiguredChannelFactory

ConfiguredChannelFactory(Instance<IncomingConnectorFactory>, Instance<OutgoingConnectorFactory>, Instance<Config>, Instance<ChannelRegistry>, BeanManager) - Constructor for class io.smallrye.reactive.messaging.impl.ConfiguredChannelFactory

Connector - Annotation Type in org.eclipse.microprofile.reactive.messaging.spi

Qualifier used on connector implementations to indicate the associated underlying transport.

CONNECTOR - Static variable in class io.smallrye.reactive.messaging.connectors.InMemoryConnector

CONNECTOR_ATTRIBUTE - Static variable in interface org.eclipse.microprofile.reactive.messaging.spi.ConnectorFactory

The connector attribute name.

CONNECTOR_NAME - Static variable in class io.smallrye.reactive.messaging.camel.CamelConnector

CONNECTOR_NAME - Static variable in class io.smallrye.reactive.messaging.http.HttpConnector

CONNECTOR_NAME - Static variable in class io.smallrye.reactive.messaging.jms.JmsConnector

The name of the connector: smallrye-jms

CONNECTOR_PREFIX - Static variable in interface org.eclipse.microprofile.reactive.messaging.spi.ConnectorFactory

Prefix used in the MicroProfile Config to configure properties shared by all the channels associated with a specific connector.

ConnectorAttribute - Annotation Type in io.smallrye.reactive.messaging.annotations

Annotation used to declare an attribute on the connector.

ConnectorAttribute.Direction - Enum in io.smallrye.reactive.messaging.annotations

ConnectorAttributeProcessor - Class in io.smallrye.reactive.messaging.connector

ConnectorAttributeProcessor() - Constructor for class io.smallrye.reactive.messaging.connector.ConnectorAttributeProcessor

ConnectorAttributes - Annotation Type in io.smallrye.reactive.messaging.annotations

This class is used to allow multiple ConnectorAttribute declarations.

ConnectorConfig - Class in io.smallrye.reactive.messaging.impl

Implementation of config used to configured the different messaging provider / connector.

ConnectorConfig(String, Config, String) - Constructor for class io.smallrye.reactive.messaging.impl.ConnectorConfig

ConnectorFactory - Interface in org.eclipse.microprofile.reactive.messaging.spi

Parent class for IncomingConnectorFactory and OutgoingConnectorFactory.

ConnectorLiteral - Class in org.eclipse.microprofile.reactive.messaging.spi

Supports inline instantiation of the Connector qualifier.

connectToUpstream(PublisherBuilder<? extends Message<?>>) - Method in class io.smallrye.reactive.messaging.AbstractMediator

connectToUpstream(PublisherBuilder<? extends Message<?>>) - Method in class io.smallrye.reactive.messaging.ProcessorMediator

connectToUpstream(PublisherBuilder<? extends Message<?>>) - Method in class io.smallrye.reactive.messaging.StreamTransformerMediator

connectToUpstream(PublisherBuilder<? extends Message<?>>) - Method in class io.smallrye.reactive.messaging.SubscriberMediator

consume(PubSubMessage) - Method in class gcp.pubsub.Receiver

consume(KafkaRecord<String, String>) - Method in class acme.Receiver

consume(Message<String>) - Method in class awssns.Receiver

consumption() - Method in class io.smallrye.reactive.messaging.DefaultMediatorConfiguration

consumption() - Method in interface io.smallrye.reactive.messaging.MediatorConfiguration

convert(byte[]) - Method in class io.smallrye.reactive.messaging.http.converters.ByteArraySerializer

convert(I) - Method in interface io.smallrye.reactive.messaging.http.converters.Converter

convert(CloudEventMessage) - Method in class io.smallrye.reactive.messaging.http.converters.CloudEventSerializer

convert(Buffer) - Method in class io.smallrye.reactive.messaging.http.converters.BufferSerializer

convert(JsonArray) - Method in class io.smallrye.reactive.messaging.http.converters.JsonArraySerializer

convert(JsonObject) - Method in class io.smallrye.reactive.messaging.http.converters.JsonObjectSerializer

convert(String) - Method in class io.smallrye.reactive.messaging.http.converters.StringSerializer

convert(ByteBuffer) - Method in class io.smallrye.reactive.messaging.http.converters.ByteBufferSerializer

Converter<I,O> - Interface in io.smallrye.reactive.messaging.http.converters

copy() - Method in class org.eclipse.microprofile.reactive.messaging.Metadata

Copies the current Metadata instance.

create() - Static method in class io.smallrye.reactive.messaging.http.HttpMessage.HttpMessageBuilder

create(MediatorConfiguration) - Method in class io.smallrye.reactive.messaging.MediatorFactory

D

decorate(PublisherBuilder<? extends Message<?>>) - Method in class io.smallrye.reactive.messaging.AbstractMediator

decorate(PublisherBuilder<? extends Message<?>>, String) - Method in class io.smallrye.reactive.messaging.metrics.MetricDecorator

decorate(PublisherBuilder<? extends Message<?>>, String) - Method in interface io.smallrye.reactive.messaging.PublisherDecorator

Decorate a publisher

DEFAULT_WORKER_POOL - Static variable in annotation type io.smallrye.reactive.messaging.annotations.Blocking

DefaultCloudEventMessage<T> - Class in io.smallrye.reactive.messaging.cloudevents

DefaultCloudEventMessage(CloudEventImpl<T>) - Constructor for class io.smallrye.reactive.messaging.cloudevents.DefaultCloudEventMessage

DefaultMediatorConfiguration - Class in io.smallrye.reactive.messaging

DefaultMediatorConfiguration(Method, Bean<?>) - Constructor for class io.smallrye.reactive.messaging.DefaultMediatorConfiguration

defaultValue() - Method in annotation type io.smallrye.reactive.messaging.annotations.ConnectorAttribute

defineWorker(String, String, String) - Method in class io.smallrye.reactive.messaging.connectors.WorkerPoolRegistry

deprecated() - Method in annotation type io.smallrye.reactive.messaging.annotations.ConnectorAttribute

description() - Method in annotation type io.smallrye.reactive.messaging.annotations.ConnectorAttribute

destroy() - Method in class io.smallrye.reactive.messaging.gcp.pubsub.PubSubManager

destroy(Object) - Method in class io.smallrye.reactive.messaging.gcp.pubsub.PubSubConnector

determineShape(List<?>, Object) - Method in class io.smallrye.reactive.messaging.MediatorConfigurationSupport

direction() - Method in annotation type io.smallrye.reactive.messaging.annotations.ConnectorAttribute

DROP - io.smallrye.reactive.messaging.annotations.OnOverflow.Strategy

Deprecated.

Drops the most recent value if the downstream can't keep up.

DROP - org.eclipse.microprofile.reactive.messaging.OnOverflow.Strategy

Drops the most recent value if the downstream can't keep up.

E

Emitter<T> - Interface in io.smallrye.reactive.messaging.annotations

Deprecated.

Use Emitter instead.

Emitter<T> - Interface in org.eclipse.microprofile.reactive.messaging

Interface used to feed a stream from an imperative piece of code.

EmitterImpl<T> - Class in io.smallrye.reactive.messaging.extension

Implementation of the emitter pattern.

EmitterImpl(String, String, long, long) - Constructor for class io.smallrye.reactive.messaging.extension.EmitterImpl

empty() - Static method in class org.eclipse.microprofile.reactive.messaging.Metadata

Returns an empty set of metadata.

equals(Object) - Method in class io.smallrye.reactive.messaging.gcp.pubsub.PubSubConfig

equals(Object) - Method in class io.smallrye.reactive.messaging.gcp.pubsub.PubSubMessage

equals(Type, Type) - Static method in class io.smallrye.reactive.messaging.helpers.TypeUtils

Check equality of types.

error(Exception) - Method in interface io.smallrye.reactive.messaging.annotations.Emitter

Deprecated.

Propagates an error in the stream.

error(Exception) - Method in class io.smallrye.reactive.messaging.extension.EmitterImpl

error(Exception) - Method in class io.smallrye.reactive.messaging.extension.LegacyEmitterImpl

error(Exception) - Method in interface org.eclipse.microprofile.reactive.messaging.Emitter

Sends a failure event to the channel.

EventBusMessage<T> - Class in io.smallrye.reactive.messaging.eventbus

EventBusSink - Class in io.smallrye.reactive.messaging.eventbus

executeWork(Handler<Promise<T>>, String, boolean) - Method in class io.smallrye.reactive.messaging.connectors.WorkerPoolRegistry

ExecutionHolder - Class in io.smallrye.reactive.messaging.connectors

Provides common runtime services to connectors, such as a Vertx instance, to avoid duplicating the creation and cleanup of shared components across connectors.

ExecutionHolder() - Constructor for class io.smallrye.reactive.messaging.connectors.ExecutionHolder

ExecutionHolder(Vertx) - Constructor for class io.smallrye.reactive.messaging.connectors.ExecutionHolder

ExecutionHolder(Instance<Vertx>) - Constructor for class io.smallrye.reactive.messaging.connectors.ExecutionHolder

extend(JavaArchive) - Method in class io.smallrye.reactive.messaging.tck.SmallRyeReactiveMessagingExtender

F

fail(Throwable) - Method in interface io.smallrye.reactive.messaging.connectors.InMemorySource

Sends a failure.

FAIL - io.smallrye.reactive.messaging.annotations.OnOverflow.Strategy

Deprecated.

Propagates a failure in case the downstream can't keep up.

FAIL - org.eclipse.microprofile.reactive.messaging.OnOverflow.Strategy

Propagates a failure in case the downstream can't keep up.

filter(PublisherBuilder<String>) - Method in class acme.Main

from(HttpResponseMetadata) - Method in class io.smallrye.reactive.messaging.http.HttpResponseMetadata.HttpResponseMetadataBuilder

from(Iterable<Object>) - Static method in class org.eclipse.microprofile.reactive.messaging.Metadata

from(Message<T>) - Static method in class io.smallrye.reactive.messaging.cloudevents.CloudEventMessageBuilder

from(Message<T>) - Static method in class io.smallrye.reactive.messaging.kafka.OutgoingKafkaRecord

G

gcp.pubsub - package gcp.pubsub

generate(ProcessingEnvironment, Connector, String, List<ConnectorAttribute>) - Static method in class io.smallrye.reactive.messaging.connector.CommonConfigurationClassWriter

generateAllClasses(Connector, String, List<ConnectorAttribute>, List<ConnectorAttribute>, List<ConnectorAttribute>) - Method in class io.smallrye.reactive.messaging.connector.ConfigurationClassWriter

generateIncomingDocumentation(Connector, List<ConnectorAttribute>, List<ConnectorAttribute>) - Method in class io.smallrye.reactive.messaging.connector.ConfigurationDocWriter

generateOutgoingDocumentation(Connector, List<ConnectorAttribute>, List<ConnectorAttribute>) - Method in class io.smallrye.reactive.messaging.connector.ConfigurationDocWriter

getAck() - Method in class io.smallrye.reactive.messaging.kafka.IncomingKafkaRecord

getAck() - Method in class io.smallrye.reactive.messaging.kafka.OutgoingKafkaRecord

getAck() - Method in interface org.eclipse.microprofile.reactive.messaging.Message

getAcknowledgment() - Method in class io.smallrye.reactive.messaging.DefaultMediatorConfiguration

getAcknowledgment() - Method in interface io.smallrye.reactive.messaging.MediatorConfiguration

getAckOrCompletion(Message<?>) - Method in class io.smallrye.reactive.messaging.AbstractMediator

getAcks() - Method in class io.smallrye.reactive.messaging.kafka.KafkaConnectorOutgoingConfiguration

Gets the acks value from the configuration.

getAddress() - Method in class io.smallrye.reactive.messaging.amqp.AmqpConnectorCommonConfiguration

Gets the address value from the configuration.

getAddress() - Method in class io.smallrye.reactive.messaging.amqp.AmqpMessage

getAddress() - Method in class io.smallrye.reactive.messaging.amqp.IncomingAmqpMetadata

getAddress() - Method in class io.smallrye.reactive.messaging.amqp.OutgoingAmqpMessage

getAddress() - Method in class io.smallrye.reactive.messaging.amqp.OutgoingAmqpMetadata

getAddress() - Method in class io.smallrye.reactive.messaging.eventbus.EventBusMessage

getAddress() - Method in class io.smallrye.reactive.messaging.eventbus.VertxEventBusConnectorCommonConfiguration

Gets the address value from the configuration.

getAmqpMessage() - Method in class io.smallrye.reactive.messaging.amqp.AmqpMessage

getApplicationProperties() - Method in class io.smallrye.reactive.messaging.amqp.AmqpMessage

getApplicationProperties() - Method in class io.smallrye.reactive.messaging.amqp.OutgoingAmqpMessage

getAppUrl() - Method in class io.smallrye.reactive.messaging.aws.sns.SnsConnectorIncomingConfiguration

Gets the app-url value from the configuration.

getAttributes() - Method in class io.smallrye.reactive.messaging.cloudevents.DefaultCloudEventMessage

getAutoAcknowledgement() - Method in class io.smallrye.reactive.messaging.amqp.AmqpConnectorIncomingConfiguration

Gets the auto-acknowledgement value from the configuration.

getAutoCleanSession() - Method in class io.smallrye.reactive.messaging.mqtt.MqttConnectorCommonConfiguration

Gets the auto-clean-session value from the configuration.

getAutoGeneratedClientId() - Method in class io.smallrye.reactive.messaging.mqtt.MqttConnectorCommonConfiguration

Gets the auto-generated-client-id value from the configuration.

getAutoGeneratedClientId() - Method in class io.smallrye.reactive.messaging.mqtt.server.MqttServerConnectorIncomingConfiguration

Gets the auto-generated-client-id value from the configuration.

getAutoKeepAlive() - Method in class io.smallrye.reactive.messaging.mqtt.MqttConnectorCommonConfiguration

Gets the auto-keep-alive value from the configuration.

getAutoOffsetReset() - Method in class io.smallrye.reactive.messaging.kafka.KafkaConnectorIncomingConfiguration

Gets the auto.offset.reset value from the configuration.

getBean() - Method in class io.smallrye.reactive.messaging.DefaultMediatorConfiguration

getBean() - Method in interface io.smallrye.reactive.messaging.MediatorConfiguration

getBody() - Method in class io.smallrye.reactive.messaging.amqp.AmqpMessage

getBody(Class<X>) - Method in class io.smallrye.reactive.messaging.jms.IncomingJmsMessageMetadata

getBooleanProperty(String) - Method in class io.smallrye.reactive.messaging.jms.impl.ImmutableJmsProperties

getBooleanProperty(String) - Method in class io.smallrye.reactive.messaging.jms.IncomingJmsMessageMetadata

getBooleanProperty(String) - Method in interface io.smallrye.reactive.messaging.jms.JmsProperties

Returns the value of the boolean property with the specified name.

getBooleanProperty(String) - Method in class io.smallrye.reactive.messaging.jms.JmsPropertiesBuilder.OutgoingJmsProperties

getBootstrapServers() - Method in class io.smallrye.reactive.messaging.kafka.KafkaConnectorCommonConfiguration

Gets the bootstrap.servers value from the configuration.

getBroadcast() - Method in class io.smallrye.reactive.messaging.amqp.AmqpConnectorIncomingConfiguration

Gets the broadcast value from the configuration.

getBroadcast() - Method in class io.smallrye.reactive.messaging.aws.sns.SnsConnectorIncomingConfiguration

Gets the broadcast value from the configuration.

getBroadcast() - Method in class io.smallrye.reactive.messaging.DefaultMediatorConfiguration

getBroadcast() - Method in class io.smallrye.reactive.messaging.eventbus.VertxEventBusConnectorIncomingConfiguration

Gets the broadcast value from the configuration.

getBroadcast() - Method in class io.smallrye.reactive.messaging.jms.JmsConnectorIncomingConfiguration

Gets the broadcast value from the configuration.

getBroadcast() - Method in class io.smallrye.reactive.messaging.kafka.KafkaConnectorIncomingConfiguration

Gets the broadcast value from the configuration.

getBroadcast() - Method in interface io.smallrye.reactive.messaging.MediatorConfiguration

getBroadcast() - Method in class io.smallrye.reactive.messaging.mqtt.MqttConnectorIncomingConfiguration

Gets the broadcast value from the configuration.

getBroadcast() - Method in class io.smallrye.reactive.messaging.mqtt.server.MqttServerConnectorIncomingConfiguration

Gets the broadcast value from the configuration.

getBufferMemory() - Method in class io.smallrye.reactive.messaging.kafka.KafkaConnectorOutgoingConfiguration

Gets the buffer.memory value from the configuration.

getByteProperty(String) - Method in class io.smallrye.reactive.messaging.jms.impl.ImmutableJmsProperties

getByteProperty(String) - Method in class io.smallrye.reactive.messaging.jms.IncomingJmsMessageMetadata

getByteProperty(String) - Method in interface io.smallrye.reactive.messaging.jms.JmsProperties

Returns the value of the byte property with the specified name.

getByteProperty(String) - Method in class io.smallrye.reactive.messaging.jms.JmsPropertiesBuilder.OutgoingJmsProperties

getCamelReactive() - Method in class io.smallrye.reactive.messaging.camel.CamelConnector

getChannel() - Method in class io.smallrye.reactive.messaging.amqp.AmqpConnectorCommonConfiguration

getChannel() - Method in class io.smallrye.reactive.messaging.aws.sns.SnsConnectorCommonConfiguration

getChannel() - Method in class io.smallrye.reactive.messaging.camel.CamelConnectorCommonConfiguration

getChannel() - Method in class io.smallrye.reactive.messaging.eventbus.VertxEventBusConnectorCommonConfiguration

getChannel() - Method in class io.smallrye.reactive.messaging.http.HttpConnectorCommonConfiguration

getChannel() - Method in class io.smallrye.reactive.messaging.jms.JmsConnectorCommonConfiguration

getChannel() - Method in class io.smallrye.reactive.messaging.kafka.KafkaConnectorCommonConfiguration

getChannel() - Method in class io.smallrye.reactive.messaging.mqtt.MqttConnectorCommonConfiguration

getChannel() - Method in class io.smallrye.reactive.messaging.mqtt.server.MqttServerConnectorCommonConfiguration

getClientId() - Method in class io.smallrye.reactive.messaging.jms.JmsConnectorCommonConfiguration

Gets the client-id value from the configuration.

getClientId() - Method in class io.smallrye.reactive.messaging.mqtt.MqttConnectorCommonConfiguration

Gets the client-id value from the configuration.

getClientId() - Method in class io.smallrye.reactive.messaging.mqtt.server.MqttMessage

getClientOptionsName() - Method in class io.smallrye.reactive.messaging.amqp.AmqpConnectorCommonConfiguration

Gets the client-options-name value from the configuration.

getCodec() - Method in class io.smallrye.reactive.messaging.eventbus.VertxEventBusConnectorOutgoingConfiguration

Gets the codec value from the configuration.

getComputedSubscriber() - Method in class io.smallrye.reactive.messaging.AbstractMediator

getComputedSubscriber() - Method in class io.smallrye.reactive.messaging.SubscriberMediator

getConfigSources() - Method in class io.smallrye.reactive.messaging.impl.ConnectorConfig

getConfiguration() - Method in class io.smallrye.reactive.messaging.AbstractMediator

getConnectionFactoryName() - Method in class io.smallrye.reactive.messaging.jms.JmsConnectorCommonConfiguration

Gets the connection-factory-name value from the configuration.

getConnectTimeout() - Method in class io.smallrye.reactive.messaging.amqp.AmqpConnectorCommonConfiguration

Gets the connect-timeout value from the configuration.

getConnectTimeoutSeconds() - Method in class io.smallrye.reactive.messaging.mqtt.MqttConnectorCommonConfiguration

Gets the connect-timeout-seconds value from the configuration.

getConsumption() - Method in class io.smallrye.reactive.messaging.MediatorConfigurationSupport.ValidationOutput

getContainerId() - Method in class io.smallrye.reactive.messaging.amqp.AmqpConnectorCommonConfiguration

Gets the containerId value from the configuration.

getContentEncoding() - Method in class io.smallrye.reactive.messaging.amqp.AmqpMessage

getContentEncoding() - Method in class io.smallrye.reactive.messaging.amqp.IncomingAmqpMetadata

getContentEncoding() - Method in class io.smallrye.reactive.messaging.amqp.OutgoingAmqpMessage

getContentEncoding() - Method in class io.smallrye.reactive.messaging.amqp.OutgoingAmqpMetadata

getContentType() - Method in class io.smallrye.reactive.messaging.amqp.AmqpMessage

getContentType() - Method in class io.smallrye.reactive.messaging.amqp.IncomingAmqpMetadata

getContentType() - Method in class io.smallrye.reactive.messaging.amqp.OutgoingAmqpMessage

getContentType() - Method in class io.smallrye.reactive.messaging.amqp.OutgoingAmqpMetadata

getConverter() - Method in class io.smallrye.reactive.messaging.http.HttpConnectorOutgoingConfiguration

Gets the converter value from the configuration.

getCorrelationId() - Method in class io.smallrye.reactive.messaging.amqp.AmqpMessage

getCorrelationId() - Method in class io.smallrye.reactive.messaging.amqp.IncomingAmqpMetadata

getCorrelationId() - Method in class io.smallrye.reactive.messaging.amqp.OutgoingAmqpMessage

getCorrelationId() - Method in class io.smallrye.reactive.messaging.amqp.OutgoingAmqpMetadata

getCorrelationId() - Method in class io.smallrye.reactive.messaging.jms.IncomingJmsMessageMetadata

getCorrelationId() - Method in class io.smallrye.reactive.messaging.jms.JmsConnectorOutgoingConfiguration

Gets the correlation-id value from the configuration.

getCorrelationId() - Method in interface io.smallrye.reactive.messaging.jms.JmsMessageMetadata

getCorrelationId() - Method in class io.smallrye.reactive.messaging.jms.OutgoingJmsMessageMetadata

getCreationTime() - Method in class io.smallrye.reactive.messaging.amqp.AmqpMessage

getCreationTime() - Method in class io.smallrye.reactive.messaging.amqp.IncomingAmqpMetadata

getCredentialPath() - Method in class io.smallrye.reactive.messaging.gcp.pubsub.PubSubConfig

getData() - Method in class io.smallrye.reactive.messaging.cloudevents.DefaultCloudEventMessage

getDeliveryCount() - Method in class io.smallrye.reactive.messaging.amqp.AmqpMessage

getDeliveryCount() - Method in class io.smallrye.reactive.messaging.amqp.IncomingAmqpMetadata

getDeliveryDelay() - Method in class io.smallrye.reactive.messaging.jms.JmsConnectorOutgoingConfiguration

Gets the delivery-delay value from the configuration.

getDeliveryMode() - Method in class io.smallrye.reactive.messaging.jms.IncomingJmsMessageMetadata

getDeliveryMode() - Method in class io.smallrye.reactive.messaging.jms.JmsConnectorOutgoingConfiguration

Gets the delivery-mode value from the configuration.

getDeliveryMode() - Method in interface io.smallrye.reactive.messaging.jms.JmsMessageMetadata

getDeliveryMode() - Method in class io.smallrye.reactive.messaging.jms.OutgoingJmsMessageMetadata

getDeliveryTime() - Method in class io.smallrye.reactive.messaging.jms.IncomingJmsMessageMetadata

getDestination() - Method in class io.smallrye.reactive.messaging.jms.IncomingJmsMessageMetadata

getDestination() - Method in class io.smallrye.reactive.messaging.jms.JmsConnectorCommonConfiguration

Gets the destination value from the configuration.

getDestination() - Method in interface io.smallrye.reactive.messaging.jms.JmsMessageMetadata

getDestination() - Method in class io.smallrye.reactive.messaging.jms.OutgoingJmsMessageMetadata

getDestinationType() - Method in class io.smallrye.reactive.messaging.jms.JmsConnectorCommonConfiguration

Gets the destination-type value from the configuration.

getDisableMessageId() - Method in class io.smallrye.reactive.messaging.jms.JmsConnectorOutgoingConfiguration

Gets the disable-message-id value from the configuration.

getDisableMessageTimestamp() - Method in class io.smallrye.reactive.messaging.jms.JmsConnectorOutgoingConfiguration

Gets the disable-message-timestamp value from the configuration.

getDoubleProperty(String) - Method in class io.smallrye.reactive.messaging.jms.impl.ImmutableJmsProperties

getDoubleProperty(String) - Method in class io.smallrye.reactive.messaging.jms.IncomingJmsMessageMetadata

getDoubleProperty(String) - Method in interface io.smallrye.reactive.messaging.jms.JmsProperties

Returns the value of the double property with the specified name.

getDoubleProperty(String) - Method in class io.smallrye.reactive.messaging.jms.JmsPropertiesBuilder.OutgoingJmsProperties

getDurable() - Method in class io.smallrye.reactive.messaging.amqp.AmqpConnectorIncomingConfiguration

Gets the durable value from the configuration.

getDurable() - Method in class io.smallrye.reactive.messaging.amqp.AmqpConnectorOutgoingConfiguration

Gets the durable value from the configuration.

getDurable() - Method in class io.smallrye.reactive.messaging.jms.JmsConnectorIncomingConfiguration

Gets the durable value from the configuration.

getEmitter(String) - Method in interface io.smallrye.reactive.messaging.ChannelRegistry

getEmitter(String) - Method in class io.smallrye.reactive.messaging.impl.InternalChannelRegistry

getEmitterNames() - Method in interface io.smallrye.reactive.messaging.ChannelRegistry

getEmitterNames() - Method in class io.smallrye.reactive.messaging.impl.InternalChannelRegistry

getEndpointUri() - Method in class io.smallrye.reactive.messaging.camel.CamelConnectorCommonConfiguration

Gets the endpoint-uri value from the configuration.

getError() - Method in class io.smallrye.reactive.messaging.amqp.AmqpMessage

getExchange() - Method in class io.smallrye.reactive.messaging.camel.CamelMessage

getExchange() - Method in class io.smallrye.reactive.messaging.camel.IncomingExchangeMetadata

getExchangePattern() - Method in class io.smallrye.reactive.messaging.camel.OutgoingExchangeMetadata

getExpectReply() - Method in class io.smallrye.reactive.messaging.eventbus.VertxEventBusConnectorOutgoingConfiguration

Gets the expect-reply value from the configuration.

getExpiration() - Method in class io.smallrye.reactive.messaging.jms.IncomingJmsMessageMetadata

getExpiryTime() - Method in class io.smallrye.reactive.messaging.amqp.AmqpMessage

getExpiryTime() - Method in class io.smallrye.reactive.messaging.amqp.IncomingAmqpMetadata

getExtensions() - Method in class io.smallrye.reactive.messaging.cloudevents.DefaultCloudEventMessage

getFailure() - Method in interface io.smallrye.reactive.messaging.connectors.InMemorySink

getFetchMinBytes() - Method in class io.smallrye.reactive.messaging.kafka.KafkaConnectorIncomingConfiguration

Gets the fetch.min.bytes value from the configuration.

getFloatProperty(String) - Method in class io.smallrye.reactive.messaging.jms.impl.ImmutableJmsProperties

getFloatProperty(String) - Method in class io.smallrye.reactive.messaging.jms.IncomingJmsMessageMetadata

getFloatProperty(String) - Method in interface io.smallrye.reactive.messaging.jms.JmsProperties

Returns the value of the float property with the specified name.

getFloatProperty(String) - Method in class io.smallrye.reactive.messaging.jms.JmsPropertiesBuilder.OutgoingJmsProperties

getFromAlias(String, Class<T>) - Method in class io.smallrye.reactive.messaging.amqp.AmqpConnectorCommonConfiguration

Retrieves the value stored for the given alias.

getFromAlias(String, Class<T>) - Method in class io.smallrye.reactive.messaging.aws.sns.SnsConnectorCommonConfiguration

Retrieves the value stored for the given alias.

getFromAlias(String, Class<T>) - Method in class io.smallrye.reactive.messaging.camel.CamelConnectorCommonConfiguration

Retrieves the value stored for the given alias.

getFromAlias(String, Class<T>) - Method in class io.smallrye.reactive.messaging.eventbus.VertxEventBusConnectorCommonConfiguration

Retrieves the value stored for the given alias.

getFromAlias(String, Class<T>) - Method in class io.smallrye.reactive.messaging.http.HttpConnectorCommonConfiguration

Retrieves the value stored for the given alias.

getFromAlias(String, Class<T>) - Method in class io.smallrye.reactive.messaging.jms.JmsConnectorCommonConfiguration

Retrieves the value stored for the given alias.

getFromAlias(String, Class<T>) - Method in class io.smallrye.reactive.messaging.kafka.KafkaConnectorCommonConfiguration

Retrieves the value stored for the given alias.

getFromAlias(String, Class<T>) - Method in class io.smallrye.reactive.messaging.mqtt.MqttConnectorCommonConfiguration

Retrieves the value stored for the given alias.

getFromAlias(String, Class<T>) - Method in class io.smallrye.reactive.messaging.mqtt.server.MqttServerConnectorCommonConfiguration

Retrieves the value stored for the given alias.

getFromAliasWithDefaultValue(String, Class<T>, T) - Method in class io.smallrye.reactive.messaging.amqp.AmqpConnectorCommonConfiguration

Retrieves the value stored for the given alias.

getFromAliasWithDefaultValue(String, Class<T>, T) - Method in class io.smallrye.reactive.messaging.aws.sns.SnsConnectorCommonConfiguration

Retrieves the value stored for the given alias.

getFromAliasWithDefaultValue(String, Class<T>, T) - Method in class io.smallrye.reactive.messaging.camel.CamelConnectorCommonConfiguration

Retrieves the value stored for the given alias.

getFromAliasWithDefaultValue(String, Class<T>, T) - Method in class io.smallrye.reactive.messaging.eventbus.VertxEventBusConnectorCommonConfiguration

Retrieves the value stored for the given alias.

getFromAliasWithDefaultValue(String, Class<T>, T) - Method in class io.smallrye.reactive.messaging.http.HttpConnectorCommonConfiguration

Retrieves the value stored for the given alias.

getFromAliasWithDefaultValue(String, Class<T>, T) - Method in class io.smallrye.reactive.messaging.jms.JmsConnectorCommonConfiguration

Retrieves the value stored for the given alias.

getFromAliasWithDefaultValue(String, Class<T>, T) - Method in class io.smallrye.reactive.messaging.kafka.KafkaConnectorCommonConfiguration

Retrieves the value stored for the given alias.

getFromAliasWithDefaultValue(String, Class<T>, T) - Method in class io.smallrye.reactive.messaging.mqtt.MqttConnectorCommonConfiguration

Retrieves the value stored for the given alias.

getFromAliasWithDefaultValue(String, Class<T>, T) - Method in class io.smallrye.reactive.messaging.mqtt.server.MqttServerConnectorCommonConfiguration

Retrieves the value stored for the given alias.

getGetterBody(ConnectorAttribute, String) - Static method in class io.smallrye.reactive.messaging.connector.ClassWriter

getGetterSignatureLine(ConnectorAttribute) - Static method in class io.smallrye.reactive.messaging.connector.ClassWriter

getGroupId() - Method in class io.smallrye.reactive.messaging.amqp.AmqpMessage

getGroupId() - Method in class io.smallrye.reactive.messaging.amqp.IncomingAmqpMetadata

getGroupId() - Method in class io.smallrye.reactive.messaging.amqp.OutgoingAmqpMessage

getGroupId() - Method in class io.smallrye.reactive.messaging.amqp.OutgoingAmqpMetadata

getGroupId() - Method in class io.smallrye.reactive.messaging.kafka.KafkaConnectorIncomingConfiguration

Gets the group.id value from the configuration.

getGroupSequence() - Method in class io.smallrye.reactive.messaging.amqp.AmqpMessage

getGroupSequence() - Method in class io.smallrye.reactive.messaging.amqp.IncomingAmqpMetadata

getHeader() - Method in class io.smallrye.reactive.messaging.amqp.AmqpMessage

getHeader() - Method in class io.smallrye.reactive.messaging.amqp.IncomingAmqpMetadata

getHeader(String) - Method in class io.smallrye.reactive.messaging.eventbus.EventBusMessage

getHeaders() - Method in class io.smallrye.reactive.messaging.http.HttpMessage

getHeaders() - Method in class io.smallrye.reactive.messaging.http.HttpRequestMetadata

getHeaders() - Method in class io.smallrye.reactive.messaging.http.HttpResponseMetadata

getHeaders() - Method in class io.smallrye.reactive.messaging.kafka.IncomingKafkaRecord

getHeaders() - Method in class io.smallrye.reactive.messaging.kafka.IncomingKafkaRecordMetadata

getHeaders() - Method in interface io.smallrye.reactive.messaging.kafka.KafkaMessageMetadata

getHeaders() - Method in interface io.smallrye.reactive.messaging.kafka.KafkaRecord

getHeaders() - Method in class io.smallrye.reactive.messaging.kafka.OutgoingKafkaRecord

getHeaders() - Method in class io.smallrye.reactive.messaging.kafka.OutgoingKafkaRecordMetadata

getHeaders(String) - Method in class io.smallrye.reactive.messaging.eventbus.EventBusMessage

getHost() - Method in class io.smallrye.reactive.messaging.amqp.AmqpConnectorCommonConfiguration

Gets the host value from the configuration.

getHost() - Method in class io.smallrye.reactive.messaging.aws.sns.SnsConnectorIncomingConfiguration

Gets the host value from the configuration.

getHost() - Method in class io.smallrye.reactive.messaging.gcp.pubsub.PubSubConfig

getHost() - Method in class io.smallrye.reactive.messaging.http.HttpConnectorIncomingConfiguration

Gets the host value from the configuration.

getHost() - Method in class io.smallrye.reactive.messaging.mqtt.MqttConnectorCommonConfiguration

Gets the host value from the configuration.

getHost() - Method in class io.smallrye.reactive.messaging.mqtt.server.MqttServerConnectorIncomingConfiguration

Gets the host value from the configuration.

getId() - Method in class io.smallrye.reactive.messaging.amqp.IncomingAmqpMetadata

getId() - Method in class io.smallrye.reactive.messaging.amqp.OutgoingAmqpMetadata

getIncoming() - Method in class io.smallrye.reactive.messaging.DefaultMediatorConfiguration

getIncoming() - Method in interface io.smallrye.reactive.messaging.MediatorConfiguration

getIncomingNames() - Method in interface io.smallrye.reactive.messaging.ChannelRegistry

getIncomingNames() - Method in class io.smallrye.reactive.messaging.impl.InternalChannelRegistry

getIntProperty(String) - Method in class io.smallrye.reactive.messaging.jms.impl.ImmutableJmsProperties

getIntProperty(String) - Method in class io.smallrye.reactive.messaging.jms.IncomingJmsMessageMetadata

getIntProperty(String) - Method in interface io.smallrye.reactive.messaging.jms.JmsProperties

Returns the value of the int property with the specified name.

getIntProperty(String) - Method in class io.smallrye.reactive.messaging.jms.JmsPropertiesBuilder.OutgoingJmsProperties

getInvokerClass() - Method in class io.smallrye.reactive.messaging.DefaultMediatorConfiguration

getInvokerClass() - Method in interface io.smallrye.reactive.messaging.MediatorConfiguration

Implementation of the Invoker interface that can be used to invoke the method described by this configuration The invoker class can either have a no-arg constructor in which case it's expected to be look up the bean programmatically, or have a constructor that takes a single Object parameter - the bean to operate on

getKeepAliveSeconds() - Method in class io.smallrye.reactive.messaging.mqtt.MqttConnectorCommonConfiguration

Gets the keep-alive-seconds value from the configuration.

getKey() - Method in class io.smallrye.reactive.messaging.kafka.IncomingKafkaRecord

getKey() - Method in class io.smallrye.reactive.messaging.kafka.IncomingKafkaRecordMetadata

getKey() - Method in class io.smallrye.reactive.messaging.kafka.KafkaConnectorOutgoingConfiguration

Gets the key value from the configuration.

getKey() - Method in interface io.smallrye.reactive.messaging.kafka.KafkaMessageMetadata

getKey() - Method in interface io.smallrye.reactive.messaging.kafka.KafkaRecord

getKey() - Method in class io.smallrye.reactive.messaging.kafka.OutgoingKafkaRecord

getKey() - Method in class io.smallrye.reactive.messaging.kafka.OutgoingKafkaRecordMetadata

getKeyDeserializer() - Method in class io.smallrye.reactive.messaging.kafka.KafkaConnectorIncomingConfiguration

Gets the key.deserializer value from the configuration.

getKeySerializer() - Method in class io.smallrye.reactive.messaging.kafka.KafkaConnectorOutgoingConfiguration

Gets the key.serializer value from the configuration.

getLongProperty(String) - Method in class io.smallrye.reactive.messaging.jms.impl.ImmutableJmsProperties

getLongProperty(String) - Method in class io.smallrye.reactive.messaging.jms.IncomingJmsMessageMetadata

getLongProperty(String) - Method in interface io.smallrye.reactive.messaging.jms.JmsProperties

Returns the value of the long property with the specified name.

getLongProperty(String) - Method in class io.smallrye.reactive.messaging.jms.JmsPropertiesBuilder.OutgoingJmsProperties

getMaxInflightMessages() - Method in class io.smallrye.reactive.messaging.kafka.KafkaConnectorOutgoingConfiguration

Gets the max-inflight-messages value from the configuration.

getMaxInflightQueue() - Method in class io.smallrye.reactive.messaging.mqtt.MqttConnectorCommonConfiguration

Gets the max-inflight-queue value from the configuration.

getMaxMessageSize() - Method in class io.smallrye.reactive.messaging.mqtt.MqttConnectorCommonConfiguration

Gets the max-message-size value from the configuration.

getMaxMessageSize() - Method in class io.smallrye.reactive.messaging.mqtt.server.MqttServerConnectorIncomingConfiguration

Gets the max-message-size value from the configuration.

getMerge() - Method in class io.smallrye.reactive.messaging.DefaultMediatorConfiguration

getMerge() - Method in interface io.smallrye.reactive.messaging.MediatorConfiguration

getMessage() - Method in class io.smallrye.reactive.messaging.gcp.pubsub.PubSubMessage

getMessageId() - Method in class io.smallrye.reactive.messaging.amqp.AmqpMessage

getMessageId() - Method in class io.smallrye.reactive.messaging.amqp.OutgoingAmqpMessage

getMessageId() - Method in class io.smallrye.reactive.messaging.jms.IncomingJmsMessageMetadata

getMessageId() - Method in interface io.smallrye.reactive.messaging.mqtt.MqttMessage

getMessageId() - Method in class io.smallrye.reactive.messaging.mqtt.ReceivingMqttMessage

getMessageId() - Method in class io.smallrye.reactive.messaging.mqtt.SendingMqttMessage

getMessageId() - Method in class io.smallrye.reactive.messaging.mqtt.server.MqttMessage

getMetadata() - Method in class io.smallrye.reactive.messaging.amqp.AmqpMessage

getMetadata() - Method in class io.smallrye.reactive.messaging.amqp.OutgoingAmqpMessage

getMetadata() - Method in class io.smallrye.reactive.messaging.camel.CamelMessage

getMetadata() - Method in class io.smallrye.reactive.messaging.http.HttpMessage

getMetadata() - Method in class io.smallrye.reactive.messaging.jms.IncomingJmsMessage

getMetadata() - Method in class io.smallrye.reactive.messaging.kafka.IncomingKafkaRecord

getMetadata() - Method in class io.smallrye.reactive.messaging.kafka.OutgoingKafkaRecord

getMetadata() - Method in interface org.eclipse.microprofile.reactive.messaging.Message

getMetadata(Class<? extends M>) - Method in interface org.eclipse.microprofile.reactive.messaging.Message

Retrieves the metadata associated with the given class.

getMethod() - Method in class io.smallrye.reactive.messaging.DefaultMediatorConfiguration

getMethod() - Method in class io.smallrye.reactive.messaging.http.HttpConnectorOutgoingConfiguration

Gets the method value from the configuration.

getMethod() - Method in class io.smallrye.reactive.messaging.http.HttpMessage

getMethod() - Method in class io.smallrye.reactive.messaging.http.HttpRequestMetadata

getMethod() - Method in class io.smallrye.reactive.messaging.http.HttpResponseMetadata

getMethod() - Method in interface io.smallrye.reactive.messaging.MediatorConfiguration

getMethodAsString() - Method in class io.smallrye.reactive.messaging.AbstractMediator

getMethodName(ConnectorAttribute) - Static method in class io.smallrye.reactive.messaging.connector.ClassWriter

getMockSnsTopics() - Method in class io.smallrye.reactive.messaging.aws.sns.SnsConnectorCommonConfiguration

Gets the mock-sns-topics value from the configuration.

getNoLocal() - Method in class io.smallrye.reactive.messaging.jms.JmsConnectorIncomingConfiguration

Gets the no-local value from the configuration.

getNumberOfSubscriberBeforeConnecting() - Method in class io.smallrye.reactive.messaging.DefaultMediatorConfiguration

getNumberOfSubscriberBeforeConnecting() - Method in interface io.smallrye.reactive.messaging.MediatorConfiguration

getObjectProperty(String) - Method in class io.smallrye.reactive.messaging.jms.impl.ImmutableJmsProperties

getObjectProperty(String) - Method in class io.smallrye.reactive.messaging.jms.IncomingJmsMessageMetadata

getObjectProperty(String) - Method in interface io.smallrye.reactive.messaging.jms.JmsProperties

Returns the value of the Java object property with the specified name.

getObjectProperty(String) - Method in class io.smallrye.reactive.messaging.jms.JmsPropertiesBuilder.OutgoingJmsProperties

getOffset() - Method in class io.smallrye.reactive.messaging.kafka.IncomingKafkaRecord

getOffset() - Method in class io.smallrye.reactive.messaging.kafka.IncomingKafkaRecordMetadata

getOptionalValue(String, Class<T>) - Method in class io.smallrye.reactive.messaging.impl.ConnectorConfig

getOutgoing() - Method in class io.smallrye.reactive.messaging.DefaultMediatorConfiguration

getOutgoing() - Method in interface io.smallrye.reactive.messaging.MediatorConfiguration

getOutgoingNames() - Method in interface io.smallrye.reactive.messaging.ChannelRegistry

getOutgoingNames() - Method in class io.smallrye.reactive.messaging.impl.InternalChannelRegistry

getParameterTypes() - Method in class io.smallrye.reactive.messaging.DefaultMediatorConfiguration

getParameterTypes() - Method in interface io.smallrye.reactive.messaging.MediatorConfiguration

getPartition() - Method in class io.smallrye.reactive.messaging.kafka.IncomingKafkaRecord

getPartition() - Method in class io.smallrye.reactive.messaging.kafka.IncomingKafkaRecordMetadata

getPartition() - Method in class io.smallrye.reactive.messaging.kafka.KafkaConnectorOutgoingConfiguration

Gets the partition value from the configuration.

getPartition() - Method in interface io.smallrye.reactive.messaging.kafka.KafkaMessageMetadata

getPartition() - Method in interface io.smallrye.reactive.messaging.kafka.KafkaRecord

getPartition() - Method in class io.smallrye.reactive.messaging.kafka.OutgoingKafkaRecord

getPartition() - Method in class io.smallrye.reactive.messaging.kafka.OutgoingKafkaRecordMetadata

getPassword() - Method in class io.smallrye.reactive.messaging.amqp.AmqpConnectorCommonConfiguration

Gets the password value from the configuration.

getPassword() - Method in class io.smallrye.reactive.messaging.jms.JmsConnectorCommonConfiguration

Gets the password value from the configuration.

getPassword() - Method in class io.smallrye.reactive.messaging.mqtt.MqttConnectorCommonConfiguration

Gets the password value from the configuration.

getPath() - Method in class io.smallrye.reactive.messaging.http.HttpRequestMetadata

getPayload() - Method in class io.smallrye.reactive.messaging.amqp.AmqpMessage

getPayload() - Method in class io.smallrye.reactive.messaging.aws.sns.SnsMessage

getPayload() - Method in class io.smallrye.reactive.messaging.camel.CamelMessage

getPayload() - Method in class io.smallrye.reactive.messaging.cloudevents.DefaultCloudEventMessage

getPayload() - Method in class io.smallrye.reactive.messaging.eventbus.EventBusMessage

getPayload() - Method in class io.smallrye.reactive.messaging.gcp.pubsub.PubSubMessage

getPayload() - Method in class io.smallrye.reactive.messaging.http.HttpMessage

getPayload() - Method in class io.smallrye.reactive.messaging.jms.IncomingJmsMessage

getPayload() - Method in class io.smallrye.reactive.messaging.kafka.IncomingKafkaRecord

getPayload() - Method in class io.smallrye.reactive.messaging.kafka.OutgoingKafkaRecord

getPayload() - Method in class io.smallrye.reactive.messaging.mqtt.ReceivingMqttMessage

getPayload() - Method in class io.smallrye.reactive.messaging.mqtt.SendingMqttMessage

getPayload() - Method in class io.smallrye.reactive.messaging.mqtt.server.MqttMessage

getPayload() - Method in interface org.eclipse.microprofile.reactive.messaging.Message

getPayload(Class<T>) - Method in class io.smallrye.reactive.messaging.camel.CamelMessage

getPort() - Method in class io.smallrye.reactive.messaging.amqp.AmqpConnectorCommonConfiguration

Gets the port value from the configuration.

getPort() - Method in class io.smallrye.reactive.messaging.aws.sns.SnsConnectorIncomingConfiguration

Gets the port value from the configuration.

getPort() - Method in class io.smallrye.reactive.messaging.gcp.pubsub.PubSubConfig

getPort() - Method in class io.smallrye.reactive.messaging.http.HttpConnectorIncomingConfiguration

Gets the port value from the configuration.

getPort() - Method in class io.smallrye.reactive.messaging.mqtt.MqttConnectorCommonConfiguration

Gets the port value from the configuration.

getPort() - Method in class io.smallrye.reactive.messaging.mqtt.server.MqttServerConnectorIncomingConfiguration

Gets the port value from the configuration.

getPriority() - Method in class io.smallrye.reactive.messaging.amqp.AmqpMessage

getPriority() - Method in class io.smallrye.reactive.messaging.amqp.IncomingAmqpMetadata

getPriority() - Method in class io.smallrye.reactive.messaging.amqp.OutgoingAmqpMessage

getPriority() - Method in class io.smallrye.reactive.messaging.amqp.OutgoingAmqpMetadata

getPriority() - Method in class io.smallrye.reactive.messaging.jms.IncomingJmsMessageMetadata

getPriority() - Method in class io.smallrye.reactive.messaging.jms.JmsConnectorOutgoingConfiguration

Gets the priority value from the configuration.

getProduction() - Method in class io.smallrye.reactive.messaging.MediatorConfigurationSupport.ValidationOutput

getProjectId() - Method in class io.smallrye.reactive.messaging.gcp.pubsub.PubSubConfig

getProperties() - Method in class io.smallrye.reactive.messaging.amqp.IncomingAmqpMetadata

getProperties() - Method in class io.smallrye.reactive.messaging.amqp.OutgoingAmqpMetadata

getProperties() - Method in class io.smallrye.reactive.messaging.camel.OutgoingExchangeMetadata

getProperties() - Method in class io.smallrye.reactive.messaging.jms.IncomingJmsMessageMetadata

getProperties() - Method in interface io.smallrye.reactive.messaging.jms.JmsMessageMetadata

getProperties() - Method in class io.smallrye.reactive.messaging.jms.JmsPropertiesBuilder.OutgoingJmsProperties

getProperties() - Method in class io.smallrye.reactive.messaging.jms.OutgoingJmsMessageMetadata

getPropertyNames() - Method in class io.smallrye.reactive.messaging.impl.ConnectorConfig

getPropertyNames() - Method in class io.smallrye.reactive.messaging.jms.impl.ImmutableJmsProperties

getPropertyNames() - Method in class io.smallrye.reactive.messaging.jms.IncomingJmsMessageMetadata

getPropertyNames() - Method in interface io.smallrye.reactive.messaging.jms.JmsProperties

Returns an Enumeration of all the property names.

getPropertyNames() - Method in class io.smallrye.reactive.messaging.jms.JmsPropertiesBuilder.OutgoingJmsProperties

getPublish() - Method in class io.smallrye.reactive.messaging.eventbus.VertxEventBusConnectorOutgoingConfiguration

Gets the publish value from the configuration.

getPublisher() - Method in class io.smallrye.reactive.messaging.extension.EmitterImpl

getPublisherBuilder(Config) - Method in class io.smallrye.reactive.messaging.amqp.AmqpConnector

getPublisherBuilder(Config) - Method in class io.smallrye.reactive.messaging.aws.sns.SnsConnector

getPublisherBuilder(Config) - Method in class io.smallrye.reactive.messaging.camel.CamelConnector

getPublisherBuilder(Config) - Method in class io.smallrye.reactive.messaging.connectors.InMemoryConnector

getPublisherBuilder(Config) - Method in class io.smallrye.reactive.messaging.eventbus.VertxEventBusConnector

getPublisherBuilder(Config) - Method in class io.smallrye.reactive.messaging.gcp.pubsub.PubSubConnector

getPublisherBuilder(Config) - Method in class io.smallrye.reactive.messaging.http.HttpConnector

getPublisherBuilder(Config) - Method in class io.smallrye.reactive.messaging.jms.JmsConnector

getPublisherBuilder(Config) - Method in class io.smallrye.reactive.messaging.kafka.KafkaConnector

getPublisherBuilder(Config) - Method in class io.smallrye.reactive.messaging.mqtt.MqttConnector

getPublisherBuilder(Config) - Method in class io.smallrye.reactive.messaging.mqtt.server.MqttServerConnector

getPublisherBuilder(Config) - Method in interface org.eclipse.microprofile.reactive.messaging.spi.IncomingConnectorFactory

Creates a channel for the given configuration.

getPublishers(String) - Method in interface io.smallrye.reactive.messaging.ChannelRegistry

getPublishers(String) - Method in class io.smallrye.reactive.messaging.impl.InternalChannelRegistry

getQos() - Method in class io.smallrye.reactive.messaging.mqtt.MqttConnectorCommonConfiguration

Gets the qos value from the configuration.

getQosLevel() - Method in interface io.smallrye.reactive.messaging.mqtt.MqttMessage

getQosLevel() - Method in class io.smallrye.reactive.messaging.mqtt.ReceivingMqttMessage

getQosLevel() - Method in class io.smallrye.reactive.messaging.mqtt.SendingMqttMessage

getQosLevel() - Method in class io.smallrye.reactive.messaging.mqtt.server.MqttMessage

getQuery() - Method in class io.smallrye.reactive.messaging.http.HttpMessage

getQuery() - Method in class io.smallrye.reactive.messaging.http.HttpRequestMetadata

getQuery() - Method in class io.smallrye.reactive.messaging.http.HttpResponseMetadata

getReceiveBufferSize() - Method in class io.smallrye.reactive.messaging.mqtt.server.MqttServerConnectorIncomingConfiguration

Gets the receive-buffer-size value from the configuration.

getReconnectAttempts() - Method in class io.smallrye.reactive.messaging.amqp.AmqpConnectorCommonConfiguration

Gets the reconnect-attempts value from the configuration.

getReconnectAttempts() - Method in class io.smallrye.reactive.messaging.mqtt.MqttConnectorCommonConfiguration

Gets the reconnect-attempts value from the configuration.

getReconnectInterval() - Method in class io.smallrye.reactive.messaging.amqp.AmqpConnectorCommonConfiguration

Gets the reconnect-interval value from the configuration.

getReconnectIntervalSeconds() - Method in class io.smallrye.reactive.messaging.mqtt.MqttConnectorCommonConfiguration

Gets the reconnect-interval-seconds value from the configuration.

getRecord() - Method in class io.smallrye.reactive.messaging.kafka.IncomingKafkaRecordMetadata

getReplyAddress() - Method in class io.smallrye.reactive.messaging.eventbus.EventBusMessage

getReplyTo() - Method in class io.smallrye.reactive.messaging.jms.IncomingJmsMessageMetadata

getReplyTo() - Method in class io.smallrye.reactive.messaging.jms.JmsConnectorOutgoingConfiguration

Gets the reply-to value from the configuration.

getReplyTo() - Method in interface io.smallrye.reactive.messaging.jms.JmsMessageMetadata

getReplyTo() - Method in class io.smallrye.reactive.messaging.jms.OutgoingJmsMessageMetadata

getReplyToDestinationType() - Method in class io.smallrye.reactive.messaging.jms.JmsConnectorOutgoingConfiguration

Gets the reply-to-destination-type value from the configuration.

getRetries() - Method in class io.smallrye.reactive.messaging.kafka.KafkaConnectorOutgoingConfiguration

Gets the retries value from the configuration.

getRetry() - Method in class io.smallrye.reactive.messaging.kafka.KafkaConnectorIncomingConfiguration

Gets the retry value from the configuration.

getRetryAttempts() - Method in class io.smallrye.reactive.messaging.kafka.KafkaConnectorIncomingConfiguration

Gets the retry-attempts value from the configuration.

getRetryMaxWait() - Method in class io.smallrye.reactive.messaging.kafka.KafkaConnectorIncomingConfiguration

Gets the retry-max-wait value from the configuration.

getReturnType() - Method in class io.smallrye.reactive.messaging.DefaultMediatorConfiguration

getReturnType() - Method in interface io.smallrye.reactive.messaging.MediatorConfiguration

getSelector() - Method in class io.smallrye.reactive.messaging.jms.JmsConnectorIncomingConfiguration

Gets the selector value from the configuration.

getServerName() - Method in class io.smallrye.reactive.messaging.mqtt.MqttConnectorCommonConfiguration

Gets the server-name value from the configuration.

getSessionMode() - Method in class io.smallrye.reactive.messaging.jms.JmsConnectorCommonConfiguration

Gets the session-mode value from the configuration.

getShortProperty(String) - Method in class io.smallrye.reactive.messaging.jms.impl.ImmutableJmsProperties

getShortProperty(String) - Method in class io.smallrye.reactive.messaging.jms.IncomingJmsMessageMetadata

getShortProperty(String) - Method in interface io.smallrye.reactive.messaging.jms.JmsProperties

Returns the value of the short property with the specified name.

getShortProperty(String) - Method in class io.smallrye.reactive.messaging.jms.JmsPropertiesBuilder.OutgoingJmsProperties

getSink() - Method in class io.smallrye.reactive.messaging.kafka.impl.KafkaSink

getSink() - Method in class io.smallrye.reactive.messaging.mqtt.MqttSink

getSnsUrl() - Method in class io.smallrye.reactive.messaging.aws.sns.SnsConnectorCommonConfiguration

Gets the sns-url value from the configuration.

getSource() - Method in class io.smallrye.reactive.messaging.kafka.impl.KafkaSource

getSsl() - Method in class io.smallrye.reactive.messaging.mqtt.MqttConnectorCommonConfiguration

Gets the ssl value from the configuration.

getSsl() - Method in class io.smallrye.reactive.messaging.mqtt.server.MqttServerConnectorIncomingConfiguration

Gets the ssl value from the configuration.

getStream() - Method in class io.smallrye.reactive.messaging.AbstractMediator

getStream() - Method in class io.smallrye.reactive.messaging.ProcessorMediator

getStream() - Method in class io.smallrye.reactive.messaging.PublisherMediator

getStream() - Method in class io.smallrye.reactive.messaging.StreamTransformerMediator

getStringProperty(String) - Method in class io.smallrye.reactive.messaging.jms.impl.ImmutableJmsProperties

getStringProperty(String) - Method in class io.smallrye.reactive.messaging.jms.IncomingJmsMessageMetadata

getStringProperty(String) - Method in interface io.smallrye.reactive.messaging.jms.JmsProperties

Returns the value of the String property with the specified name.

getStringProperty(String) - Method in class io.smallrye.reactive.messaging.jms.JmsPropertiesBuilder.OutgoingJmsProperties

getSubject() - Method in class io.smallrye.reactive.messaging.amqp.AmqpMessage

getSubject() - Method in class io.smallrye.reactive.messaging.amqp.IncomingAmqpMetadata

getSubject() - Method in class io.smallrye.reactive.messaging.amqp.OutgoingAmqpMessage

getSubject() - Method in class io.smallrye.reactive.messaging.amqp.OutgoingAmqpMetadata

getSubject() - Method in class io.smallrye.reactive.messaging.aws.sns.SnsMessage

Get message subject of SNS notification.

getSubscriberBuilder(Config) - Method in class io.smallrye.reactive.messaging.amqp.AmqpConnector

getSubscriberBuilder(Config) - Method in class io.smallrye.reactive.messaging.aws.sns.SnsConnector

getSubscriberBuilder(Config) - Method in class io.smallrye.reactive.messaging.camel.CamelConnector

getSubscriberBuilder(Config) - Method in class io.smallrye.reactive.messaging.connectors.InMemoryConnector

getSubscriberBuilder(Config) - Method in class io.smallrye.reactive.messaging.eventbus.VertxEventBusConnector

getSubscriberBuilder(Config) - Method in class io.smallrye.reactive.messaging.gcp.pubsub.PubSubConnector

getSubscriberBuilder(Config) - Method in class io.smallrye.reactive.messaging.http.HttpConnector

getSubscriberBuilder(Config) - Method in class io.smallrye.reactive.messaging.jms.JmsConnector

getSubscriberBuilder(Config) - Method in class io.smallrye.reactive.messaging.kafka.KafkaConnector

getSubscriberBuilder(Config) - Method in class io.smallrye.reactive.messaging.mqtt.MqttConnector

getSubscriberBuilder(Config) - Method in interface org.eclipse.microprofile.reactive.messaging.spi.OutgoingConnectorFactory

Creates a channel for the given configuration.

getSubscribers(String) - Method in interface io.smallrye.reactive.messaging.ChannelRegistry

getSubscribers(String) - Method in class io.smallrye.reactive.messaging.impl.InternalChannelRegistry

getSubscription() - Method in class io.smallrye.reactive.messaging.gcp.pubsub.PubSubConfig

getTimeout() - Method in class io.smallrye.reactive.messaging.eventbus.VertxEventBusConnectorOutgoingConfiguration

Gets the timeout value from the configuration.

getTimeoutOnConnect() - Method in class io.smallrye.reactive.messaging.mqtt.server.MqttServerConnectorIncomingConfiguration

Gets the timeout-on-connect value from the configuration.

getTimestamp() - Method in class io.smallrye.reactive.messaging.jms.IncomingJmsMessageMetadata

getTimestamp() - Method in class io.smallrye.reactive.messaging.kafka.IncomingKafkaRecord

getTimestamp() - Method in class io.smallrye.reactive.messaging.kafka.IncomingKafkaRecordMetadata

getTimestamp() - Method in interface io.smallrye.reactive.messaging.kafka.KafkaMessageMetadata

getTimestamp() - Method in interface io.smallrye.reactive.messaging.kafka.KafkaRecord

getTimestamp() - Method in class io.smallrye.reactive.messaging.kafka.OutgoingKafkaRecord

getTimestamp() - Method in class io.smallrye.reactive.messaging.kafka.OutgoingKafkaRecordMetadata

getTimestampType() - Method in class io.smallrye.reactive.messaging.kafka.IncomingKafkaRecordMetadata

getTopic() - Method in class io.smallrye.reactive.messaging.aws.sns.SnsConnectorCommonConfiguration

Gets the topic value from the configuration.

getTopic() - Method in class io.smallrye.reactive.messaging.gcp.pubsub.PubSubConfig

getTopic() - Method in class io.smallrye.reactive.messaging.kafka.IncomingKafkaRecord

getTopic() - Method in class io.smallrye.reactive.messaging.kafka.IncomingKafkaRecordMetadata

getTopic() - Method in class io.smallrye.reactive.messaging.kafka.KafkaConnectorCommonConfiguration

Gets the topic value from the configuration.

getTopic() - Method in interface io.smallrye.reactive.messaging.kafka.KafkaMessageMetadata

getTopic() - Method in interface io.smallrye.reactive.messaging.kafka.KafkaRecord

getTopic() - Method in class io.smallrye.reactive.messaging.kafka.OutgoingKafkaRecord

getTopic() - Method in class io.smallrye.reactive.messaging.kafka.OutgoingKafkaRecordMetadata

getTopic() - Method in class io.smallrye.reactive.messaging.mqtt.MqttConnectorCommonConfiguration

Gets the topic value from the configuration.

getTopic() - Method in interface io.smallrye.reactive.messaging.mqtt.MqttMessage

getTopic() - Method in class io.smallrye.reactive.messaging.mqtt.ReceivingMqttMessage

getTopic() - Method in class io.smallrye.reactive.messaging.mqtt.SendingMqttMessage

getTopic() - Method in class io.smallrye.reactive.messaging.mqtt.server.MqttMessage

getTrustAll() - Method in class io.smallrye.reactive.messaging.mqtt.MqttConnectorCommonConfiguration

Gets the trust-all value from the configuration.

getTtl() - Method in class io.smallrye.reactive.messaging.amqp.AmqpConnectorOutgoingConfiguration

Gets the ttl value from the configuration.

getTtl() - Method in class io.smallrye.reactive.messaging.amqp.AmqpMessage

getTtl() - Method in class io.smallrye.reactive.messaging.amqp.IncomingAmqpMetadata

getTtl() - Method in class io.smallrye.reactive.messaging.amqp.OutgoingAmqpMessage

getTtl() - Method in class io.smallrye.reactive.messaging.amqp.OutgoingAmqpMetadata

getTtl() - Method in class io.smallrye.reactive.messaging.jms.JmsConnectorOutgoingConfiguration

Gets the ttl value from the configuration.

getType() - Method in class io.smallrye.reactive.messaging.jms.IncomingJmsMessageMetadata

getType() - Method in interface io.smallrye.reactive.messaging.jms.JmsMessageMetadata

getType() - Method in class io.smallrye.reactive.messaging.jms.OutgoingJmsMessageMetadata

getUrl() - Method in class io.smallrye.reactive.messaging.http.HttpConnectorOutgoingConfiguration

Gets the url value from the configuration.

getUrl() - Method in class io.smallrye.reactive.messaging.http.HttpMessage

getUrl() - Method in class io.smallrye.reactive.messaging.http.HttpResponseMetadata

getUseAnonymousSender() - Method in class io.smallrye.reactive.messaging.amqp.AmqpConnectorOutgoingConfiguration

Gets the use-anonymous-sender value from the configuration.

getUseBuilderTypes() - Method in class io.smallrye.reactive.messaging.MediatorConfigurationSupport.ValidationOutput

getUseReplyAsAck() - Method in class io.smallrye.reactive.messaging.eventbus.VertxEventBusConnectorIncomingConfiguration

Gets the use-reply-as-ack value from the configuration.

getUsername() - Method in class io.smallrye.reactive.messaging.amqp.AmqpConnectorCommonConfiguration

Gets the username value from the configuration.

getUsername() - Method in class io.smallrye.reactive.messaging.jms.JmsConnectorCommonConfiguration

Gets the username value from the configuration.

getUsername() - Method in class io.smallrye.reactive.messaging.mqtt.MqttConnectorCommonConfiguration

Gets the username value from the configuration.

getUseSsl() - Method in class io.smallrye.reactive.messaging.amqp.AmqpConnectorCommonConfiguration

Gets the use-ssl value from the configuration.

getValue(String, Class<T>) - Method in class io.smallrye.reactive.messaging.impl.ConnectorConfig

getValueDeserializer() - Method in class io.smallrye.reactive.messaging.kafka.KafkaConnectorIncomingConfiguration

Gets the value.deserializer value from the configuration.

getValueSerializer() - Method in class io.smallrye.reactive.messaging.kafka.KafkaConnectorOutgoingConfiguration

Gets the value.serializer value from the configuration.

getWaitForWriteCompletion() - Method in class io.smallrye.reactive.messaging.kafka.KafkaConnectorOutgoingConfiguration

Gets the waitForWriteCompletion value from the configuration.

getWillFlag() - Method in class io.smallrye.reactive.messaging.mqtt.MqttConnectorCommonConfiguration

Gets the will-flag value from the configuration.

getWillQos() - Method in class io.smallrye.reactive.messaging.mqtt.MqttConnectorCommonConfiguration

Gets the will-qos value from the configuration.

getWillRetain() - Method in class io.smallrye.reactive.messaging.mqtt.MqttConnectorCommonConfiguration

Gets the will-retain value from the configuration.

getWorkerPoolName() - Method in class io.smallrye.reactive.messaging.DefaultMediatorConfiguration

getWorkerPoolName() - Method in interface io.smallrye.reactive.messaging.MediatorConfiguration

H

hasAlias(ConnectorAttribute) - Static method in class io.smallrye.reactive.messaging.connector.ClassWriter

hasCompleted() - Method in interface io.smallrye.reactive.messaging.connectors.InMemorySink

hasDefaultValue(ConnectorAttribute) - Static method in class io.smallrye.reactive.messaging.connector.ClassWriter

hasFailed() - Method in interface io.smallrye.reactive.messaging.connectors.InMemorySink

hashCode() - Method in class io.smallrye.reactive.messaging.gcp.pubsub.PubSubConfig

hashCode() - Method in class io.smallrye.reactive.messaging.gcp.pubsub.PubSubMessage

hiddenFromDocumentation() - Method in annotation type io.smallrye.reactive.messaging.annotations.ConnectorAttribute

HttpConnector - Class in io.smallrye.reactive.messaging.http

HttpConnector() - Constructor for class io.smallrye.reactive.messaging.http.HttpConnector

HttpConnectorCommonConfiguration - Class in io.smallrye.reactive.messaging.http

Extracts the common configuration for the smallrye-http connector.

HttpConnectorCommonConfiguration(Config) - Constructor for class io.smallrye.reactive.messaging.http.HttpConnectorCommonConfiguration

Creates a new HttpConnectorCommonConfiguration.

HttpConnectorIncomingConfiguration - Class in io.smallrye.reactive.messaging.http

Extract the incoming configuration for the smallrye-http connector.

HttpConnectorIncomingConfiguration(Config) - Constructor for class io.smallrye.reactive.messaging.http.HttpConnectorIncomingConfiguration

Creates a new HttpConnectorIncomingConfiguration.

HttpConnectorOutgoingConfiguration - Class in io.smallrye.reactive.messaging.http

Extract the outgoing configuration for the smallrye-http connector.

HttpConnectorOutgoingConfiguration(Config) - Constructor for class io.smallrye.reactive.messaging.http.HttpConnectorOutgoingConfiguration

Creates a new HttpConnectorOutgoingConfiguration.

HttpMessage<T> - Class in io.smallrye.reactive.messaging.http

HttpMessage.HttpMessageBuilder<T> - Class in io.smallrye.reactive.messaging.http

HttpRequestMetadata - Class in io.smallrye.reactive.messaging.http

Metadata for incoming HTTP messages.

HttpRequestMetadata(String, String, Map<String, List<String>>, Map<String, List<String>>) - Constructor for class io.smallrye.reactive.messaging.http.HttpRequestMetadata

HttpResponseMetadata - Class in io.smallrye.reactive.messaging.http

Metadata for outgoing HTTP messages handled by the HTTP connector.

HttpResponseMetadata(Map<String, List<String>>, String, String, Map<String, List<String>>) - Constructor for class io.smallrye.reactive.messaging.http.HttpResponseMetadata

HttpResponseMetadata.HttpResponseMetadataBuilder - Class in io.smallrye.reactive.messaging.http

HttpResponseMetadataBuilder() - Constructor for class io.smallrye.reactive.messaging.http.HttpResponseMetadata.HttpResponseMetadataBuilder

HttpSource - Class in io.smallrye.reactive.messaging.http

I

ImmutableJmsProperties - Class in io.smallrye.reactive.messaging.jms.impl

ImmutableJmsProperties(Message) - Constructor for class io.smallrye.reactive.messaging.jms.impl.ImmutableJmsProperties

Incoming - Annotation Type in org.eclipse.microprofile.reactive.messaging

Used to signify a subscriber to incoming messages.

INCOMING - io.smallrye.reactive.messaging.annotations.ConnectorAttribute.Direction

INCOMING_AND_OUTGOING - io.smallrye.reactive.messaging.annotations.ConnectorAttribute.Direction

INCOMING_PREFIX - Static variable in interface org.eclipse.microprofile.reactive.messaging.spi.ConnectorFactory

Prefix used in the MicroProfile Config to configure an incoming channel.

IncomingAmqpMetadata - Class in io.smallrye.reactive.messaging.amqp

IncomingAmqpMetadata(String, JsonObject, String, String, String, long, int, long, String, long, String, boolean, boolean, int, String, long, Header) - Constructor for class io.smallrye.reactive.messaging.amqp.IncomingAmqpMetadata

IncomingConnectorFactory - Interface in org.eclipse.microprofile.reactive.messaging.spi

SPI used to implement a connector managing a source of messages for a specific transport.

IncomingExchangeMetadata - Class in io.smallrye.reactive.messaging.camel

IncomingExchangeMetadata(Exchange) - Constructor for class io.smallrye.reactive.messaging.camel.IncomingExchangeMetadata

IncomingJmsMessage<T> - Class in io.smallrye.reactive.messaging.jms

IncomingJmsMessageMetadata - Class in io.smallrye.reactive.messaging.jms

IncomingJmsMessageMetadata(Message) - Constructor for class io.smallrye.reactive.messaging.jms.IncomingJmsMessageMetadata

IncomingKafkaRecord<K,T> - Class in io.smallrye.reactive.messaging.kafka

IncomingKafkaRecord(KafkaConsumer<K, T>, KafkaConsumerRecord<K, T>) - Constructor for class io.smallrye.reactive.messaging.kafka.IncomingKafkaRecord

IncomingKafkaRecordMetadata<K,T> - Class in io.smallrye.reactive.messaging.kafka

IncomingKafkaRecordMetadata(KafkaConsumerRecord<K, T>) - Constructor for class io.smallrye.reactive.messaging.kafka.IncomingKafkaRecordMetadata

Incomings - Annotation Type in io.smallrye.reactive.messaging.annotations

This class is used to allow multiple Incoming declarations.

INDIVIDUAL_MESSAGE - io.smallrye.reactive.messaging.MediatorConfiguration.Production

INDIVIDUAL_PAYLOAD - io.smallrye.reactive.messaging.MediatorConfiguration.Production

init() - Method in class io.smallrye.reactive.messaging.camel.CamelConnector

init() - Method in class io.smallrye.reactive.messaging.jms.JmsConnector

initConnector() - Method in class io.smallrye.reactive.messaging.aws.sns.SnsConnector

initialize() - Method in interface io.smallrye.reactive.messaging.ChannelRegistar

initialize() - Method in class io.smallrye.reactive.messaging.gcp.pubsub.PubSubConnector

initialize() - Method in class io.smallrye.reactive.messaging.impl.ConfiguredChannelFactory

initialize() - Method in class io.smallrye.reactive.messaging.impl.LegacyConfiguredChannelFactory

initialize(Object) - Method in class io.smallrye.reactive.messaging.AbstractMediator

initialize(Object) - Method in class io.smallrye.reactive.messaging.ProcessorMediator

initialize(Object) - Method in class io.smallrye.reactive.messaging.PublisherMediator

initialize(Object) - Method in class io.smallrye.reactive.messaging.StreamTransformerMediator

initialize(Object) - Method in class io.smallrye.reactive.messaging.SubscriberMediator

initializeAndRun() - Method in class io.smallrye.reactive.messaging.extension.MediatorManager

initializeEmitter(String, String, long, long) - Method in class io.smallrye.reactive.messaging.extension.MediatorManager

initializeEmitters(Map<String, OnOverflow>) - Method in class io.smallrye.reactive.messaging.extension.MediatorManager

InMemoryConnector - Class in io.smallrye.reactive.messaging.connectors

An implementation of connector used for testing applications without having to use external broker.

InMemoryConnector() - Constructor for class io.smallrye.reactive.messaging.connectors.InMemoryConnector

InMemorySink<T> - Interface in io.smallrye.reactive.messaging.connectors

Allows interacting with an in-memory sink.

InMemorySource<T> - Interface in io.smallrye.reactive.messaging.connectors

Allows interacting with an in-memory source.

input() - Method in class io.smallrye.reactive.messaging.http.converters.BufferSerializer

input() - Method in class io.smallrye.reactive.messaging.http.converters.ByteArraySerializer

input() - Method in class io.smallrye.reactive.messaging.http.converters.ByteBufferSerializer

input() - Method in class io.smallrye.reactive.messaging.http.converters.CloudEventSerializer

input() - Method in interface io.smallrye.reactive.messaging.http.converters.Converter

input() - Method in class io.smallrye.reactive.messaging.http.converters.JsonArraySerializer

input() - Method in class io.smallrye.reactive.messaging.http.converters.JsonObjectSerializer

input() - Method in class io.smallrye.reactive.messaging.http.converters.StringSerializer

InternalChannelRegistry - Class in io.smallrye.reactive.messaging.impl

InternalChannelRegistry() - Constructor for class io.smallrye.reactive.messaging.impl.InternalChannelRegistry

InvalidIndex - io.smallrye.reactive.messaging.MediatorConfigurationSupport.GenericTypeAssignable.Result

invoke(Object...) - Method in class io.smallrye.reactive.messaging.AbstractMediator

invoke(Object...) - Method in interface io.smallrye.reactive.messaging.Invoker

invokeBlocking(Object...) - Method in class io.smallrye.reactive.messaging.AbstractMediator

invokeBlocking(Object...) - Method in class io.smallrye.reactive.messaging.ProcessorMediator

invokeBlocking(Object...) - Method in class io.smallrye.reactive.messaging.PublisherMediator

Invoker - Interface in io.smallrye.reactive.messaging

io.smallrye.reactive.messaging - package io.smallrye.reactive.messaging

io.smallrye.reactive.messaging.amqp - package io.smallrye.reactive.messaging.amqp

io.smallrye.reactive.messaging.annotations - package io.smallrye.reactive.messaging.annotations

io.smallrye.reactive.messaging.aws.sns - package io.smallrye.reactive.messaging.aws.sns

io.smallrye.reactive.messaging.camel - package io.smallrye.reactive.messaging.camel

io.smallrye.reactive.messaging.cloudevents - package io.smallrye.reactive.messaging.cloudevents

io.smallrye.reactive.messaging.connector - package io.smallrye.reactive.messaging.connector

io.smallrye.reactive.messaging.connectors - package io.smallrye.reactive.messaging.connectors

io.smallrye.reactive.messaging.eventbus - package io.smallrye.reactive.messaging.eventbus

io.smallrye.reactive.messaging.example.eventclouds - package io.smallrye.reactive.messaging.example.eventclouds

io.smallrye.reactive.messaging.extension - package io.smallrye.reactive.messaging.extension

io.smallrye.reactive.messaging.gcp.pubsub - package io.smallrye.reactive.messaging.gcp.pubsub

io.smallrye.reactive.messaging.helpers - package io.smallrye.reactive.messaging.helpers

io.smallrye.reactive.messaging.http - package io.smallrye.reactive.messaging.http

io.smallrye.reactive.messaging.http.converters - package io.smallrye.reactive.messaging.http.converters

io.smallrye.reactive.messaging.impl - package io.smallrye.reactive.messaging.impl

io.smallrye.reactive.messaging.jms - package io.smallrye.reactive.messaging.jms

io.smallrye.reactive.messaging.jms.impl - package io.smallrye.reactive.messaging.jms.impl

io.smallrye.reactive.messaging.kafka - package io.smallrye.reactive.messaging.kafka

io.smallrye.reactive.messaging.kafka.impl - package io.smallrye.reactive.messaging.kafka.impl

io.smallrye.reactive.messaging.metrics - package io.smallrye.reactive.messaging.metrics

io.smallrye.reactive.messaging.mqtt - package io.smallrye.reactive.messaging.mqtt

io.smallrye.reactive.messaging.mqtt.server - package io.smallrye.reactive.messaging.mqtt.server

io.smallrye.reactive.messaging.tck - package io.smallrye.reactive.messaging.tck

isAssignable(Class<?>, Class<?>) - Static method in class io.smallrye.reactive.messaging.helpers.ClassUtils

Checks if one cls can be assigned to a variable of another toClass, like: Cls c = ...; ToClass x = c;

isAssignable(Type, Type) - Static method in class io.smallrye.reactive.messaging.helpers.TypeUtils

Checks if the subject type may be implicitly cast to the target type following the Java generics rules.

isBlank(String) - Static method in class io.smallrye.reactive.messaging.helpers.Validation

Checks if a given string is blank or null.

isBlocking() - Method in class io.smallrye.reactive.messaging.DefaultMediatorConfiguration

isBlocking() - Method in interface io.smallrye.reactive.messaging.MediatorConfiguration

isBlockingExecutionOrdered() - Method in class io.smallrye.reactive.messaging.DefaultMediatorConfiguration

isBlockingExecutionOrdered() - Method in interface io.smallrye.reactive.messaging.MediatorConfiguration

isBodyAssignableTo(Class<?>) - Method in class io.smallrye.reactive.messaging.jms.IncomingJmsMessageMetadata

isCancelled() - Method in interface io.smallrye.reactive.messaging.annotations.Emitter

Deprecated.

isCancelled() - Method in class io.smallrye.reactive.messaging.extension.EmitterImpl

isCancelled() - Method in class io.smallrye.reactive.messaging.extension.LegacyEmitterImpl

isCancelled() - Method in interface org.eclipse.microprofile.reactive.messaging.Emitter

isConnected() - Method in class io.smallrye.reactive.messaging.AbstractMediator

isConnected() - Method in class io.smallrye.reactive.messaging.ProcessorMediator

isConnected() - Method in class io.smallrye.reactive.messaging.PublisherMediator

isConnected() - Method in class io.smallrye.reactive.messaging.StreamTransformerMediator

isConnected() - Method in class io.smallrye.reactive.messaging.SubscriberMediator

isDuplicate() - Method in interface io.smallrye.reactive.messaging.mqtt.MqttMessage

isDuplicate() - Method in class io.smallrye.reactive.messaging.mqtt.ReceivingMqttMessage

isDuplicate() - Method in class io.smallrye.reactive.messaging.mqtt.SendingMqttMessage

isDuplicate() - Method in class io.smallrye.reactive.messaging.mqtt.server.MqttMessage

isDurable() - Method in class io.smallrye.reactive.messaging.amqp.AmqpMessage

isDurable() - Method in class io.smallrye.reactive.messaging.amqp.IncomingAmqpMetadata

isDurable() - Method in class io.smallrye.reactive.messaging.amqp.OutgoingAmqpMessage

isDurable() - Method in class io.smallrye.reactive.messaging.amqp.OutgoingAmqpMetadata

isFirstAcquirer() - Method in class io.smallrye.reactive.messaging.amqp.IncomingAmqpMetadata

isInitialized() - Method in class io.smallrye.reactive.messaging.extension.MediatorManager

isMockPubSubTopics() - Method in class io.smallrye.reactive.messaging.gcp.pubsub.PubSubConfig

isReady() - Method in class io.smallrye.reactive.messaging.mqtt.MqttConnector

isReady() - Method in class io.smallrye.reactive.messaging.mqtt.MqttSink

isRedelivered() - Method in class io.smallrye.reactive.messaging.jms.IncomingJmsMessageMetadata

isRequested() - Method in interface io.smallrye.reactive.messaging.annotations.Emitter

Deprecated.

isRequested() - Method in class io.smallrye.reactive.messaging.extension.EmitterImpl

isRequested() - Method in class io.smallrye.reactive.messaging.extension.LegacyEmitterImpl

isRequested() - Method in interface org.eclipse.microprofile.reactive.messaging.Emitter

isRetain() - Method in interface io.smallrye.reactive.messaging.mqtt.MqttMessage

isRetain() - Method in class io.smallrye.reactive.messaging.mqtt.ReceivingMqttMessage

isRetain() - Method in class io.smallrye.reactive.messaging.mqtt.SendingMqttMessage

isRetain() - Method in class io.smallrye.reactive.messaging.mqtt.server.MqttMessage

isTrue(boolean, String, Object...) - Static method in class io.smallrye.reactive.messaging.helpers.Validation

iterator() - Method in class org.eclipse.microprofile.reactive.messaging.Metadata

J

JmsConnector - Class in io.smallrye.reactive.messaging.jms

JmsConnector() - Constructor for class io.smallrye.reactive.messaging.jms.JmsConnector

JmsConnectorCommonConfiguration - Class in io.smallrye.reactive.messaging.jms

Extracts the common configuration for the smallrye-jms connector.

JmsConnectorCommonConfiguration(Config) - Constructor for class io.smallrye.reactive.messaging.jms.JmsConnectorCommonConfiguration

Creates a new JmsConnectorCommonConfiguration.

JmsConnectorIncomingConfiguration - Class in io.smallrye.reactive.messaging.jms

Extract the incoming configuration for the smallrye-jms connector.

JmsConnectorIncomingConfiguration(Config) - Constructor for class io.smallrye.reactive.messaging.jms.JmsConnectorIncomingConfiguration

Creates a new JmsConnectorIncomingConfiguration.

JmsConnectorOutgoingConfiguration - Class in io.smallrye.reactive.messaging.jms

Extract the outgoing configuration for the smallrye-jms connector.

JmsConnectorOutgoingConfiguration(Config) - Constructor for class io.smallrye.reactive.messaging.jms.JmsConnectorOutgoingConfiguration

Creates a new JmsConnectorOutgoingConfiguration.

JmsMessageMetadata - Interface in io.smallrye.reactive.messaging.jms

JmsProperties - Interface in io.smallrye.reactive.messaging.jms

Structure handling JMS Message properties.

JmsPropertiesBuilder - Class in io.smallrye.reactive.messaging.jms

JmsPropertiesBuilder() - Constructor for class io.smallrye.reactive.messaging.jms.JmsPropertiesBuilder

JmsPropertiesBuilder.OutgoingJmsProperties - Class in io.smallrye.reactive.messaging.jms

JmsPropertiesBuilder.Property<T> - Class in io.smallrye.reactive.messaging.jms

JmsTask - Interface in io.smallrye.reactive.messaging.jms.impl

JsonArraySerializer - Class in io.smallrye.reactive.messaging.http.converters

JsonArraySerializer() - Constructor for class io.smallrye.reactive.messaging.http.converters.JsonArraySerializer

JsonHelper - Class in io.smallrye.reactive.messaging.http

JsonHelper - Class in io.smallrye.reactive.messaging.kafka.impl

JsonHelper() - Constructor for class io.smallrye.reactive.messaging.http.JsonHelper

JsonHelper() - Constructor for class io.smallrye.reactive.messaging.kafka.impl.JsonHelper

JsonObjectSerializer - Class in io.smallrye.reactive.messaging.http.converters

JsonObjectSerializer() - Constructor for class io.smallrye.reactive.messaging.http.converters.JsonObjectSerializer

K

KafkaConnector - Class in io.smallrye.reactive.messaging.kafka

KafkaConnector() - Constructor for class io.smallrye.reactive.messaging.kafka.KafkaConnector

KafkaConnectorCommonConfiguration - Class in io.smallrye.reactive.messaging.kafka

Extracts the common configuration for the smallrye-kafka connector.

KafkaConnectorCommonConfiguration(Config) - Constructor for class io.smallrye.reactive.messaging.kafka.KafkaConnectorCommonConfiguration

Creates a new KafkaConnectorCommonConfiguration.

KafkaConnectorIncomingConfiguration - Class in io.smallrye.reactive.messaging.kafka

Extract the incoming configuration for the smallrye-kafka connector.

KafkaConnectorIncomingConfiguration(Config) - Constructor for class io.smallrye.reactive.messaging.kafka.KafkaConnectorIncomingConfiguration

Creates a new KafkaConnectorIncomingConfiguration.

KafkaConnectorOutgoingConfiguration - Class in io.smallrye.reactive.messaging.kafka

Extract the outgoing configuration for the smallrye-kafka connector.

KafkaConnectorOutgoingConfiguration(Config) - Constructor for class io.smallrye.reactive.messaging.kafka.KafkaConnectorOutgoingConfiguration

Creates a new KafkaConnectorOutgoingConfiguration.

KafkaMessage<K,T> - Interface in io.smallrye.reactive.messaging.kafka

Deprecated.

Use instead

KafkaMessageMetadata<K> - Interface in io.smallrye.reactive.messaging.kafka

KafkaRecord<K,T> - Interface in io.smallrye.reactive.messaging.kafka

KafkaSink - Class in io.smallrye.reactive.messaging.kafka.impl

KafkaSink(Vertx, KafkaConnectorOutgoingConfiguration) - Constructor for class io.smallrye.reactive.messaging.kafka.impl.KafkaSink

KafkaSource<K,V> - Class in io.smallrye.reactive.messaging.kafka.impl

KafkaSource(Vertx, KafkaConnectorIncomingConfiguration) - Constructor for class io.smallrye.reactive.messaging.kafka.impl.KafkaSource

L

LATEST - io.smallrye.reactive.messaging.annotations.OnOverflow.Strategy

Deprecated.

Keeps only the latest value, dropping any previous values if the downstream can't keep up.

LATEST - org.eclipse.microprofile.reactive.messaging.OnOverflow.Strategy

Keeps only the latest value, dropping any previous value if the downstream can't keep up.

LegacyConfiguredChannelFactory - Class in io.smallrye.reactive.messaging.impl

Look for stream factories and get instances.

LegacyConfiguredChannelFactory() - Constructor for class io.smallrye.reactive.messaging.impl.LegacyConfiguredChannelFactory

LegacyConfiguredChannelFactory(Instance<IncomingConnectorFactory>, Instance<OutgoingConnectorFactory>, Instance<Config>, Instance<ChannelRegistry>, BeanManager) - Constructor for class io.smallrye.reactive.messaging.impl.LegacyConfiguredChannelFactory

LegacyEmitterImpl<T> - Class in io.smallrye.reactive.messaging.extension

Implementation of the old (legacy) Emitter interface.

LOGGER - Static variable in class io.smallrye.reactive.messaging.connector.ClassWriter

lookup(Object, String) - Static method in class io.smallrye.reactive.messaging.http.converters.Serializer

M

main(String[]) - Static method in class acme.Main

main(String[]) - Static method in class awssns.Main

main(String[]) - Static method in class gcp.pubsub.Main

main(String[]) - Static method in class io.smallrye.reactive.messaging.example.eventclouds.Main

Main - Class in acme

Main - Class in awssns

Main - Class in gcp.pubsub

Main - Class in io.smallrye.reactive.messaging.example.eventclouds

Main() - Constructor for class acme.Main

Main() - Constructor for class awssns.Main

Main() - Constructor for class gcp.pubsub.Main

Main() - Constructor for class io.smallrye.reactive.messaging.example.eventclouds.Main

managePreProcessingAck() - Method in class io.smallrye.reactive.messaging.AbstractMediator

mandatory() - Method in annotation type io.smallrye.reactive.messaging.annotations.ConnectorAttribute

MANUAL - org.eclipse.microprofile.reactive.messaging.Acknowledgment.Strategy

Acknowledgment managed by the user code.

MediatorConfiguration - Interface in io.smallrye.reactive.messaging

MediatorConfiguration.Consumption - Enum in io.smallrye.reactive.messaging

MediatorConfiguration.Production - Enum in io.smallrye.reactive.messaging

MediatorConfigurationSupport - Class in io.smallrye.reactive.messaging

MediatorConfigurationSupport(String, Class<?>, Class<?>[], MediatorConfigurationSupport.GenericTypeAssignable, MediatorConfigurationSupport.GenericTypeAssignable) - Constructor for class io.smallrye.reactive.messaging.MediatorConfigurationSupport

MediatorConfigurationSupport.GenericTypeAssignable - Interface in io.smallrye.reactive.messaging

MediatorConfigurationSupport.GenericTypeAssignable.Result - Enum in io.smallrye.reactive.messaging

MediatorConfigurationSupport.ValidationOutput - Class in io.smallrye.reactive.messaging

MediatorFactory - Class in io.smallrye.reactive.messaging

MediatorFactory() - Constructor for class io.smallrye.reactive.messaging.MediatorFactory

MediatorManager - Class in io.smallrye.reactive.messaging.extension

Class responsible for managing mediators

MediatorManager() - Constructor for class io.smallrye.reactive.messaging.extension.MediatorManager

Merge - Annotation Type in io.smallrye.reactive.messaging.annotations

Temporary annotation - must be copied to spec.

MERGE - io.smallrye.reactive.messaging.annotations.Merge.Mode

Merge the different sources.

Merge.Mode - Enum in io.smallrye.reactive.messaging.annotations

message - Variable in class io.smallrye.reactive.messaging.amqp.AmqpMessage

Message<T> - Interface in org.eclipse.microprofile.reactive.messaging

A message envelope.

MESSAGE - io.smallrye.reactive.messaging.MediatorConfiguration.Consumption

metadata - Variable in class io.smallrye.reactive.messaging.amqp.AmqpMessage

Metadata - Class in org.eclipse.microprofile.reactive.messaging

Message metadata containers.

methodAsString() - Method in class io.smallrye.reactive.messaging.DefaultMediatorConfiguration

methodAsString() - Method in interface io.smallrye.reactive.messaging.MediatorConfiguration

MetricDecorator - Class in io.smallrye.reactive.messaging.metrics

MetricDecorator() - Constructor for class io.smallrye.reactive.messaging.metrics.MetricDecorator

MqttConnector - Class in io.smallrye.reactive.messaging.mqtt

MqttConnector() - Constructor for class io.smallrye.reactive.messaging.mqtt.MqttConnector

MqttConnectorCommonConfiguration - Class in io.smallrye.reactive.messaging.mqtt

Extracts the common configuration for the smallrye-mqtt connector.

MqttConnectorCommonConfiguration(Config) - Constructor for class io.smallrye.reactive.messaging.mqtt.MqttConnectorCommonConfiguration

Creates a new MqttConnectorCommonConfiguration.

MqttConnectorIncomingConfiguration - Class in io.smallrye.reactive.messaging.mqtt

Extract the incoming configuration for the smallrye-mqtt connector.

MqttConnectorIncomingConfiguration(Config) - Constructor for class io.smallrye.reactive.messaging.mqtt.MqttConnectorIncomingConfiguration

Creates a new MqttConnectorIncomingConfiguration.

MqttConnectorOutgoingConfiguration - Class in io.smallrye.reactive.messaging.mqtt

Extract the outgoing configuration for the smallrye-mqtt connector.

MqttConnectorOutgoingConfiguration(Config) - Constructor for class io.smallrye.reactive.messaging.mqtt.MqttConnectorOutgoingConfiguration

Creates a new MqttConnectorOutgoingConfiguration.

MqttHelpers - Class in io.smallrye.reactive.messaging.mqtt

MqttMessage - Class in io.smallrye.reactive.messaging.mqtt.server

MqttMessage<T> - Interface in io.smallrye.reactive.messaging.mqtt

MqttServerConnector - Class in io.smallrye.reactive.messaging.mqtt.server

MqttServerConnectorCommonConfiguration - Class in io.smallrye.reactive.messaging.mqtt.server

Extracts the common configuration for the smallrye-mqtt-server connector.

MqttServerConnectorCommonConfiguration(Config) - Constructor for class io.smallrye.reactive.messaging.mqtt.server.MqttServerConnectorCommonConfiguration

Creates a new MqttServerConnectorCommonConfiguration.

MqttServerConnectorIncomingConfiguration - Class in io.smallrye.reactive.messaging.mqtt.server

Extract the incoming configuration for the smallrye-mqtt-server connector.

MqttServerConnectorIncomingConfiguration(Config) - Constructor for class io.smallrye.reactive.messaging.mqtt.server.MqttServerConnectorIncomingConfiguration

Creates a new MqttServerConnectorIncomingConfiguration.

MqttServerConnectorOutgoingConfiguration - Class in io.smallrye.reactive.messaging.mqtt.server

Extract the outgoing configuration for the smallrye-mqtt-server connector.

MqttServerConnectorOutgoingConfiguration(Config) - Constructor for class io.smallrye.reactive.messaging.mqtt.server.MqttServerConnectorOutgoingConfiguration

Creates a new MqttServerConnectorOutgoingConfiguration.

MqttServerQuickstart - Class in acme

MqttServerQuickstart() - Constructor for class acme.MqttServerQuickstart

MqttSink - Class in io.smallrye.reactive.messaging.mqtt

MqttSink(Vertx, MqttConnectorOutgoingConfiguration) - Constructor for class io.smallrye.reactive.messaging.mqtt.MqttSink

MqttSource - Class in io.smallrye.reactive.messaging.mqtt

MqttSource(Vertx, MqttConnectorIncomingConfiguration) - Constructor for class io.smallrye.reactive.messaging.mqtt.MqttSource

MyCloudEventProcessor - Class in io.smallrye.reactive.messaging.example.eventclouds

MyCloudEventProcessor() - Constructor for class io.smallrye.reactive.messaging.example.eventclouds.MyCloudEventProcessor

MyCloudEventSink - Class in io.smallrye.reactive.messaging.example.eventclouds

MyCloudEventSink() - Constructor for class io.smallrye.reactive.messaging.example.eventclouds.MyCloudEventSink

MyCloudEventSource - Class in io.smallrye.reactive.messaging.example.eventclouds

MyCloudEventSource() - Constructor for class io.smallrye.reactive.messaging.example.eventclouds.MyCloudEventSource

N

name() - Method in annotation type io.smallrye.reactive.messaging.annotations.ConnectorAttribute

name() - Method in interface io.smallrye.reactive.messaging.connectors.InMemorySink

name() - Method in interface io.smallrye.reactive.messaging.connectors.InMemorySource

name() - Method in class io.smallrye.reactive.messaging.jms.JmsPropertiesBuilder.Property

NO_VALUE - Static variable in annotation type io.smallrye.reactive.messaging.annotations.ConnectorAttribute

The constant used to indicate that the attribute has no default value or no alias.

NONE - io.smallrye.reactive.messaging.annotations.OnOverflow.Strategy

Deprecated.

The values are propagated without any back pressure strategy.

NONE - io.smallrye.reactive.messaging.MediatorConfiguration.Consumption

NONE - io.smallrye.reactive.messaging.MediatorConfiguration.Production

NONE - org.eclipse.microprofile.reactive.messaging.Acknowledgment.Strategy

No acknowledgment is performed, neither implicitly or explicitly.

NONE - org.eclipse.microprofile.reactive.messaging.OnOverflow.Strategy

The values are propagated without any back pressure strategy.

noNullElements(T[], String) - Static method in class io.smallrye.reactive.messaging.helpers.Validation

normalizeUpperBounds(Type[]) - Static method in class io.smallrye.reactive.messaging.helpers.TypeUtils

This method strips out the redundant upper bound types in type variable types and wildcard types (or it would with wildcard types if multiple upper bounds were allowed).

NotAssignable - io.smallrye.reactive.messaging.MediatorConfigurationSupport.GenericTypeAssignable.Result

notEmpty(T[], String) - Static method in class io.smallrye.reactive.messaging.helpers.Validation

NotGeneric - io.smallrye.reactive.messaging.MediatorConfigurationSupport.GenericTypeAssignable.Result

notNull(T, String) - Static method in class io.smallrye.reactive.messaging.helpers.Validation

O

of(Object...) - Static method in class org.eclipse.microprofile.reactive.messaging.Metadata

Returns an instance of Metadata containing multiple values.

of(String) - Static method in class org.eclipse.microprofile.reactive.messaging.spi.ConnectorLiteral

Creates a new instance of ConnectorLiteral.

of(String, K, T) - Static method in interface io.smallrye.reactive.messaging.kafka.KafkaMessage

Deprecated.

Creates a new outgoing kafka message.

of(String, K, T) - Static method in interface io.smallrye.reactive.messaging.kafka.KafkaRecord

Creates a new outgoing Kafka record.

of(String, K, T, Instant, int) - Static method in interface io.smallrye.reactive.messaging.kafka.KafkaMessage

Deprecated.

Creates a new outgoing kafka message.

of(String, K, T, Instant, int) - Static method in interface io.smallrye.reactive.messaging.kafka.KafkaRecord

Creates a new outgoing Kafka record.

of(String, T) - Static method in interface io.smallrye.reactive.messaging.mqtt.MqttMessage

of(String, T, MqttQoS) - Static method in interface io.smallrye.reactive.messaging.mqtt.MqttMessage

of(String, T, MqttQoS, boolean) - Static method in interface io.smallrye.reactive.messaging.mqtt.MqttMessage

of(String, T, Supplier<CompletionStage<Void>>) - Static method in interface io.smallrye.reactive.messaging.mqtt.MqttMessage

of(K, T) - Static method in interface io.smallrye.reactive.messaging.kafka.KafkaMessage

Deprecated.

Creates a new outgoing kafka message.

of(K, T) - Static method in interface io.smallrye.reactive.messaging.kafka.KafkaRecord

Creates a new outgoing Kafka record.

of(T) - Static method in interface io.smallrye.reactive.messaging.mqtt.MqttMessage

of(T) - Static method in interface org.eclipse.microprofile.reactive.messaging.Message

Create a message with the given payload.

of(T, Iterable<Object>) - Static method in interface org.eclipse.microprofile.reactive.messaging.Message

Create a message with the given payload and metadata.

of(T, Iterable<Object>, Supplier<CompletionStage<Void>>) - Static method in interface org.eclipse.microprofile.reactive.messaging.Message

Create a message with the given payload, metadata and ack function.

of(T, Supplier<CompletionStage<Void>>) - Static method in interface org.eclipse.microprofile.reactive.messaging.Message

Create a message with the given payload and ack function.

of(T, Metadata) - Static method in interface org.eclipse.microprofile.reactive.messaging.Message

Create a message with the given payload and metadata.

of(T, Metadata, Supplier<CompletionStage<Void>>) - Static method in interface org.eclipse.microprofile.reactive.messaging.Message

Create a message with the given payload, metadata and ack function.

onComplete() - Method in class io.smallrye.reactive.messaging.SubscriberWrapper

ONE - io.smallrye.reactive.messaging.annotations.Merge.Mode

Pick the first source and use only this one.

onError(Throwable) - Method in class io.smallrye.reactive.messaging.SubscriberWrapper

onNext(T) - Method in class io.smallrye.reactive.messaging.SubscriberWrapper

OnOverflow - Annotation Type in io.smallrye.reactive.messaging.annotations

Deprecated.

Use OnOverflow instead

OnOverflow - Annotation Type in org.eclipse.microprofile.reactive.messaging

Allows configuring the back pressure policy on injected Emitter:

OnOverflow.Strategy - Enum in io.smallrye.reactive.messaging.annotations

Deprecated.

The back pressure strategy.

OnOverflow.Strategy - Enum in org.eclipse.microprofile.reactive.messaging

The back pressure strategy.

onSubscribe(Subscription) - Method in class io.smallrye.reactive.messaging.SubscriberWrapper

options() - Method in class acme.AmqpConfiguration

options2() - Method in class acme.AmqpConfiguration

ordered() - Method in annotation type io.smallrye.reactive.messaging.annotations.Blocking

Indicates whether the execution on the worker pool should be ordered.

org.eclipse.microprofile.reactive.messaging - package org.eclipse.microprofile.reactive.messaging

IMPORTANT This package is a copy from the original package from the specification.

org.eclipse.microprofile.reactive.messaging.spi - package org.eclipse.microprofile.reactive.messaging.spi

The MicroProfile Reactive Messaging API Connector SPI

Outgoing - Annotation Type in org.eclipse.microprofile.reactive.messaging

Used to signify a publisher of outgoing messages.

OUTGOING - io.smallrye.reactive.messaging.annotations.ConnectorAttribute.Direction

OUTGOING_PREFIX - Static variable in interface org.eclipse.microprofile.reactive.messaging.spi.ConnectorFactory

Prefix used in the MicroProfile Config to configure an outgoing channel.

OutgoingAmqpMessage<T> - Class in io.smallrye.reactive.messaging.amqp

OutgoingAmqpMessage(AmqpMessage, OutgoingAmqpMetadata) - Constructor for class io.smallrye.reactive.messaging.amqp.OutgoingAmqpMessage

OutgoingAmqpMetadata - Class in io.smallrye.reactive.messaging.amqp

OutgoingAmqpMetadata(String, JsonObject, String, String, String, String, String, boolean, int, String, long) - Constructor for class io.smallrye.reactive.messaging.amqp.OutgoingAmqpMetadata

OutgoingAmqpMetadata.OutgoingAmqpMetadataBuilder - Class in io.smallrye.reactive.messaging.amqp

OutgoingConnectorFactory - Interface in org.eclipse.microprofile.reactive.messaging.spi

SPI used to implement a connector managing a sink of messages for a specific transport.

OutgoingExchangeMetadata - Class in io.smallrye.reactive.messaging.camel

OutgoingExchangeMetadata() - Constructor for class io.smallrye.reactive.messaging.camel.OutgoingExchangeMetadata

OutgoingJmsMessageMetadata - Class in io.smallrye.reactive.messaging.jms

OutgoingJmsMessageMetadata(String, Destination, Destination, int, String, JmsProperties) - Constructor for class io.smallrye.reactive.messaging.jms.OutgoingJmsMessageMetadata

OutgoingJmsMessageMetadata.OutgoingJmsMessageMetadataBuilder - Class in io.smallrye.reactive.messaging.jms

OutgoingJmsMessageMetadataBuilder() - Constructor for class io.smallrye.reactive.messaging.jms.OutgoingJmsMessageMetadata.OutgoingJmsMessageMetadataBuilder

OutgoingJmsProperties(Map<String, JmsPropertiesBuilder.Property<?>>) - Constructor for class io.smallrye.reactive.messaging.jms.JmsPropertiesBuilder.OutgoingJmsProperties

OutgoingKafkaRecord<K,T> - Class in io.smallrye.reactive.messaging.kafka

OutgoingKafkaRecord(String, K, T, Instant, int, Headers, Supplier<CompletionStage<Void>>) - Constructor for class io.smallrye.reactive.messaging.kafka.OutgoingKafkaRecord

OutgoingKafkaRecordMetadata<K> - Class in io.smallrye.reactive.messaging.kafka

OutgoingKafkaRecordMetadata(String, K, int, Instant, Headers) - Constructor for class io.smallrye.reactive.messaging.kafka.OutgoingKafkaRecordMetadata

OutgoingKafkaRecordMetadata.OutgoingKafkaRecordMetadataBuilder<K> - Class in io.smallrye.reactive.messaging.kafka

OutgoingKafkaRecordMetadataBuilder() - Constructor for class io.smallrye.reactive.messaging.kafka.OutgoingKafkaRecordMetadata.OutgoingKafkaRecordMetadataBuilder

output() - Method in interface io.smallrye.reactive.messaging.http.converters.Converter

output() - Method in class io.smallrye.reactive.messaging.http.converters.Serializer

P

PAYLOAD - io.smallrye.reactive.messaging.MediatorConfiguration.Consumption

periodicallySendMessage() - Method in class awssns.BeanUsingAnEmitter

periodicallySendMessage() - Method in class gcp.pubsub.BeanUsingAnEmitter

periodicallySendMessageToKafka() - Method in class acme.BeanUsingAnEmitter

POST_PROCESSING - org.eclipse.microprofile.reactive.messaging.Acknowledgment.Strategy

Acknowledgment performed automatically once the message has been processed.

PRE_PROCESSING - org.eclipse.microprofile.reactive.messaging.Acknowledgment.Strategy

Acknowledgment performed automatically before the processing of the message by the user code.

preDestroy() - Method in class io.smallrye.reactive.messaging.aws.sns.SnsConnector

Its being invoked before bean being destroyed.

primitiveToWrapper(Class<?>) - Static method in class io.smallrye.reactive.messaging.helpers.ClassUtils

Converts the specified primitive Class object to its corresponding wrapper Class object.

process(CloudEventMessage<String>) - Method in class io.smallrye.reactive.messaging.example.eventclouds.MyCloudEventProcessor

process(Set<? extends TypeElement>, RoundEnvironment) - Method in class io.smallrye.reactive.messaging.connector.ConnectorAttributeProcessor

processBroadcast(Object, Supplier<Integer>) - Method in class io.smallrye.reactive.messaging.MediatorConfigurationSupport

processDefaultAcknowledgement(Shape, MediatorConfiguration.Consumption) - Method in class io.smallrye.reactive.messaging.MediatorConfigurationSupport

ProcessingException - Exception in io.smallrye.reactive.messaging

ProcessingException(String, Throwable) - Constructor for exception io.smallrye.reactive.messaging.ProcessingException

processMerge(List<?>, Supplier<Merge.Mode>) - Method in class io.smallrye.reactive.messaging.MediatorConfigurationSupport

PROCESSOR - io.smallrye.reactive.messaging.Shape

ProcessorMediator - Class in io.smallrye.reactive.messaging

ProcessorMediator(MediatorConfiguration) - Constructor for class io.smallrye.reactive.messaging.ProcessorMediator

processSuppliedAcknowledgement(List<?>, Supplier<Acknowledgment.Strategy>) - Method in class io.smallrye.reactive.messaging.MediatorConfigurationSupport

production() - Method in class io.smallrye.reactive.messaging.DefaultMediatorConfiguration

production() - Method in interface io.smallrye.reactive.messaging.MediatorConfiguration

propertyExists(String) - Method in class io.smallrye.reactive.messaging.jms.impl.ImmutableJmsProperties

propertyExists(String) - Method in class io.smallrye.reactive.messaging.jms.IncomingJmsMessageMetadata

propertyExists(String) - Method in interface io.smallrye.reactive.messaging.jms.JmsProperties

Indicates whether a property value exists.

propertyExists(String) - Method in class io.smallrye.reactive.messaging.jms.JmsPropertiesBuilder.OutgoingJmsProperties

publisher(PubSubConfig) - Method in class io.smallrye.reactive.messaging.gcp.pubsub.PubSubManager

PUBLISHER - io.smallrye.reactive.messaging.Shape

PublisherDecorator - Interface in io.smallrye.reactive.messaging

SPI to allow extension of publishers included in the final graph

PublisherMediator - Class in io.smallrye.reactive.messaging

PublisherMediator(MediatorConfiguration) - Constructor for class io.smallrye.reactive.messaging.PublisherMediator

PubSubConfig - Class in io.smallrye.reactive.messaging.gcp.pubsub

PubSubConfig(String, String, Path, boolean, String, Integer) - Constructor for class io.smallrye.reactive.messaging.gcp.pubsub.PubSubConfig

PubSubConfig(String, String, Path, String, boolean, String, Integer) - Constructor for class io.smallrye.reactive.messaging.gcp.pubsub.PubSubConfig

PubSubConnector - Class in io.smallrye.reactive.messaging.gcp.pubsub

PubSubConnector() - Constructor for class io.smallrye.reactive.messaging.gcp.pubsub.PubSubConnector

PubSubManager - Class in io.smallrye.reactive.messaging.gcp.pubsub

PubSubManager() - Constructor for class io.smallrye.reactive.messaging.gcp.pubsub.PubSubManager

PubSubMessage - Class in io.smallrye.reactive.messaging.gcp.pubsub

PubSubMessage(PubsubMessage) - Constructor for class io.smallrye.reactive.messaging.gcp.pubsub.PubSubMessage

PubSubMessage(PubsubMessage, AckReplyConsumer) - Constructor for class io.smallrye.reactive.messaging.gcp.pubsub.PubSubMessage

PubSubMessageReceiver - Class in io.smallrye.reactive.messaging.gcp.pubsub

PubSubMessageReceiver(MultiEmitter<? super Message<?>>) - Constructor for class io.smallrye.reactive.messaging.gcp.pubsub.PubSubMessageReceiver

PubSubSource - Class in io.smallrye.reactive.messaging.gcp.pubsub

PubSubSource(PubSubConfig, PubSubManager) - Constructor for class io.smallrye.reactive.messaging.gcp.pubsub.PubSubSource

putProperty(String, Object) - Method in class io.smallrye.reactive.messaging.camel.OutgoingExchangeMetadata

R

ReactiveMessagingExtension - Class in io.smallrye.reactive.messaging.extension

ReactiveMessagingExtension() - Constructor for class io.smallrye.reactive.messaging.extension.ReactiveMessagingExtension

receive(String) - Method in class io.smallrye.reactive.messaging.example.eventclouds.MyCloudEventSink

received() - Method in interface io.smallrye.reactive.messaging.connectors.InMemorySink

receiveMessage(PubsubMessage, AckReplyConsumer) - Method in class io.smallrye.reactive.messaging.gcp.pubsub.PubSubMessageReceiver

Receiver - Class in acme

Receiver - Class in awssns

Receiver - Class in gcp.pubsub

Receiver() - Constructor for class acme.Receiver

Receiver() - Constructor for class awssns.Receiver

Receiver() - Constructor for class gcp.pubsub.Receiver

ReceivingMqttMessage - Class in io.smallrye.reactive.messaging.mqtt

register(String, Emitter<?>) - Method in interface io.smallrye.reactive.messaging.ChannelRegistry

register(String, Emitter<?>) - Method in class io.smallrye.reactive.messaging.impl.InternalChannelRegistry

register(String, PublisherBuilder<? extends Message<?>>) - Method in interface io.smallrye.reactive.messaging.ChannelRegistry

register(String, PublisherBuilder<? extends Message<?>>) - Method in class io.smallrye.reactive.messaging.impl.InternalChannelRegistry

register(String, SubscriberBuilder<? extends Message<?>, Void>) - Method in interface io.smallrye.reactive.messaging.ChannelRegistry

register(String, SubscriberBuilder<? extends Message<?>, Void>) - Method in class io.smallrye.reactive.messaging.impl.InternalChannelRegistry

registry - Variable in class io.smallrye.reactive.messaging.impl.ConfiguredChannelFactory

removeProperty(String) - Method in class io.smallrye.reactive.messaging.camel.OutgoingExchangeMetadata

run() - Method in class io.smallrye.reactive.messaging.AbstractMediator

run() - Method in class io.smallrye.reactive.messaging.SubscriberMediator

S

send() - Method in class acme.Sender

send(M) - Method in class io.smallrye.reactive.messaging.extension.EmitterImpl

send(M) - Method in interface org.eclipse.microprofile.reactive.messaging.Emitter

Sends a payload to the channel.

send(T) - Method in interface io.smallrye.reactive.messaging.annotations.Emitter

Deprecated.

Sends a payload or a message to the stream.

send(T) - Method in interface io.smallrye.reactive.messaging.connectors.InMemorySource

Sends a message or a payload to the channel.

send(T) - Method in class io.smallrye.reactive.messaging.extension.EmitterImpl

send(T) - Method in class io.smallrye.reactive.messaging.extension.LegacyEmitterImpl

send(T) - Method in interface org.eclipse.microprofile.reactive.messaging.Emitter

Sends a payload to the channel.

Sender - Class in acme

Sender() - Constructor for class acme.Sender

SendingMqttMessage<T> - Class in io.smallrye.reactive.messaging.mqtt

Serializer<I> - Class in io.smallrye.reactive.messaging.http.converters

Serializer() - Constructor for class io.smallrye.reactive.messaging.http.converters.Serializer

setDecorators(Instance<PublisherDecorator>) - Method in class io.smallrye.reactive.messaging.AbstractMediator

setExchangePattern(ExchangePattern) - Method in class io.smallrye.reactive.messaging.camel.OutgoingExchangeMetadata

setInvoker(Invoker) - Method in class io.smallrye.reactive.messaging.AbstractMediator

setWorkerPoolRegistry(WorkerPoolRegistry) - Method in class io.smallrye.reactive.messaging.AbstractMediator

shape() - Method in class io.smallrye.reactive.messaging.DefaultMediatorConfiguration

shape() - Method in interface io.smallrye.reactive.messaging.MediatorConfiguration

Shape - Enum in io.smallrye.reactive.messaging

sink(String) - Method in class acme.Main

sink(String) - Method in class io.smallrye.reactive.messaging.connectors.InMemoryConnector

Retrieves an InMemorySink associated to the channel named channel.

SmallRyeReactiveMessagingExtender - Class in io.smallrye.reactive.messaging.tck

SmallRyeReactiveMessagingExtender() - Constructor for class io.smallrye.reactive.messaging.tck.SmallRyeReactiveMessagingExtender

SnsConnector - Class in io.smallrye.reactive.messaging.aws.sns

Implement incoming/outgoing connection factories for Amazon Simple Notification Service reactive messaging.

SnsConnector() - Constructor for class io.smallrye.reactive.messaging.aws.sns.SnsConnector

SnsConnectorCommonConfiguration - Class in io.smallrye.reactive.messaging.aws.sns

Extracts the common configuration for the smallrye-aws-sns connector.

SnsConnectorCommonConfiguration(Config) - Constructor for class io.smallrye.reactive.messaging.aws.sns.SnsConnectorCommonConfiguration

Creates a new SnsConnectorCommonConfiguration.

SnsConnectorIncomingConfiguration - Class in io.smallrye.reactive.messaging.aws.sns

Extract the incoming configuration for the smallrye-aws-sns connector.

SnsConnectorIncomingConfiguration(Config) - Constructor for class io.smallrye.reactive.messaging.aws.sns.SnsConnectorIncomingConfiguration

Creates a new SnsConnectorIncomingConfiguration.

SnsConnectorOutgoingConfiguration - Class in io.smallrye.reactive.messaging.aws.sns

Extract the outgoing configuration for the smallrye-aws-sns connector.

SnsConnectorOutgoingConfiguration(Config) - Constructor for class io.smallrye.reactive.messaging.aws.sns.SnsConnectorOutgoingConfiguration

Creates a new SnsConnectorOutgoingConfiguration.

SnsMessage - Class in io.smallrye.reactive.messaging.aws.sns

Implementation of Message for SNS.

SnsMessage(SnsNotification) - Constructor for class io.smallrye.reactive.messaging.aws.sns.SnsMessage

Constructor for AWS SNS.

SnsMessage(String) - Constructor for class io.smallrye.reactive.messaging.aws.sns.SnsMessage

Constructor for fake SNS.

SnsVerticle - Class in io.smallrye.reactive.messaging.aws.sns

Vert.x verticle that handles subscription to SNS topic and receive notifications from topic.

SnsVerticle(String, String, int, boolean, String) - Constructor for class io.smallrye.reactive.messaging.aws.sns.SnsVerticle

Parameterized constructor.

source() - Method in class acme.Main

source() - Method in class io.smallrye.reactive.messaging.example.eventclouds.MyCloudEventSource

source(MqttMessage) - Method in class acme.MqttServerQuickstart

source(String) - Method in class io.smallrye.reactive.messaging.connectors.InMemoryConnector

Retrieves an InMemorySource associated to the channel named channel.

start(Promise<Void>) - Method in class io.smallrye.reactive.messaging.aws.sns.SnsVerticle

stop() - Method in class io.smallrye.reactive.messaging.http.HttpSource

STREAM_OF_MESSAGE - io.smallrye.reactive.messaging.MediatorConfiguration.Consumption

STREAM_OF_MESSAGE - io.smallrye.reactive.messaging.MediatorConfiguration.Production

STREAM_OF_PAYLOAD - io.smallrye.reactive.messaging.MediatorConfiguration.Consumption

STREAM_OF_PAYLOAD - io.smallrye.reactive.messaging.MediatorConfiguration.Production

STREAM_TRANSFORMER - io.smallrye.reactive.messaging.Shape

StreamTransformerMediator - Class in io.smallrye.reactive.messaging

StreamTransformerMediator(MediatorConfiguration) - Constructor for class io.smallrye.reactive.messaging.StreamTransformerMediator

STRICT_MODE_PROPERTY - Static variable in class io.smallrye.reactive.messaging.extension.MediatorManager

StringSerializer - Class in io.smallrye.reactive.messaging.http.converters

StringSerializer() - Constructor for class io.smallrye.reactive.messaging.http.converters.StringSerializer

subscribe(Subscriber<? super T>) - Method in class io.smallrye.reactive.messaging.SubscriberWrapper

subscriber(PubSubConfig, MultiEmitter<? super Message<?>>) - Method in class io.smallrye.reactive.messaging.gcp.pubsub.PubSubManager

SUBSCRIBER - io.smallrye.reactive.messaging.Shape

SubscriberMediator - Class in io.smallrye.reactive.messaging

SubscriberMediator(MediatorConfiguration) - Constructor for class io.smallrye.reactive.messaging.SubscriberMediator

SubscriberWrapper<I,T> - Class in io.smallrye.reactive.messaging

SubscriberWrapper(Subscriber<I>, Function<T, I>, Function<T, CompletionStage<Void>>) - Constructor for class io.smallrye.reactive.messaging.SubscriberWrapper

subscriptionAdminClient(PubSubConfig) - Method in class io.smallrye.reactive.messaging.gcp.pubsub.PubSubManager

switchIncomingChannelsToInMemory(String...) - Static method in class io.smallrye.reactive.messaging.connectors.InMemoryConnector

Switch the given incoming channel to in-memory.

switchOutgoingChannelsToInMemory(String...) - Static method in class io.smallrye.reactive.messaging.connectors.InMemoryConnector

Switch the given outgoing channel to in-memory.

T

terminate(Object) - Method in class io.smallrye.reactive.messaging.amqp.AmqpConnector

terminate(Object) - Method in class io.smallrye.reactive.messaging.connectors.ExecutionHolder

terminate(Object) - Method in class io.smallrye.reactive.messaging.connectors.WorkerPoolRegistry

terminate(Object) - Method in class io.smallrye.reactive.messaging.kafka.KafkaConnector

terminate(Object) - Method in class io.smallrye.reactive.messaging.mqtt.server.MqttServerConnector

topicAdminClient(PubSubConfig) - Method in class io.smallrye.reactive.messaging.gcp.pubsub.PubSubManager

toString() - Method in class io.smallrye.reactive.messaging.cloudevents.DefaultCloudEventMessage

toString() - Method in class io.smallrye.reactive.messaging.gcp.pubsub.PubSubConfig

toString() - Method in class io.smallrye.reactive.messaging.gcp.pubsub.PubSubMessage

toString(Type) - Static method in class io.smallrye.reactive.messaging.helpers.TypeUtils

toUpperCase(String) - Method in class acme.Main

type() - Method in annotation type io.smallrye.reactive.messaging.annotations.ConnectorAttribute

TypeUtils - Class in io.smallrye.reactive.messaging.helpers

Utility methods focusing on type inspection, particularly with regard to generics.

U

UNBOUNDED_BUFFER - io.smallrye.reactive.messaging.annotations.OnOverflow.Strategy

Deprecated.

Buffers all values until the downstream consumes it.

UNBOUNDED_BUFFER - org.eclipse.microprofile.reactive.messaging.OnOverflow.Strategy

Buffers all values until the downstream consumes it.

UNI_OF_MESSAGE - io.smallrye.reactive.messaging.MediatorConfiguration.Production

UNI_OF_PAYLOAD - io.smallrye.reactive.messaging.MediatorConfiguration.Production

unwrap() - Method in class io.smallrye.reactive.messaging.amqp.AmqpMessage

unwrap() - Method in class io.smallrye.reactive.messaging.eventbus.EventBusMessage

unwrap(Class<C>) - Method in class io.smallrye.reactive.messaging.jms.IncomingJmsMessage

unwrap(Class<C>) - Method in interface org.eclipse.microprofile.reactive.messaging.Message

Returns an object of the specified type to allow access to the connector-specific Message implementation, and other classes.

usesBuilderTypes() - Method in class io.smallrye.reactive.messaging.DefaultMediatorConfiguration

usesBuilderTypes() - Method in interface io.smallrye.reactive.messaging.MediatorConfiguration

V

validate() - Method in class io.smallrye.reactive.messaging.amqp.AmqpConnectorCommonConfiguration

validate() - Method in class io.smallrye.reactive.messaging.amqp.AmqpConnectorIncomingConfiguration

validate() - Method in class io.smallrye.reactive.messaging.amqp.AmqpConnectorOutgoingConfiguration

validate() - Method in class io.smallrye.reactive.messaging.aws.sns.SnsConnectorCommonConfiguration

validate() - Method in class io.smallrye.reactive.messaging.aws.sns.SnsConnectorIncomingConfiguration

validate() - Method in class io.smallrye.reactive.messaging.aws.sns.SnsConnectorOutgoingConfiguration

validate() - Method in class io.smallrye.reactive.messaging.camel.CamelConnectorCommonConfiguration

validate() - Method in class io.smallrye.reactive.messaging.camel.CamelConnectorIncomingConfiguration

validate() - Method in class io.smallrye.reactive.messaging.camel.CamelConnectorOutgoingConfiguration

validate() - Method in class io.smallrye.reactive.messaging.eventbus.VertxEventBusConnectorCommonConfiguration

validate() - Method in class io.smallrye.reactive.messaging.eventbus.VertxEventBusConnectorIncomingConfiguration

validate() - Method in class io.smallrye.reactive.messaging.eventbus.VertxEventBusConnectorOutgoingConfiguration

validate() - Method in class io.smallrye.reactive.messaging.http.HttpConnectorCommonConfiguration

validate() - Method in class io.smallrye.reactive.messaging.http.HttpConnectorIncomingConfiguration

validate() - Method in class io.smallrye.reactive.messaging.http.HttpConnectorOutgoingConfiguration

validate() - Method in class io.smallrye.reactive.messaging.jms.JmsConnectorCommonConfiguration

validate() - Method in class io.smallrye.reactive.messaging.jms.JmsConnectorIncomingConfiguration

validate() - Method in class io.smallrye.reactive.messaging.jms.JmsConnectorOutgoingConfiguration

validate() - Method in class io.smallrye.reactive.messaging.kafka.KafkaConnectorCommonConfiguration

validate() - Method in class io.smallrye.reactive.messaging.kafka.KafkaConnectorIncomingConfiguration

validate() - Method in class io.smallrye.reactive.messaging.kafka.KafkaConnectorOutgoingConfiguration

validate() - Method in class io.smallrye.reactive.messaging.mqtt.MqttConnectorCommonConfiguration

validate() - Method in class io.smallrye.reactive.messaging.mqtt.MqttConnectorIncomingConfiguration

validate() - Method in class io.smallrye.reactive.messaging.mqtt.MqttConnectorOutgoingConfiguration

validate() - Method in class io.smallrye.reactive.messaging.mqtt.server.MqttServerConnectorCommonConfiguration

validate() - Method in class io.smallrye.reactive.messaging.mqtt.server.MqttServerConnectorIncomingConfiguration

validate() - Method in class io.smallrye.reactive.messaging.mqtt.server.MqttServerConnectorOutgoingConfiguration

validate(Shape, Acknowledgment.Strategy) - Method in class io.smallrye.reactive.messaging.MediatorConfigurationSupport

validateBlocking(MediatorConfigurationSupport.ValidationOutput) - Method in class io.smallrye.reactive.messaging.MediatorConfigurationSupport

Validation - Class in io.smallrye.reactive.messaging.helpers

ValidationOutput(MediatorConfiguration.Production, MediatorConfiguration.Consumption) - Constructor for class io.smallrye.reactive.messaging.MediatorConfigurationSupport.ValidationOutput

ValidationOutput(MediatorConfiguration.Production, MediatorConfiguration.Consumption, Boolean) - Constructor for class io.smallrye.reactive.messaging.MediatorConfigurationSupport.ValidationOutput

value() - Method in annotation type io.smallrye.reactive.messaging.annotations.Blocking

Indicates the name of the worker pool to use for execution.

value() - Method in annotation type io.smallrye.reactive.messaging.annotations.Broadcast

Indicates the number of subscribers required before dispatching the items.

value() - Method in annotation type io.smallrye.reactive.messaging.annotations.Channel

Deprecated.

The name of the channel.

value() - Method in annotation type io.smallrye.reactive.messaging.annotations.ConnectorAttributes

value() - Method in annotation type io.smallrye.reactive.messaging.annotations.Incomings

value() - Method in annotation type io.smallrye.reactive.messaging.annotations.Merge

value() - Method in annotation type io.smallrye.reactive.messaging.annotations.OnOverflow

Deprecated.

value() - Method in class io.smallrye.reactive.messaging.jms.JmsPropertiesBuilder.Property

value() - Method in annotation type org.eclipse.microprofile.reactive.messaging.Acknowledgment

value() - Method in annotation type org.eclipse.microprofile.reactive.messaging.Channel

The name of the channel (indicated in the @Outgoing annotation.

value() - Method in annotation type org.eclipse.microprofile.reactive.messaging.Incoming

The name of the consumed channel.

value() - Method in annotation type org.eclipse.microprofile.reactive.messaging.OnOverflow

value() - Method in annotation type org.eclipse.microprofile.reactive.messaging.Outgoing

The name of the channel to publish to.

value() - Method in annotation type org.eclipse.microprofile.reactive.messaging.spi.Connector

value() - Method in class org.eclipse.microprofile.reactive.messaging.spi.ConnectorLiteral

valueOf(String) - Static method in enum io.smallrye.reactive.messaging.annotations.ConnectorAttribute.Direction

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum io.smallrye.reactive.messaging.annotations.Merge.Mode

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum io.smallrye.reactive.messaging.annotations.OnOverflow.Strategy

Deprecated.

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum io.smallrye.reactive.messaging.MediatorConfiguration.Consumption

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum io.smallrye.reactive.messaging.MediatorConfiguration.Production

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum io.smallrye.reactive.messaging.MediatorConfigurationSupport.GenericTypeAssignable.Result

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum io.smallrye.reactive.messaging.Shape

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.eclipse.microprofile.reactive.messaging.Acknowledgment.Strategy

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.eclipse.microprofile.reactive.messaging.OnOverflow.Strategy

Returns the enum constant of this type with the specified name.

values() - Static method in enum io.smallrye.reactive.messaging.annotations.ConnectorAttribute.Direction

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum io.smallrye.reactive.messaging.annotations.Merge.Mode

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum io.smallrye.reactive.messaging.annotations.OnOverflow.Strategy

Deprecated.

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum io.smallrye.reactive.messaging.MediatorConfiguration.Consumption

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum io.smallrye.reactive.messaging.MediatorConfiguration.Production

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum io.smallrye.reactive.messaging.MediatorConfigurationSupport.GenericTypeAssignable.Result

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum io.smallrye.reactive.messaging.Shape

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.eclipse.microprofile.reactive.messaging.Acknowledgment.Strategy

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.eclipse.microprofile.reactive.messaging.OnOverflow.Strategy

Returns an array containing the constants of this enum type, in the order they are declared.

vertx() - Method in class io.smallrye.reactive.messaging.connectors.ExecutionHolder

VertxEventBusConnector - Class in io.smallrye.reactive.messaging.eventbus

VertxEventBusConnector() - Constructor for class io.smallrye.reactive.messaging.eventbus.VertxEventBusConnector

VertxEventBusConnectorCommonConfiguration - Class in io.smallrye.reactive.messaging.eventbus

Extracts the common configuration for the smallrye-vertx-eventbus connector.

VertxEventBusConnectorCommonConfiguration(Config) - Constructor for class io.smallrye.reactive.messaging.eventbus.VertxEventBusConnectorCommonConfiguration

Creates a new VertxEventBusConnectorCommonConfiguration.

VertxEventBusConnectorIncomingConfiguration - Class in io.smallrye.reactive.messaging.eventbus

Extract the incoming configuration for the smallrye-vertx-eventbus connector.

VertxEventBusConnectorIncomingConfiguration(Config) - Constructor for class io.smallrye.reactive.messaging.eventbus.VertxEventBusConnectorIncomingConfiguration

Creates a new VertxEventBusConnectorIncomingConfiguration.

VertxEventBusConnectorOutgoingConfiguration - Class in io.smallrye.reactive.messaging.eventbus

Extract the outgoing configuration for the smallrye-vertx-eventbus connector.

VertxEventBusConnectorOutgoingConfiguration(Config) - Constructor for class io.smallrye.reactive.messaging.eventbus.VertxEventBusConnectorOutgoingConfiguration

Creates a new VertxEventBusConnectorOutgoingConfiguration.

W

WeavingException - Exception in io.smallrye.reactive.messaging

WeavingException(String) - Constructor for exception io.smallrye.reactive.messaging.WeavingException

WeavingException(String, String, int) - Constructor for exception io.smallrye.reactive.messaging.WeavingException

WeavingException(String, Throwable) - Constructor for exception io.smallrye.reactive.messaging.WeavingException

Used when a synchronous error is caught during the subscription

WeavingException(List<String>, Throwable) - Constructor for exception io.smallrye.reactive.messaging.WeavingException

with(Object) - Method in class org.eclipse.microprofile.reactive.messaging.Metadata

Creates a new instance of Metadata with the current entries, plus meta.

with(String, boolean) - Method in class io.smallrye.reactive.messaging.jms.JmsPropertiesBuilder

with(String, byte) - Method in class io.smallrye.reactive.messaging.jms.JmsPropertiesBuilder

with(String, double) - Method in class io.smallrye.reactive.messaging.jms.JmsPropertiesBuilder

with(String, float) - Method in class io.smallrye.reactive.messaging.jms.JmsPropertiesBuilder

with(String, int) - Method in class io.smallrye.reactive.messaging.jms.JmsPropertiesBuilder

with(String, long) - Method in class io.smallrye.reactive.messaging.jms.JmsPropertiesBuilder

with(String, short) - Method in class io.smallrye.reactive.messaging.jms.JmsPropertiesBuilder

with(String, String) - Method in class io.smallrye.reactive.messaging.jms.JmsPropertiesBuilder

withAck(Supplier<CompletionStage<Void>>) - Method in class io.smallrye.reactive.messaging.http.HttpMessage.HttpMessageBuilder

withAck(Supplier<CompletionStage<Void>>) - Method in class io.smallrye.reactive.messaging.kafka.OutgoingKafkaRecord

withAck(Supplier<CompletionStage<Void>>) - Method in interface io.smallrye.reactive.messaging.mqtt.MqttMessage

withAck(Supplier<CompletionStage<Void>>) - Method in interface org.eclipse.microprofile.reactive.messaging.Message

Creates a new instance of Message with the given acknowledgement supplier.

withAddress(String) - Method in class io.smallrye.reactive.messaging.amqp.AmqpMessageBuilder

withAddress(String) - Method in class io.smallrye.reactive.messaging.amqp.OutgoingAmqpMetadata.OutgoingAmqpMetadataBuilder

withApplicationProperties(JsonObject) - Method in class io.smallrye.reactive.messaging.amqp.AmqpMessageBuilder

withBody(String) - Method in class io.smallrye.reactive.messaging.amqp.AmqpMessageBuilder

withBooleanAsBody(boolean) - Method in class io.smallrye.reactive.messaging.amqp.AmqpMessageBuilder

withBufferAsBody(Buffer) - Method in class io.smallrye.reactive.messaging.amqp.AmqpMessageBuilder

withByteAsBody(byte) - Method in class io.smallrye.reactive.messaging.amqp.AmqpMessageBuilder

withCharAsBody(char) - Method in class io.smallrye.reactive.messaging.amqp.AmqpMessageBuilder

withContentEncoding(String) - Method in class io.smallrye.reactive.messaging.amqp.AmqpMessageBuilder

withContentEncoding(String) - Method in class io.smallrye.reactive.messaging.amqp.OutgoingAmqpMetadata.OutgoingAmqpMetadataBuilder

withContentType(String) - Method in class io.smallrye.reactive.messaging.amqp.AmqpMessageBuilder

withContentType(String) - Method in class io.smallrye.reactive.messaging.amqp.OutgoingAmqpMetadata.OutgoingAmqpMetadataBuilder

withCorrelationId(String) - Method in class io.smallrye.reactive.messaging.amqp.AmqpMessageBuilder

withCorrelationId(String) - Method in class io.smallrye.reactive.messaging.amqp.OutgoingAmqpMetadata.OutgoingAmqpMetadataBuilder

withCorrelationId(String) - Method in class io.smallrye.reactive.messaging.jms.OutgoingJmsMessageMetadata.OutgoingJmsMessageMetadataBuilder

withData(T) - Method in class io.smallrye.reactive.messaging.cloudevents.CloudEventMessageBuilder

withDataContentType(String) - Method in class io.smallrye.reactive.messaging.cloudevents.CloudEventMessageBuilder

withDataschema(URI) - Method in class io.smallrye.reactive.messaging.cloudevents.CloudEventMessageBuilder

withDeliveryMode(int) - Method in class io.smallrye.reactive.messaging.jms.OutgoingJmsMessageMetadata.OutgoingJmsMessageMetadataBuilder

withDestination(Destination) - Method in class io.smallrye.reactive.messaging.jms.OutgoingJmsMessageMetadata.OutgoingJmsMessageMetadataBuilder

withDoubleAsBody(double) - Method in class io.smallrye.reactive.messaging.amqp.AmqpMessageBuilder

withDurable(boolean) - Method in class io.smallrye.reactive.messaging.amqp.AmqpMessageBuilder

withDurable(boolean) - Method in class io.smallrye.reactive.messaging.amqp.OutgoingAmqpMetadata.OutgoingAmqpMetadataBuilder

withExtension(ExtensionFormat) - Method in class io.smallrye.reactive.messaging.cloudevents.CloudEventMessageBuilder

withFloatAsBody(float) - Method in class io.smallrye.reactive.messaging.amqp.AmqpMessageBuilder

withGroupId(String) - Method in class io.smallrye.reactive.messaging.amqp.AmqpMessageBuilder

withGroupId(String) - Method in class io.smallrye.reactive.messaging.amqp.OutgoingAmqpMetadata.OutgoingAmqpMetadataBuilder

withHeader(String, byte[]) - Method in class io.smallrye.reactive.messaging.kafka.OutgoingKafkaRecord

Creates a new outgoing Kafka Message with a header added to the header list.

withHeader(String, String) - Method in class io.smallrye.reactive.messaging.http.HttpMessage.HttpMessageBuilder

withHeader(String, String) - Method in class io.smallrye.reactive.messaging.http.HttpResponseMetadata.HttpResponseMetadataBuilder

withHeader(String, String) - Method in class io.smallrye.reactive.messaging.kafka.OutgoingKafkaRecord

Creates a new outgoing Kafka Message with a header added to the header list.

withHeader(String, String, Charset) - Method in class io.smallrye.reactive.messaging.kafka.OutgoingKafkaRecord

Creates a new outgoing Kafka Message with a header added to the header list.

withHeader(String, List<String>) - Method in class io.smallrye.reactive.messaging.http.HttpMessage.HttpMessageBuilder

withHeaders(List<RecordHeader>) - Method in class io.smallrye.reactive.messaging.kafka.OutgoingKafkaRecordMetadata.OutgoingKafkaRecordMetadataBuilder

withHeaders(Map<String, List<String>>) - Method in class io.smallrye.reactive.messaging.http.HttpMessage.HttpMessageBuilder

withHeaders(Map<String, List<String>>) - Method in class io.smallrye.reactive.messaging.http.HttpResponseMetadata.HttpResponseMetadataBuilder

withHeaders(Headers) - Method in class io.smallrye.reactive.messaging.kafka.OutgoingKafkaRecordMetadata.OutgoingKafkaRecordMetadataBuilder

withId(String) - Method in class io.smallrye.reactive.messaging.amqp.AmqpMessageBuilder

withId(String) - Method in class io.smallrye.reactive.messaging.amqp.OutgoingAmqpMetadata.OutgoingAmqpMetadataBuilder

withId(String) - Method in class io.smallrye.reactive.messaging.cloudevents.CloudEventMessageBuilder

withInstantAsBody(Instant) - Method in class io.smallrye.reactive.messaging.amqp.AmqpMessageBuilder

withIntegerAsBody(int) - Method in class io.smallrye.reactive.messaging.amqp.AmqpMessageBuilder

withJsonArrayAsBody(JsonArray) - Method in class io.smallrye.reactive.messaging.amqp.AmqpMessageBuilder

withJsonObjectAsBody(JsonObject) - Method in class io.smallrye.reactive.messaging.amqp.AmqpMessageBuilder

withKey(K) - Method in class io.smallrye.reactive.messaging.kafka.OutgoingKafkaRecordMetadata.OutgoingKafkaRecordMetadataBuilder

withLongAsBody(long) - Method in class io.smallrye.reactive.messaging.amqp.AmqpMessageBuilder

withMetadata(Iterable<Object>) - Method in class io.smallrye.reactive.messaging.kafka.OutgoingKafkaRecord

withMetadata(Iterable<Object>) - Method in interface org.eclipse.microprofile.reactive.messaging.Message

Creates a new instance of Message with the specified metadata.

withMetadata(Metadata) - Method in class io.smallrye.reactive.messaging.kafka.OutgoingKafkaRecord

withMetadata(Metadata) - Method in interface org.eclipse.microprofile.reactive.messaging.Message

Creates a new instance of Message with the specified metadata.

withMethod(String) - Method in class io.smallrye.reactive.messaging.http.HttpMessage.HttpMessageBuilder

withMethod(String) - Method in class io.smallrye.reactive.messaging.http.HttpResponseMetadata.HttpResponseMetadataBuilder

without(Class<?>) - Method in class org.eclipse.microprofile.reactive.messaging.Metadata

Creates a new instance of Metadata with the current entries, minus the entry associated with the given class.

without(String) - Method in class io.smallrye.reactive.messaging.jms.JmsPropertiesBuilder

withoutHeader(String) - Method in class io.smallrye.reactive.messaging.http.HttpResponseMetadata.HttpResponseMetadataBuilder

withoutQueryParameter(String) - Method in class io.smallrye.reactive.messaging.http.HttpResponseMetadata.HttpResponseMetadataBuilder

withPartition(int) - Method in class io.smallrye.reactive.messaging.kafka.OutgoingKafkaRecordMetadata.OutgoingKafkaRecordMetadataBuilder

withPayload(P) - Method in class io.smallrye.reactive.messaging.kafka.OutgoingKafkaRecord

withPayload(P) - Method in interface org.eclipse.microprofile.reactive.messaging.Message

Creates a new instance of Message with the specified payload.

withPayload(T) - Method in class io.smallrye.reactive.messaging.http.HttpMessage.HttpMessageBuilder

withPriority(int) - Method in class io.smallrye.reactive.messaging.amqp.OutgoingAmqpMetadata.OutgoingAmqpMetadataBuilder

withPriority(short) - Method in class io.smallrye.reactive.messaging.amqp.AmqpMessageBuilder

withProperties(JmsProperties) - Method in class io.smallrye.reactive.messaging.jms.OutgoingJmsMessageMetadata.OutgoingJmsMessageMetadataBuilder

withProperties(JsonObject) - Method in class io.smallrye.reactive.messaging.amqp.OutgoingAmqpMetadata.OutgoingAmqpMetadataBuilder

withQueryParameter(String, String) - Method in class io.smallrye.reactive.messaging.http.HttpMessage.HttpMessageBuilder

withQueryParameter(String, String) - Method in class io.smallrye.reactive.messaging.http.HttpResponseMetadata.HttpResponseMetadataBuilder

withQueryParameter(String, List<String>) - Method in class io.smallrye.reactive.messaging.http.HttpMessage.HttpMessageBuilder

withQueryParameter(Map<String, List<String>>) - Method in class io.smallrye.reactive.messaging.http.HttpResponseMetadata.HttpResponseMetadataBuilder

withReplyTo(String) - Method in class io.smallrye.reactive.messaging.amqp.AmqpMessageBuilder

withReplyTo(Destination) - Method in class io.smallrye.reactive.messaging.jms.OutgoingJmsMessageMetadata.OutgoingJmsMessageMetadataBuilder

withReplyToGroupId(String) - Method in class io.smallrye.reactive.messaging.amqp.AmqpMessageBuilder

withShortAsBody(short) - Method in class io.smallrye.reactive.messaging.amqp.AmqpMessageBuilder

withSource(URI) - Method in class io.smallrye.reactive.messaging.cloudevents.CloudEventMessageBuilder

withSubject(String) - Method in class io.smallrye.reactive.messaging.amqp.AmqpMessageBuilder

withSubject(String) - Method in class io.smallrye.reactive.messaging.amqp.OutgoingAmqpMetadata.OutgoingAmqpMetadataBuilder

withSubject(String) - Method in class io.smallrye.reactive.messaging.cloudevents.CloudEventMessageBuilder

withSymbolAsBody(String) - Method in class io.smallrye.reactive.messaging.amqp.AmqpMessageBuilder

withTime(ZonedDateTime) - Method in class io.smallrye.reactive.messaging.cloudevents.CloudEventMessageBuilder

withTimestamp(Instant) - Method in class io.smallrye.reactive.messaging.kafka.OutgoingKafkaRecordMetadata.OutgoingKafkaRecordMetadataBuilder

withTopic(String) - Method in class io.smallrye.reactive.messaging.kafka.OutgoingKafkaRecordMetadata.OutgoingKafkaRecordMetadataBuilder

withTtl(long) - Method in class io.smallrye.reactive.messaging.amqp.AmqpMessageBuilder

withTtl(long) - Method in class io.smallrye.reactive.messaging.amqp.OutgoingAmqpMetadata.OutgoingAmqpMetadataBuilder

withType(String) - Method in class io.smallrye.reactive.messaging.cloudevents.CloudEventMessageBuilder

withType(String) - Method in class io.smallrye.reactive.messaging.jms.OutgoingJmsMessageMetadata.OutgoingJmsMessageMetadataBuilder

withUrl(String) - Method in class io.smallrye.reactive.messaging.http.HttpMessage.HttpMessageBuilder

withUrl(String) - Method in class io.smallrye.reactive.messaging.http.HttpResponseMetadata.HttpResponseMetadataBuilder

withUuidAsBody(UUID) - Method in class io.smallrye.reactive.messaging.amqp.AmqpMessageBuilder

workerPoolRegistry - Variable in class io.smallrye.reactive.messaging.AbstractMediator

WorkerPoolRegistry - Class in io.smallrye.reactive.messaging.connectors

WorkerPoolRegistry() - Constructor for class io.smallrye.reactive.messaging.connectors.WorkerPoolRegistry

wrap(JmsTask) - Static method in interface io.smallrye.reactive.messaging.jms.impl.JmsTask

wrap(Callable<R>) - Static method in class io.smallrye.reactive.messaging.jms.impl.Wrap

Wrap - Class in io.smallrye.reactive.messaging.jms.impl

A B C D E F G H I J K L M N O P R S T U V W
All Classes All Packages