All Classes Interface Summary Class Summary Enum Summary Exception Summary Annotation Types Summary
| Class |
Description |
| AbstractMediator |
|
| Acknowledgment |
Configure the acknowledgement policy for the given @Incoming.
|
| Acknowledgment.Strategy |
|
| AmqpConfiguration |
|
| AmqpConnector |
|
| AmqpConnectorCommonConfiguration |
Extracts the common configuration for the smallrye-amqp connector.
|
| AmqpConnectorIncomingConfiguration |
Extract the incoming configuration for the smallrye-amqp connector.
|
| AmqpConnectorOutgoingConfiguration |
Extract the outgoing configuration for the smallrye-amqp connector.
|
| AmqpMessage<T> |
|
| AmqpMessageBuilder<T> |
|
| BeanUsingAnEmitter |
|
| BeanUsingAnEmitter |
|
| BeanUsingAnEmitter |
|
| Blocking |
Identifies that a particular method performs blocking operations,
and as such should be executed on separate worker.
|
| Broadcast |
Configure if the annotated publisher should dispatch the messages to several subscribers.
|
| BufferSerializer |
|
| ByteArraySerializer |
|
| ByteBufferSerializer |
|
| CamelConnector |
|
| CamelConnectorCommonConfiguration |
Extracts the common configuration for the smallrye-camel connector.
|
| CamelConnectorIncomingConfiguration |
Extract the incoming configuration for the smallrye-camel connector.
|
| CamelConnectorOutgoingConfiguration |
Extract the outgoing configuration for the smallrye-camel connector.
|
| CamelMessage<T> |
|
| Channel |
Deprecated.
|
| Channel |
This qualifier indicates which channel should be injected / populated.
|
| ChannelProducer |
This component computes the right object to be injected into injection point using Channel and the
deprecated Channel. |
| ChannelRegistar |
|
| ChannelRegistry |
|
| ClassUtils |
Allows checking if a class can be assigned to a variable from another class.
|
| ClassWriter |
|
| Clients |
|
| Clients.ClientHolder |
|
| CloudEventMessage<T> |
Message extending Cloud Events.
|
| CloudEventMessageBuilder<T> |
|
| CloudEventSerializer |
|
| CommonConfigurationClassWriter |
Generates the parent class used by the incoming and outgoing configuration classes.
|
| ConfigurationClassWriter |
|
| ConfigurationDocWriter |
|
| ConfiguredChannelFactory |
Look for stream factories and get instances.
|
| Connector |
Qualifier used on connector implementations to indicate the associated underlying transport.
|
| ConnectorAttribute |
Annotation used to declare an attribute on the connector.
|
| ConnectorAttribute.Direction |
|
| ConnectorAttributeProcessor |
|
| ConnectorAttributes |
|
| ConnectorConfig |
Implementation of config used to configured the different messaging provider / connector.
|
| ConnectorFactory |
|
| ConnectorLiteral |
Supports inline instantiation of the Connector qualifier. |
| Converter<I,O> |
|
| DefaultCloudEventMessage<T> |
|
| DefaultMediatorConfiguration |
|
| Emitter<T> |
Deprecated.
|
| Emitter<T> |
Interface used to feed a stream from an imperative piece of code.
|
| EmitterImpl<T> |
Implementation of the emitter pattern.
|
| EventBusMessage<T> |
|
| EventBusSink |
|
| ExecutionHolder |
Provides common runtime services to connectors, such as a Vertx instance,
to avoid duplicating the creation and cleanup of shared components across connectors.
|
| HttpConnector |
|
| HttpConnectorCommonConfiguration |
Extracts the common configuration for the smallrye-http connector.
|
| HttpConnectorIncomingConfiguration |
Extract the incoming configuration for the smallrye-http connector.
|
| HttpConnectorOutgoingConfiguration |
Extract the outgoing configuration for the smallrye-http connector.
|
| HttpMessage<T> |
|
| HttpMessage.HttpMessageBuilder<T> |
|
| HttpRequestMetadata |
Metadata for incoming HTTP messages.
|
| HttpResponseMetadata |
Metadata for outgoing HTTP messages handled by the HTTP connector.
|
| HttpResponseMetadata.HttpResponseMetadataBuilder |
|
| HttpSource |
|
| ImmutableJmsProperties |
|
| Incoming |
Used to signify a subscriber to incoming messages.
|
| IncomingAmqpMetadata |
|
| IncomingConnectorFactory |
SPI used to implement a connector managing a source of messages for a specific transport.
|
| IncomingExchangeMetadata |
|
| IncomingJmsMessage<T> |
|
| IncomingJmsMessageMetadata |
|
| IncomingKafkaRecord<K,T> |
|
| IncomingKafkaRecordMetadata<K,T> |
|
| Incomings |
This class is used to allow multiple Incoming declarations. |
| InMemoryConnector |
An implementation of connector used for testing applications without having to use external broker.
|
| InMemorySink<T> |
Allows interacting with an in-memory sink.
|
| InMemorySource<T> |
Allows interacting with an in-memory source.
|
| InternalChannelRegistry |
|
| Invoker |
|
| JmsConnector |
|
| JmsConnectorCommonConfiguration |
Extracts the common configuration for the smallrye-jms connector.
|
| JmsConnectorIncomingConfiguration |
Extract the incoming configuration for the smallrye-jms connector.
|
| JmsConnectorOutgoingConfiguration |
Extract the outgoing configuration for the smallrye-jms connector.
|
| JmsMessageMetadata |
|
| JmsProperties |
Structure handling JMS Message properties.
|
| JmsPropertiesBuilder |
|
| JmsPropertiesBuilder.OutgoingJmsProperties |
|
| JmsPropertiesBuilder.Property<T> |
|
| JmsTask |
|
| JsonArraySerializer |
|
| JsonHelper |
|
| JsonHelper |
|
| JsonObjectSerializer |
|
| KafkaConnector |
|
| KafkaConnectorCommonConfiguration |
Extracts the common configuration for the smallrye-kafka connector.
|
| KafkaConnectorIncomingConfiguration |
Extract the incoming configuration for the smallrye-kafka connector.
|
| KafkaConnectorOutgoingConfiguration |
Extract the outgoing configuration for the smallrye-kafka connector.
|
| KafkaMessage<K,T> |
Deprecated.
|
| KafkaMessageMetadata<K> |
|
| KafkaRecord<K,T> |
|
| KafkaSink |
|
| KafkaSource<K,V> |
|
| LegacyConfiguredChannelFactory |
Look for stream factories and get instances.
|
| LegacyEmitterImpl<T> |
Implementation of the old (legacy) Emitter interface.
|
| Main |
|
| Main |
|
| Main |
|
| Main |
|
| MediatorConfiguration |
|
| MediatorConfiguration.Consumption |
|
| MediatorConfiguration.Production |
|
| MediatorConfigurationSupport |
|
| MediatorConfigurationSupport.GenericTypeAssignable |
|
| MediatorConfigurationSupport.GenericTypeAssignable.Result |
|
| MediatorConfigurationSupport.ValidationOutput |
|
| MediatorFactory |
|
| MediatorManager |
Class responsible for managing mediators
|
| Merge |
Temporary annotation - must be copied to spec.
|
| Merge.Mode |
|
| Message<T> |
A message envelope.
|
| Metadata |
Message metadata containers.
|
| MetricDecorator |
|
| MqttConnector |
|
| MqttConnectorCommonConfiguration |
Extracts the common configuration for the smallrye-mqtt connector.
|
| MqttConnectorIncomingConfiguration |
Extract the incoming configuration for the smallrye-mqtt connector.
|
| MqttConnectorOutgoingConfiguration |
Extract the outgoing configuration for the smallrye-mqtt connector.
|
| MqttHelpers |
|
| MqttMessage<T> |
|
| MqttMessage |
|
| MqttServerConnector |
|
| MqttServerConnectorCommonConfiguration |
Extracts the common configuration for the smallrye-mqtt-server connector.
|
| MqttServerConnectorIncomingConfiguration |
Extract the incoming configuration for the smallrye-mqtt-server connector.
|
| MqttServerConnectorOutgoingConfiguration |
Extract the outgoing configuration for the smallrye-mqtt-server connector.
|
| MqttServerQuickstart |
|
| MqttSink |
|
| MqttSource |
|
| MyCloudEventProcessor |
|
| MyCloudEventSink |
|
| MyCloudEventSource |
|
| OnOverflow |
Deprecated.
|
| OnOverflow |
Allows configuring the back pressure policy on injected Emitter: |
| OnOverflow.Strategy |
The back pressure strategy.
|
| OnOverflow.Strategy |
The back pressure strategy.
|
| Outgoing |
Used to signify a publisher of outgoing messages.
|
| OutgoingAmqpMessage<T> |
|
| OutgoingAmqpMetadata |
|
| OutgoingAmqpMetadata.OutgoingAmqpMetadataBuilder |
|
| OutgoingConnectorFactory |
SPI used to implement a connector managing a sink of messages for a specific transport.
|
| OutgoingExchangeMetadata |
|
| OutgoingJmsMessageMetadata |
|
| OutgoingJmsMessageMetadata.OutgoingJmsMessageMetadataBuilder |
|
| OutgoingKafkaRecord<K,T> |
|
| OutgoingKafkaRecordMetadata<K> |
|
| OutgoingKafkaRecordMetadata.OutgoingKafkaRecordMetadataBuilder<K> |
|
| ProcessingException |
|
| ProcessorMediator |
|
| PublisherDecorator |
SPI to allow extension of publishers included in the final graph
|
| PublisherMediator |
|
| PubSubConfig |
|
| PubSubConnector |
|
| PubSubManager |
|
| PubSubMessage |
|
| PubSubMessageReceiver |
|
| PubSubSource |
|
| ReactiveMessagingExtension |
|
| Receiver |
|
| Receiver |
|
| Receiver |
|
| ReceivingMqttMessage |
|
| Sender |
|
| SendingMqttMessage<T> |
|
| Serializer<I> |
|
| Shape |
|
| SmallRyeReactiveMessagingExtender |
|
| SnsConnector |
Implement incoming/outgoing connection factories for Amazon Simple Notification Service reactive messaging.
|
| SnsConnectorCommonConfiguration |
Extracts the common configuration for the smallrye-aws-sns connector.
|
| SnsConnectorIncomingConfiguration |
Extract the incoming configuration for the smallrye-aws-sns connector.
|
| SnsConnectorOutgoingConfiguration |
Extract the outgoing configuration for the smallrye-aws-sns connector.
|
| SnsMessage |
|
| SnsVerticle |
Vert.x verticle that handles subscription to SNS topic and receive notifications from topic.
|
| StreamTransformerMediator |
|
| StringSerializer |
|
| SubscriberMediator |
|
| SubscriberWrapper<I,T> |
|
| TypeUtils |
Utility methods focusing on type inspection, particularly with regard to
generics.
|
| Validation |
|
| VertxEventBusConnector |
|
| VertxEventBusConnectorCommonConfiguration |
Extracts the common configuration for the smallrye-vertx-eventbus connector.
|
| VertxEventBusConnectorIncomingConfiguration |
Extract the incoming configuration for the smallrye-vertx-eventbus connector.
|
| VertxEventBusConnectorOutgoingConfiguration |
Extract the outgoing configuration for the smallrye-vertx-eventbus connector.
|
| WeavingException |
|
| WorkerPoolRegistry |
|
| Wrap |
|