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.
The implementation of this interface will handle the messages received from the server for the subscribed subjects
as well as various status notifications.