usergrid-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From toddn...@apache.org
Subject incubator-usergrid git commit: Fixes fat finger
Date Tue, 04 Aug 2015 23:31:17 GMT
Repository: incubator-usergrid
Updated Branches:
  refs/heads/USERGRID-900 491008e96 -> 0f94609ea


Fixes fat finger


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

Branch: refs/heads/USERGRID-900
Commit: 0f94609eabc5e563428b51590da93c61b397dd3e
Parents: 491008e
Author: Todd Nine <tnine@apigee.com>
Authored: Tue Aug 4 17:31:16 2015 -0600
Committer: Todd Nine <tnine@apigee.com>
Committed: Tue Aug 4 17:31:16 2015 -0600

----------------------------------------------------------------------
 .../asyncevents/AmazonAsyncEventService.java              | 10 +++++-----
 1 file changed, 5 insertions(+), 5 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-usergrid/blob/0f94609e/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 85aecdf..f5ef2fc 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
@@ -299,7 +299,7 @@ public class AmazonAsyncEventService implements AsyncEventService {
 
         final Observable<IndexOperationMessage> observable = eventBuilder.buildEntityIndex(
entityIndexOperation );
 
-        subscibeAndAck( observable, message );
+        subscribeAndAck( observable, message );
     }
 
 
@@ -334,7 +334,7 @@ public class AmazonAsyncEventService implements AsyncEventService {
         final Observable<IndexOperationMessage> edgeIndexObservable = ecm.load(edgeIndexEvent.getEntityId()).flatMap(
entity -> eventBuilder.buildNewEdge(
             applicationScope, entity, edge ) );
 
-        subscibeAndAck( edgeIndexObservable, message );
+        subscribeAndAck( edgeIndexObservable, message );
     }
 
     @Override
@@ -363,7 +363,7 @@ public class AmazonAsyncEventService implements AsyncEventService {
 
         final Observable<IndexOperationMessage> observable = eventBuilder.buildDeleteEdge(
applicationScope, edge );
 
-        subscibeAndAck( observable, message );
+        subscribeAndAck( observable, message );
     }
 
 
@@ -399,7 +399,7 @@ public class AmazonAsyncEventService implements AsyncEventService {
         final Observable merged = Observable.merge( entityDeleteResults.getEntitiesCompacted(),
             entityDeleteResults.getIndexObservable() );
 
-        subscibeAndAck( merged, message );
+        subscribeAndAck( merged, message );
     }
 
 
@@ -520,7 +520,7 @@ public class AmazonAsyncEventService implements AsyncEventService {
      * @param observable
      * @param message
      */
-    private void subscibeAndAck( final Observable<?> observable, final QueueMessage
message ){
+    private void subscribeAndAck( final Observable<?> observable, final QueueMessage
message ){
        observable.doOnCompleted( ()-> ack(message)  ).subscribeOn( rxTaskScheduler.getAsyncIOScheduler()
).subscribe();
     }
 }


Mime
View raw message