MessageFlow Metasys Rest API Stream MetasysOpenStreamEvent ParsedObservedValue MetasysObservedValueEvent MetasysStreamImporter.onEvent(StreamEvent event) distributionClient.publish(observationMessage); -> eg AzureObservationDistributionClient