Saros
Distributed Collaborative Editing and Distributed Party Programming
|
Public Member Functions | |
SarosSXETransmitter (ISarosSession sarosSession) | |
void | installRecordReceiver (final SXEController controller) |
void | sendAsync (final SXEMessage msg) |
synchronized SXEMessage | sendAndAwait (IProgressMonitor monitor, SXEMessage msg, SXEMessageType...awaitFor) throws IOException |
void | enableInvitation (final SXEController controller) |
void | disconnect () |
void | dispose () |
Static Public Attributes | |
static final Logger | log |
Protected Member Functions | |
void | sendWithoutDispatch (SXEMessage msg) |
void | setSender (List< RecordDataObject > rdos, String sender) |
String | prefix () |
Protected Attributes | |
ExecutorService | sendingDispatch |
Uses Smack and Saros to establish the SXE communication.
It maintains invitation and record listener as well as the extension provider.
de.fu_berlin.inf.dpp.whiteboard.net.SarosSXETransmitter.SarosSXETransmitter | ( | ISarosSession | sarosSession | ) |
void de.fu_berlin.inf.dpp.whiteboard.net.SarosSXETransmitter.disconnect | ( | ) |
Don's receive anymore records
void de.fu_berlin.inf.dpp.whiteboard.net.SarosSXETransmitter.dispose | ( | ) |
remove the extension provider and invitation
void de.fu_berlin.inf.dpp.whiteboard.net.SarosSXETransmitter.enableInvitation | ( | final SXEController | controller | ) |
Registers the controller to receive state-offer messages and to start the invitation process
void de.fu_berlin.inf.dpp.whiteboard.net.SarosSXETransmitter.installRecordReceiver | ( | final SXEController | controller | ) |
registers the controller to receive records
Implements de.fu_berlin.inf.dpp.whiteboard.sxe.net.ISXETransmitter.
String de.fu_berlin.inf.dpp.whiteboard.net.SarosSXETransmitter.prefix | ( | ) | [protected] |
synchronized SXEMessage de.fu_berlin.inf.dpp.whiteboard.net.SarosSXETransmitter.sendAndAwait | ( | IProgressMonitor | monitor, |
SXEMessage | msg, | ||
SXEMessageType... | awaitFor | ||
) | throws IOException |
void de.fu_berlin.inf.dpp.whiteboard.net.SarosSXETransmitter.sendAsync | ( | final SXEMessage | msg | ) |
void de.fu_berlin.inf.dpp.whiteboard.net.SarosSXETransmitter.sendWithoutDispatch | ( | SXEMessage | msg | ) | [protected] |
void de.fu_berlin.inf.dpp.whiteboard.net.SarosSXETransmitter.setSender | ( | List< RecordDataObject > | rdos, |
String | sender | ||
) | [protected] |
final Logger de.fu_berlin.inf.dpp.whiteboard.net.SarosSXETransmitter.log [static] |
Logger .getLogger(SarosSXETransmitter.class)
ExecutorService de.fu_berlin.inf.dpp.whiteboard.net.SarosSXETransmitter.sendingDispatch [protected] |
Executors .newSingleThreadExecutor(new NamedThreadFactory( "Whiteboard-SXESending-Dispatch-"))