Fix issue with buffer size initialization.

hawkular · Oct 31, 2016 · 2733c78 · 2733c78
1 parent 5c55391
commit 2733c78
Showing 1 changed file with 12 additions and 0 deletions.
diff --git a/...ting/alerting-jar/src/main/java/org/hawkular/metrics/alerting/InsertedDataSubscriber.java b/...ting/alerting-jar/src/main/java/org/hawkular/metrics/alerting/InsertedDataSubscriber.java
@@ -109,6 +109,7 @@ public class InsertedDataSubscriber {
     public void onMetricsServiceReady(@Observes @ServiceReady ServiceReadyEvent event) {
         if (!Boolean.parseBoolean(disableMetricsForwardingProperty)) {
             publishPeriod = getPublishPeriod();
+            publishBufferSize = getPublishBufferSize();
             disablePublishFiltering = Boolean.parseBoolean(disablePublishFilteringProperty);
             Observable<List<Metric<?>>> events;
             events = event.getInsertedData()
@@ -206,4 +207,15 @@ private int getPublishPeriod() {
             return Integer.parseInt(METRICS_PUBLISH_PERIOD.defaultValue());
         }
     }
+
+    private int getPublishBufferSize() {
+        try {
+            return Integer.parseInt(publishBufferSizeProperty);
+        } catch (NumberFormatException e) {
+            log.warnf("Invalid publish buffer size. Setting default value %s",
+                    METRICS_PUBLISH_BUFFER_SIZE.defaultValue());
+            return Integer.parseInt(METRICS_PUBLISH_BUFFER_SIZE.defaultValue());
+        }
+    }
+
 }