Package | Description |
---|---|
com.diffusiondata.gateway.framework |
Diffusion Gateway Framework API.
|
Modifier and Type | Method and Description |
---|---|
default HybridHandler<?> |
GatewayApplication.addHybrid(ServiceDefinition serviceDefinition,
Publisher publisher,
Subscriber subscriber,
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,
Subscriber subscriber,
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 |
SinkHandler.SinkServiceProperties.Builder.build()
Creates a
SinkHandler.SinkServiceProperties instance with the current
settings of this builder. |
SourceHandler.SourceServiceProperties |
SourceHandler.SourceServiceProperties.Builder.build()
Create a
SourceHandler.SourceServiceProperties instance with the
current settings of this builder. |
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.
|
SinkHandler.SinkServiceProperties.Builder |
SinkHandler.SinkServiceProperties.Builder.payloadConverter(PayloadConverter<?,?> converter)
Specifies a payload converter to use for the service.
|
SourceHandler.SourceServiceProperties.Builder |
SourceHandler.SourceServiceProperties.Builder.payloadConverter(PayloadConverter<?,?> converter)
Specifies a payload converter to use for this service.
|
SinkHandler.SinkServiceProperties.Builder |
SinkHandler.SinkServiceProperties.Builder.payloadConverter(String name)
Specifies the name of a payload converter to use for this
service.
|
SourceHandler.SourceServiceProperties.Builder |
SourceHandler.SourceServiceProperties.Builder.payloadConverter(String name)
Specifies the name of a payload converter to use for this
service.
|
SinkHandler.SinkServiceProperties.Builder |
SinkHandler.SinkServiceProperties.Builder.payloadConverter(String name,
Map<String,Object> parameters)
Specifies the name of a payload converter and parameters the
converter requires to be initialized.
|
SourceHandler.SourceServiceProperties.Builder |
SourceHandler.SourceServiceProperties.Builder.payloadConverter(String name,
Map<String,Object> parameters)
Specifies the name of a payload converter and parameters the
converter requires to be initialized.
|
Copyright © 2024 DiffusionData Limited. All rights reserved.