apache/cloudstack
1
0
Fork 0
mirror of https://github.com/apache/cloudstack.git synced 2025-12-16 10:32:34 +01:00
Code Issues Packages Projects Releases Wiki Activity

remove parent concept from AsyncCallbackDispatcher, let user of AyncMethod handle high level concept of chaining

Browse Source
This commit is contained in:
Kelven Yang 2012-12-19 11:05:02 -08:00
parent 0581ea763a
commit ea713c70a2
1 changed files with 0 additions and 23 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
framework/ipc/src/org/apache/cloudstack/framework/async/AsyncCallbackDispatcher.java
View File

@ -28,8 +28,6 @@ import net.sf.cglib.proxy.MethodProxy;
@SuppressWarnings("rawtypes") @SuppressWarnings("rawtypes")
public class AsyncCallbackDispatcher<T> implements AsyncCompletionCallback { public class AsyncCallbackDispatcher<T> implements AsyncCompletionCallback {
private AsyncCallbackDispatcher _parent;
private Method _callbackMethod; private Method _callbackMethod;
private T _targetObject; private T _targetObject;
private Object _contextObject; private Object _contextObject;
@ -41,12 +39,6 @@ public class AsyncCallbackDispatcher<T> implements AsyncCompletionCallback {
_targetObject = target; _targetObject = target;
} }
private AsyncCallbackDispatcher(T target, AsyncCallbackDispatcher parent) {
assert(target != null);
_targetObject = target;
_parent = parent;
}
public AsyncCallbackDispatcher<T> attachDriver(AsyncCallbackDriver driver) { public AsyncCallbackDispatcher<T> attachDriver(AsyncCallbackDriver driver) {
assert(driver != null); assert(driver != null);
_driver = driver; _driver = driver;
@ -89,12 +81,6 @@ public class AsyncCallbackDispatcher<T> implements AsyncCompletionCallback {
_driver.performCompletionCallback(this); _driver.performCompletionCallback(this);
} }
public void deepComplete(Object resultObject) {
complete(resultObject);
if(_parent != null)
_parent.deepComplete(resultObject);
}
@SuppressWarnings("unchecked") @SuppressWarnings("unchecked")
public <R> R getResult() { public <R> R getResult() {
return (R)_resultObject; return (R)_resultObject;
@ -109,15 +95,6 @@ public class AsyncCallbackDispatcher<T> implements AsyncCompletionCallback {
return new AsyncCallbackDispatcher<P>(target); 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) { public static boolean dispatch(Object target, AsyncCallbackDispatcher callback) {
assert(callback != null); assert(callback != null);
assert(target != null); assert(target != null);