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 2014/02/27 00:23:27 UTC

[2/8] git commit: flush list after certain amount of commits

flush list after certain amount of commits


Project: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/commit/d5b540c7
Tree: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/tree/d5b540c7
Diff: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/diff/d5b540c7

Branch: refs/pull/62/merge
Commit: d5b540c79f3d8b034f09564320f4c9ccf5961f9d
Parents: 2f3085e
Author: Shawn Feldman <sh...@gmail.com>
Authored: Wed Feb 26 15:21:48 2014 -0700
Committer: Shawn Feldman <sh...@gmail.com>
Committed: Wed Feb 26 15:21:48 2014 -0700

----------------------------------------------------------------------
 .../usergrid/services/users/activities/ActivitiesService.java      | 2 ++
 1 file changed, 2 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-usergrid/blob/d5b540c7/stack/services/src/main/java/org/apache/usergrid/services/users/activities/ActivitiesService.java
----------------------------------------------------------------------
diff --git a/stack/services/src/main/java/org/apache/usergrid/services/users/activities/ActivitiesService.java b/stack/services/src/main/java/org/apache/usergrid/services/users/activities/ActivitiesService.java
index 12807b6..6cc0daf 100644
--- a/stack/services/src/main/java/org/apache/usergrid/services/users/activities/ActivitiesService.java
+++ b/stack/services/src/main/java/org/apache/usergrid/services/users/activities/ActivitiesService.java
@@ -143,6 +143,8 @@ public class ActivitiesService extends GenericCollectionService {
                 refs.add(c);
                 //break out when you get too big
                 if( refs.size() > breaker ){
+                    em.addToCollections(refs, "feed", activity);
+                    refs.clear();
                     break;
                 }
             }