Branch: refs/heads/master Home: https://github.com/rhq-project/rhq Commit: 5127e55c2cccb4ee10b96671bcffb56d45f1486d https://github.com/rhq-project/rhq/commit/5127e55c2cccb4ee10b96671bcffb56... Author: Michael Burman <miburman(a)redhat.com&gt; Date: 2015-04-09 (Thu, 09 Apr 2015) Changed paths: M modules/enterprise/server/jar/src/main/java/org/rhq/enterprise/server/measurement/MeasurementDataManagerBean.java M modules/enterprise/server/jar/src/main/java/org/rhq/enterprise/server/storage/StorageClientManager.java M modules/enterprise/server/jar/src/main/java/org/rhq/enterprise/server/storage/StorageClientManagerMBean.java M modules/enterprise/server/server-metrics/src/main/java/org/rhq/server/metrics/MetricsServer.java M modules/enterprise/server/server-metrics/src/main/java/org/rhq/server/metrics/RawDataInsertedCallback.java M modules/enterprise/server/server-metrics/src/test/java/org/rhq/server/metrics/TimeoutTest.java M modules/enterprise/server/server-metrics/src/test/java/org/rhq/server/metrics/WaitForRawInserts.java M modules/helpers/metrics-simulator/src/main/java/org/rhq/metrics/simulator/MeasurementCollector.java M modules/helpers/metrics-simulator/src/main/java/org/rhq/metrics/simulator/WaitForRawInserts.java M modules/plugins/rhq-server/src/main/resources/META-INF/rhq-plugin.xml Log Message: ----------- [BZ 1147098] Add all the raw data first to a queue and from the queue write it to the Cassandra. Use the buffer to prevent bursts from overloading the Storage Node. Also, in case the queue is full, return an exception to the agent for agent queueing. Commit: b3b421cda35a61a19e215be4306fb5c6aa0e512b https://github.com/rhq-project/rhq/commit/b3b421cda35a61a19e215be4306fb5c... Author: Michael Burman <yak(a)iki.fi&gt; Date: 2015-04-09 (Thu, 09 Apr 2015) Changed paths: M modules/enterprise/server/jar/src/main/java/org/rhq/enterprise/server/measurement/MeasurementDataManagerBean.java M modules/enterprise/server/jar/src/main/java/org/rhq/enterprise/server/storage/StorageClientManager.java M modules/enterprise/server/jar/src/main/java/org/rhq/enterprise/server/storage/StorageClientManagerMBean.java M modules/enterprise/server/server-metrics/src/main/java/org/rhq/server/metrics/MetricsServer.java M modules/enterprise/server/server-metrics/src/main/java/org/rhq/server/metrics/RawDataInsertedCallback.java M modules/enterprise/server/server-metrics/src/test/java/org/rhq/server/metrics/TimeoutTest.java M modules/enterprise/server/server-metrics/src/test/java/org/rhq/server/metrics/WaitForRawInserts.java M modules/helpers/metrics-simulator/src/main/java/org/rhq/metrics/simulator/MeasurementCollector.java M modules/helpers/metrics-simulator/src/main/java/org/rhq/metrics/simulator/WaitForRawInserts.java M modules/plugins/rhq-server/src/main/resources/META-INF/rhq-plugin.xml Log Message: ----------- Merge pull request #162 from burmanm/queue_writes [BZ 1147098] Add all the raw data first to a queue and from the queue write it to the Cassandra. Use the buffer to prevent bursts from overloading the Storage Node and dropping events. Also, in case the queue is full, return an exception to the agent for agent queueing. Compare: https://github.com/rhq-project/rhq/compare/27d5b0ad372b...b3b421cda35a