You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
This commit was created on GitHub.com and signed with GitHub’s verified signature.
The key has expired.
New Features
New Beta MQTT sink for publishing to an MQTT Broker: Mqtt2Service
Does not create a topic per data item, only four topics are used per device
Rational: MTConnect rates were too fast for broker and exceeded number of in-flight messages. This solves the issue.
Probe, Current, Sample and Assets (similar to the REST api)
Probe - Provides the Device definition for a given device
Current - Provides a snapshot of all the data items at a fixed interval (default every 10 seconds)
Sample - Time series deltas published on changes at a minimum interval (default every 500ms)
Assets - One topic per asset document organized by device
Review readme for configuration options.
Bug Fixes
Fixed Period Filter where in an edge case it would publish an additional observation not on period boundaries.
Internal Changes
Created an AsyncObserver for the REST and MQTT 2 Sinks. The class allows Sinks to monitor a set of data items for change and only activate asynchronously when something happens. Keeps track of sequence numbers while waiting so recipient knows where to continue from.