| Package | Description |
|---|---|
| io.smallrye.reactive.messaging.amqp | |
| io.smallrye.reactive.messaging.camel | |
| io.smallrye.reactive.messaging.connector | |
| io.smallrye.reactive.messaging.connectors | |
| io.smallrye.reactive.messaging.jms | |
| io.smallrye.reactive.messaging.kafka | |
| io.smallrye.reactive.messaging.mqtt | |
| org.eclipse.microprofile.reactive.messaging.spi |
The MicroProfile Reactive Messaging API Connector SPI
|
| Modifier and Type | Class and Description |
|---|---|
class |
AmqpConnector |
| Modifier and Type | Class and Description |
|---|---|
class |
CamelConnector |
| Modifier and Type | Method and Description |
|---|---|
static void |
CommonConfigurationClassWriter.generate(ProcessingEnvironment environment,
Connector connector,
String className,
List<ConnectorAttribute> attributes) |
void |
ConfigurationClassWriter.generateAllClasses(Connector connector,
String className,
List<ConnectorAttribute> common,
List<ConnectorAttribute> incoming,
List<ConnectorAttribute> outgoing) |
void |
ConfigurationDocWriter.generateIncomingDocumentation(Connector connector,
List<ConnectorAttribute> commonAttributes,
List<ConnectorAttribute> incomingAttributes) |
void |
ConfigurationDocWriter.generateOutgoingDocumentation(Connector connector,
List<ConnectorAttribute> commonAttributes,
List<ConnectorAttribute> incomingAttributes) |
| Modifier and Type | Class and Description |
|---|---|
class |
InMemoryConnector
An implementation of connector used for testing applications without having to use external broker.
|
| Modifier and Type | Class and Description |
|---|---|
class |
JmsConnector |
| Modifier and Type | Class and Description |
|---|---|
class |
KafkaConnector |
| Modifier and Type | Class and Description |
|---|---|
class |
MqttConnector |
| Modifier and Type | Method and Description |
|---|---|
static Connector |
ConnectorLiteral.of(String value)
Creates a new instance of
ConnectorLiteral. |
Copyright © 2018–2021 SmallRye. All rights reserved.