org.eclipse.ecf.provider.generic
Class SOConnector

java.lang.Object
  org.eclipse.ecf.provider.generic.SOConnector

All Implemented Interfaces:

org.eclipse.ecf.core.sharedobject.ISharedObjectConnector

public class SOConnector
extends java.lang.Object
implements org.eclipse.ecf.core.sharedobject.ISharedObjectConnector

Constructor Summary

SOConnector(ID sender, ID[] recv, org.eclipse.ecf.core.sharedobject.util.IQueueEnqueue[] queues)

Method Summary

IAsyncResult[]	callAsynch(org.eclipse.ecf.core.sharedobject.events.ISharedObjectEvent arg)
void	dispose()
void	enqueue(org.eclipse.ecf.core.sharedobject.events.ISharedObjectEvent event)
void	enqueue(org.eclipse.ecf.core.sharedobject.events.ISharedObjectEvent[] events)
protected IAsyncResult[]	fireCallEvent(org.eclipse.ecf.core.sharedobject.events.ISharedObjectEvent event)
protected void	fireEvent(org.eclipse.ecf.core.sharedobject.events.ISharedObjectEvent event)
protected void	fireEvents(org.eclipse.ecf.core.sharedobject.events.ISharedObjectEvent[] event)
ID[]	getReceiverIDs()
ID	getSenderID()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SOConnector

public SOConnector(ID sender,
                   ID[] recv,
                   org.eclipse.ecf.core.sharedobject.util.IQueueEnqueue[] queues)

Method Detail

fireEvent

protected void fireEvent(org.eclipse.ecf.core.sharedobject.events.ISharedObjectEvent event)
                  throws org.eclipse.ecf.core.sharedobject.util.QueueException

Throws:

org.eclipse.ecf.core.sharedobject.util.QueueException

fireEvents

protected void fireEvents(org.eclipse.ecf.core.sharedobject.events.ISharedObjectEvent[] event)
                   throws org.eclipse.ecf.core.sharedobject.util.QueueException

Throws:

org.eclipse.ecf.core.sharedobject.util.QueueException

fireCallEvent

protected IAsyncResult[] fireCallEvent(org.eclipse.ecf.core.sharedobject.events.ISharedObjectEvent event)
                                throws org.eclipse.ecf.core.sharedobject.util.QueueException

Throws:

org.eclipse.ecf.core.sharedobject.util.QueueException

getSenderID

public ID getSenderID()

Specified by:

getSenderID in interface org.eclipse.ecf.core.sharedobject.ISharedObjectConnector

getReceiverIDs

public ID[] getReceiverIDs()

Specified by:

getReceiverIDs in interface org.eclipse.ecf.core.sharedobject.ISharedObjectConnector

enqueue

public void enqueue(org.eclipse.ecf.core.sharedobject.events.ISharedObjectEvent event)
             throws org.eclipse.ecf.core.sharedobject.util.QueueException

Specified by:

enqueue in interface org.eclipse.ecf.core.sharedobject.ISharedObjectConnector

Throws:

org.eclipse.ecf.core.sharedobject.util.QueueException

enqueue

public void enqueue(org.eclipse.ecf.core.sharedobject.events.ISharedObjectEvent[] events)
             throws org.eclipse.ecf.core.sharedobject.util.QueueException

Specified by:

enqueue in interface org.eclipse.ecf.core.sharedobject.ISharedObjectConnector

Throws:

org.eclipse.ecf.core.sharedobject.util.QueueException

callAsynch

public IAsyncResult[] callAsynch(org.eclipse.ecf.core.sharedobject.events.ISharedObjectEvent arg)
                          throws java.lang.Exception

Throws:

java.lang.Exception

dispose

public void dispose()

Specified by:

dispose in interface org.eclipse.ecf.core.sharedobject.ISharedObjectConnector