add additional logging
diff --git a/stack/core/src/main/java/org/apache/usergrid/corepersistence/asyncevents/AmazonAsyncEventService.java b/stack/core/src/main/java/org/apache/usergrid/corepersistence/asyncevents/AmazonAsyncEventService.java
index e3aca06..5a46aed 100644
--- a/stack/core/src/main/java/org/apache/usergrid/corepersistence/asyncevents/AmazonAsyncEventService.java
+++ b/stack/core/src/main/java/org/apache/usergrid/corepersistence/asyncevents/AmazonAsyncEventService.java
@@ -305,7 +305,7 @@
});
//filter for success, send to the index(optional), ack
- return (List<QueueMessage>) masterObservable
+ return masterObservable
//take the max
.buffer(bufferSize)
//map them to index results and return them
@@ -328,12 +328,12 @@
//measure
.doOnNext(indexEventResult -> messageCycle.update(System.currentTimeMillis() - indexEventResult.getCreationTime()))
//return the queue messages to ack
- .map(result -> result.getQueueMessage().get());
+ .map(result -> result.getQueueMessage().get())
+ .toList();
})
.doOnError(t -> logger.error("Failed to process queuemessages",t))
.toBlocking().lastOrDefault(null);
-
}
