[Hawkular-commits] [hawkular/hawkular-metrics] d72af2: HWKMETRICS-315 Bus integration: events randomly or...

Branch: refs/heads/master Home: https://github.com/hawkular/hawkular-metrics Commit: d72af2cd3a8d95b58a9f630bc4d4c6a31e50dd3a https://github.com/hawkular/hawkular-metrics/commit/d72af2cd3a8d95b58a9f6... Author: Thomas Segismont <tsegismo(a)redhat.com&gt; Date: 2015-10-15 (Thu, 15 Oct 2015) Changed paths: M hawkular-component/src/main/java/org/hawkular/metrics/component/publish/InsertedDataSubscriber.java Log Message: ----------- HWKMETRICS-315 Bus integration: events randomly or never posted When Metrics was started after the Pinger, the Pinger would accumulate data to post before sending it all at once eventually. Because there were not enough threads to handle the peak load, RxJava tried to apply backpressure but PublishSubject does not support it by nature. The fix consists in: - buffering inserted metric to avoid submitting too much to the io scheduler - adding a buffer-on-backpressure strategy Note that the problem was emphasized before as we used to schedule sending on a wrapped ManagedExecutorService. Now we use the #io scheduler (change already in master). I've successfully tested the changes on Hawkular server. Commit: 8ea009e42cbf919366007390838974db2c85bb87 https://github.com/hawkular/hawkular-metrics/commit/8ea009e42cbf919366007... Author: Thomas Segismont <tsegismo(a)redhat.com&gt; Date: 2015-10-15 (Thu, 15 Oct 2015) Changed paths: M hawkular-component/src/main/java/org/hawkular/metrics/component/publish/AvailDataPublisher.java M hawkular-component/src/test/groovy/org/hawkular/metrics/component/bus/test/InsertedDataITest.groovy Log Message: ----------- Change avail text format to suit Alerts Commit: 9080fcfbe40a66ce8143c477b5d6f8fbadeecf3a https://github.com/hawkular/hawkular-metrics/commit/9080fcfbe40a66ce8143c... Author: jsanda <jsanda(a)redhat.com&gt; Date: 2015-10-15 (Thu, 15 Oct 2015) Changed paths: M hawkular-component/src/main/java/org/hawkular/metrics/component/publish/AvailDataPublisher.java M hawkular-component/src/main/java/org/hawkular/metrics/component/publish/InsertedDataSubscriber.java M hawkular-component/src/test/groovy/org/hawkular/metrics/component/bus/test/InsertedDataITest.groovy Log Message: ----------- Merge pull request #398 from tsegismont/hawkular-bus-integration-fixes Hawkular bus integration fixes Thanks @tsegismont Compare: https://github.com/hawkular/hawkular-metrics/compare/1948f07b768d...9080f...