Github user mdunker commented on a diff in the pull request:
https://github.com/apache/usergrid/pull/584#discussion_r150589242
--- Diff:
stack/core/src/main/java/org/apache/usergrid/corepersistence/asyncevents/AsyncEventServiceImpl.java
---
@@ -704,7 +707,24 @@ public void queueIndexOperationMessage(final
IndexOperationMessage indexOperatio
offerTopic( elasticsearchIndexEvent, queueType );
}
- private void handleIndexOperation(final ElasticsearchIndexEvent
elasticsearchIndexEvent)
+ protected ElasticsearchIndexEvent getIndexOperationMessage(final
IndexOperationMessage indexOperationMessage) {
--- End diff --
Should this be named getIndexEvent or something similar? index operation
message is the input
---
