...
The following steps should be done performed in order to implement custom data streamer:
- Chose model that data streamer will be implement (server or client).
- Define new data streamer class that extends
StreamAdapter
. - Provide API for data streamer configuration and implement parameters validation if needed. Hosts, ports, other data source specific parameters.
- Implement life cycle management methods if needed. Usually developer will want to have control over data source resources such as JMS sessions, HTTP/socket connections, Kafka consumers and so on.
- Implement logic of data consuming from data source. For example: JMS message process JMS message ing in corresponding listener, accept accepting client connections and read reading data from it, consume consuming messages from Kafka topics and so on.
- Implement data conversion from data source specific format to Java object. For example: convert JMS Message instances conversion, convert conversion of bytes received from socket, convert conversion of bytes consumed from Kafka topics and so on.
- Provide abstraction and API for user defined data converters. For example: JMS defines several message types (TextMessage, MapMessage), socket servers can use different protocols and so on.
...