You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@usergrid.apache.org by gr...@apache.org on 2015/08/10 19:29:23 UTC
[05/13] incubator-usergrid git commit: Fixes fat finger
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-903
Commit: 0f94609eabc5e563428b51590da93c61b397dd3e
Parents: 491008e
Author: Todd Nine <tn...@apigee.com>
Authored: Tue Aug 4 17:31:16 2015 -0600
Committer: Todd Nine <tn...@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();
}
}