Skip to main content
aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
-rw-r--r--framework/bundles/org.eclipse.ecf.provider/src/org/eclipse/ecf/provider/generic/SOConnector.java11
1 files changed, 6 insertions, 5 deletions
diff --git a/framework/bundles/org.eclipse.ecf.provider/src/org/eclipse/ecf/provider/generic/SOConnector.java b/framework/bundles/org.eclipse.ecf.provider/src/org/eclipse/ecf/provider/generic/SOConnector.java
index 6cf2c70e6..3d2527e4a 100644
--- a/framework/bundles/org.eclipse.ecf.provider/src/org/eclipse/ecf/provider/generic/SOConnector.java
+++ b/framework/bundles/org.eclipse.ecf.provider/src/org/eclipse/ecf/provider/generic/SOConnector.java
@@ -23,7 +23,8 @@ import org.eclipse.ecf.core.sharedobject.events.ISharedObjectEvent;
import org.eclipse.ecf.core.sharedobject.events.SharedObjectCallEvent;
import org.eclipse.ecf.core.sharedobject.util.IQueueEnqueue;
import org.eclipse.ecf.core.sharedobject.util.QueueException;
-import org.eclipse.ecf.core.util.AsynchResult;
+import org.eclipse.ecf.core.util.AsyncResult;
+import org.eclipse.ecf.core.util.IAsyncResult;
public class SOConnector implements ISharedObjectConnector {
ID sender;
@@ -53,13 +54,13 @@ public class SOConnector implements ISharedObjectConnector {
}
}
- protected AsynchResult[] fireCallEvent(ISharedObjectEvent event)
+ protected IAsyncResult[] fireCallEvent(ISharedObjectEvent event)
throws QueueException {
- AsynchResult[] results = new AsynchResult[receiverQueues.size()];
+ IAsyncResult[] results = new IAsyncResult[receiverQueues.size()];
int i = 0;
for (Enumeration e = receiverQueues.elements(); e.hasMoreElements();) {
IQueueEnqueue queue = (IQueueEnqueue) e.nextElement();
- results[i] = new AsynchResult();
+ results[i] = new AsyncResult();
queue.enqueue(new SharedObjectCallEvent(event
.getSenderSharedObjectID(), event, results[i]));
}
@@ -103,7 +104,7 @@ public class SOConnector implements ISharedObjectConnector {
fireEvents(events);
}
- public AsynchResult[] callAsynch(ISharedObjectEvent arg) throws Exception {
+ public IAsyncResult[] callAsynch(ISharedObjectEvent arg) throws Exception {
return fireCallEvent(arg);
}

Back to the top