usergrid-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sfeld...@apache.org
Subject usergrid git commit: add additional logging
Date Thu, 08 Oct 2015 21:13:34 GMT
Repository: usergrid
Updated Branches:
  refs/heads/2.1-release 365f6dc2a -> 0692faa1c


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/2.1-release
Commit: 0692faa1c2b13e9908596309e00650bf84d0f9b2
Parents: 365f6dc
Author: Shawn Feldman <sfeldman@apache.org>
Authored: Thu Oct 8 15:13:27 2015 -0600
Committer: Shawn Feldman <sfeldman@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);
-
     }
 
 


Mime
View raw message