Ensure that only single result is returned

hawkular · May 26, 2015 · 80d0f27 · 80d0f27
1 parent 19613fd
commit 80d0f27
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/...-impl/src/main/java/org/hawkular/metrics/core/impl/cassandra/MetricsServiceCassandra.java b/...-impl/src/main/java/org/hawkular/metrics/core/impl/cassandra/MetricsServiceCassandra.java
@@ -598,6 +598,7 @@ public Observable<BucketedOutput<AvailabilityBucketDataPoint>> findAvailabilityS
     public Observable<Boolean> idExists(final String id) {
         return dataAccess.findAllGaugeMetrics().flatMap(Observable::from)
                 .filter(row -> id.equals(row.getString(2)))
+                .take(1)
                 .map(r -> Boolean.TRUE)
                 .defaultIfEmpty(Boolean.FALSE);
     }