This Application Programming Interface (API) contains all the necessary operations for connecting to a cluster of one or more MigratoryData servers, subscribing to one or more subjects, getting real-time messages for the subscribed subjects, and publishing real-time messages.

Classes

  • class MigratoryDataClient
    This class implements all the necessary operations for connecting to a cluster of one or more MigratoryData servers, subscribing to one or more subjects, getting real-time messages for the subscribed subjects, and publishing messages.
  • interface MigratoryDataListener
    The implementation of this interface will handle the messages received from the server for the subscribed subjects as well as various status notifications.
  • interface MigratoryDataInteractiveListener
    Implementations of this interface handle data messages and status notifications, like implementations of MigratoryDataListener do, and furthermore handle subscription events for the advertised interactive subjects.
  • interface MigratoryDataLogLevel
    This class enumerates the MigratoryData logging levels.
  • interface MigratoryDataLogListener
    The implementation of this interface will handle the log messages produced by the library.
  • class MigratoryDataMessage
    Represent a message.
    • interface MessageType
      The message type received from MigratoryData server.
    • interface QoS
      The quality of service (QoS) levels for MigratoryData messaging.
  • interface MigratoryDataKafkaUtils
    This utility class is designed to handle the encoding and decoding of Kafka records that are associated with MigratoryData messages.

Contents