| Package | Description |
|---|---|
| com.diffusiondata.gateway.framework |
Diffusion Gateway Framework API.
|
| Modifier and Type | Method and Description |
|---|---|
default HybridHandler<?> |
GatewayApplication.addHybrid(ServiceDefinition serviceDefinition,
Publisher publisher,
StateHandler stateHandler)
Adds a hybrid service to the application.
|
default PollingSourceHandler |
GatewayApplication.addPollingSource(ServiceDefinition serviceDefinition,
Publisher publisher,
StateHandler stateHandler)
Adds a polling source service to the application.
|
default SinkHandler<?> |
GatewayApplication.addSink(ServiceDefinition serviceDefinition,
StateHandler stateHandler)
Adds a sink service to the application.
|
default StreamingSourceHandler |
GatewayApplication.addStreamingSource(ServiceDefinition serviceDefinition,
Publisher publisher,
StateHandler stateHandler)
Adds a streaming source service to the application.
|
SinkHandler.SinkServiceProperties.Builder |
SinkHandler.SinkServiceProperties.Builder.consumeJSONSubTypes(boolean consumesJSONSubTypes)
Specifies whether to consume data from all subtypes of JSON topic
type, if the subscription is for JSON topic selector.
|
default SinkHandler.SinkServiceProperties |
SinkHandler.getSinkServiceProperties()
This is used to set topic-specific properties for topics consumed by this
service.
|
default SourceHandler.SourceServiceProperties |
SourceHandler.getSourceServiceProperties()
This is used to set topic-specific properties for topics created by this
service.
|
SourceHandler.SourceServiceProperties.Builder |
SourceHandler.SourceServiceProperties.Builder.payloadConvertor(InboundPayloadConvertor<?,?> convertor)
Specifies an inbound payload convertor to use for converting
published values to Diffusion specific values.
|
SinkHandler.SinkServiceProperties.Builder |
SinkHandler.SinkServiceProperties.Builder.payloadConvertor(OutboundPayloadConvertor<?,?> convertor)
Specifies an outbound payload convertor to use for converting
Diffusion specific values to application format.
|
SourceHandler.SourceServiceProperties.Builder |
SourceHandler.SourceServiceProperties.Builder.payloadConvertorName(String name)
Specifies the name of an inbound payload convertor to use for
converting published values to Diffusion specific values.
|
SinkHandler.SinkServiceProperties.Builder |
SinkHandler.SinkServiceProperties.Builder.payloadConvertorName(String name)
Specifies the name of an outbound payload convertor to use for
converting Diffusion specific values to application format.
|
SourceHandler.SourceServiceProperties.Builder |
SourceHandler.SourceServiceProperties.Builder.topicType(TopicType type)
Sets the topic type.
|
SinkHandler.SinkServiceProperties.Builder |
SinkHandler.SinkServiceProperties.Builder.topicType(TopicType type)
Sets the topic type.
|
Copyright © 2023 DiffusionData Limited. All rights reserved.