Versions Compared

Old Version 25

changes.mady.by.user Andrey Gura

Saved on

compared with

New Version 26

changes.mady.by.user Andrey Gura

Saved on

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

  1. Chose model that data streamer will be implement (server or client).
  2. Define new data streamer class that extends StreamAdapter.
  3. Provide API for data streamer configuration and implement parameters validation if needed. Hosts, ports, other data source specific parameters.
  4. 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 consumersand so on.
  5. Implement logic of data consuming from data source. For example: process JMS message in corresponding listener, accept connections and read data from it, consume messages from Kafka topics and so on.
  6. Implement data conversion from data source specific format to Java object. For example: convert JMS Message instances, convert bytes received from socket, convert bytes consumed from Kafka topics and so on.
  7. 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.