public interface SourceHandler extends ServiceHandler
A source service handler may be a StreamingSourceHandler
or a
PollingSourceHandler
.
The handler publishes updates to Diffusion using a Publisher
provided
to it when it is instantiated.
The handler may also optionally return service
specific properties
via its getSourceServiceProperties()
method. If
it does not then defaults will be assumed. These properties allow the handler
to define details about the topics it wants to create and/or the data
conversions to use.
Modifier and Type | Interface and Description |
---|---|
static interface |
SourceHandler.SourceServiceProperties
The properties that apply to topics created by and published to by the
service.
|
ServiceHandler.PauseReason, ServiceHandler.ResumeReason
Modifier and Type | Method and Description |
---|---|
default SourceHandler.SourceServiceProperties |
getSourceServiceProperties()
This is used to set topic-specific properties for topics created by this
service.
|
pause, resume, start, stop
default SourceHandler.SourceServiceProperties getSourceServiceProperties() throws InvalidConfigurationException
Properties can be built using a builder
which can be created using
DiffusionGatewayFramework.newSourceServicePropertiesBuilder()
.
The default implementation returns null, which means that all defaults
are assumed for service properties. See the methods of
SourceHandler.SourceServiceProperties.Builder
for details about defaults.
InvalidConfigurationException
- possibly thrown by
SourceHandler.SourceServiceProperties.Builder
Copyright © 2024 DiffusionData Limited. All rights reserved.