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.