You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@usergrid.apache.org by sn...@apache.org on 2015/10/15 16:18:19 UTC
[29/50] [abbrv] usergrid git commit: add additional logging
add additional logging
Project: http://git-wip-us.apache.org/repos/asf/usergrid/repo
Commit: http://git-wip-us.apache.org/repos/asf/usergrid/commit/0692faa1
Tree: http://git-wip-us.apache.org/repos/asf/usergrid/tree/0692faa1
Diff: http://git-wip-us.apache.org/repos/asf/usergrid/diff/0692faa1
Branch: refs/heads/usergrid-1007-shiro-cache
Commit: 0692faa1c2b13e9908596309e00650bf84d0f9b2
Parents: 365f6dc
Author: Shawn Feldman <sf...@apache.org>
Authored: Thu Oct 8 15:13:27 2015 -0600
Committer: Shawn Feldman <sf...@apache.org>
Committed: Thu Oct 8 15:13:27 2015 -0600
----------------------------------------------------------------------
.../corepersistence/asyncevents/AmazonAsyncEventService.java | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/usergrid/blob/0692faa1/stack/core/src/main/java/org/apache/usergrid/corepersistence/asyncevents/AmazonAsyncEventService.java
----------------------------------------------------------------------
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 @@ public class AmazonAsyncEventService implements AsyncEventService {
});
//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 @@ public class AmazonAsyncEventService implements AsyncEventService {
//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);
-
}