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/two-dot-o-dev 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(); } }
