Updated Branches: refs/heads/javelin 0581ea763 -> ea713c70a
remove parent concept from AsyncCallbackDispatcher, let user of AyncMethod handle high level concept of chaining Project: http://git-wip-us.apache.org/repos/asf/incubator-cloudstack/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-cloudstack/commit/ea713c70 Tree: http://git-wip-us.apache.org/repos/asf/incubator-cloudstack/tree/ea713c70 Diff: http://git-wip-us.apache.org/repos/asf/incubator-cloudstack/diff/ea713c70 Branch: refs/heads/javelin Commit: ea713c70a2eb1d44de7fce6a62d82f8763ed8ad7 Parents: 0581ea7 Author: Kelven Yang <[email protected]> Authored: Wed Dec 19 11:05:02 2012 -0800 Committer: Kelven Yang <[email protected]> Committed: Wed Dec 19 11:05:24 2012 -0800 ---------------------------------------------------------------------- .../framework/async/AsyncCallbackDispatcher.java | 23 --------------- 1 files changed, 0 insertions(+), 23 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-cloudstack/blob/ea713c70/framework/ipc/src/org/apache/cloudstack/framework/async/AsyncCallbackDispatcher.java ---------------------------------------------------------------------- diff --git a/framework/ipc/src/org/apache/cloudstack/framework/async/AsyncCallbackDispatcher.java b/framework/ipc/src/org/apache/cloudstack/framework/async/AsyncCallbackDispatcher.java index c31e0ed..125d946 100644 --- a/framework/ipc/src/org/apache/cloudstack/framework/async/AsyncCallbackDispatcher.java +++ b/framework/ipc/src/org/apache/cloudstack/framework/async/AsyncCallbackDispatcher.java @@ -28,8 +28,6 @@ import net.sf.cglib.proxy.MethodProxy; @SuppressWarnings("rawtypes") public class AsyncCallbackDispatcher<T> implements AsyncCompletionCallback { - private AsyncCallbackDispatcher _parent; - private Method _callbackMethod; private T _targetObject; private Object _contextObject; @@ -41,12 +39,6 @@ public class AsyncCallbackDispatcher<T> implements AsyncCompletionCallback { _targetObject = target; } - private AsyncCallbackDispatcher(T target, AsyncCallbackDispatcher parent) { - assert(target != null); - _targetObject = target; - _parent = parent; - } - public AsyncCallbackDispatcher<T> attachDriver(AsyncCallbackDriver driver) { assert(driver != null); _driver = driver; @@ -89,12 +81,6 @@ public class AsyncCallbackDispatcher<T> implements AsyncCompletionCallback { _driver.performCompletionCallback(this); } - public void deepComplete(Object resultObject) { - complete(resultObject); - if(_parent != null) - _parent.deepComplete(resultObject); - } - @SuppressWarnings("unchecked") public <R> R getResult() { return (R)_resultObject; @@ -109,15 +95,6 @@ public class AsyncCallbackDispatcher<T> implements AsyncCompletionCallback { return new AsyncCallbackDispatcher<P>(target); } - public <P> AsyncCallbackDispatcher<P> chainToCreate(P target) { - return new AsyncCallbackDispatcher<P>(target, this); - } - - @SuppressWarnings("unchecked") - public <P> AsyncCallbackDispatcher<P> getParent() { - return (AsyncCallbackDispatcher<P>)_parent; - } - public static boolean dispatch(Object target, AsyncCallbackDispatcher callback) { assert(callback != null); assert(target != null);
