- private void resolveProxyCalls(final Object message, final ActorRef recipient, final ActorRef futureSender) {
- if (message instanceof ReadRequest) {
-
- final ReadRequest readRequest = (ReadRequest) message;
- operationsProcessor.doRead(readRequest.getStore(), readRequest.getPath(), recipient, futureSender);
-
- } else if (message instanceof ExistsRequest) {
-
- final ExistsRequest readRequest = (ExistsRequest) message;
- operationsProcessor.doExists(readRequest.getStore(), readRequest.getPath(), recipient, futureSender);
-
- } else if (message instanceof MergeRequest) {
-
- final MergeRequest mergeRequest = (MergeRequest) message;
- operationsProcessor.doMerge(mergeRequest.getStore(), mergeRequest.getNormalizedNodeMessage());
-
- } else if (message instanceof PutRequest) {
-
- final PutRequest putRequest = (PutRequest) message;
- operationsProcessor.doPut(putRequest.getStore(), putRequest.getNormalizedNodeMessage());
-
- } else if (message instanceof DeleteRequest) {
-
- final DeleteRequest deleteRequest = (DeleteRequest) message;
- operationsProcessor.doDelete(deleteRequest.getStore(), deleteRequest.getPath());
-
- } else if (message instanceof CancelRequest) {
-
- operationsProcessor.doCancel(recipient, futureSender);
-
- } else if (message instanceof SubmitRequest) {
-
- operationsProcessor.doSubmit(recipient, futureSender);
- }