Saros
Distributed Collaborative Editing and Distributed Party Programming
de.fu_berlin.inf.dpp.whiteboard.net.SarosSXETransmitter Class Reference
Inheritance diagram for de.fu_berlin.inf.dpp.whiteboard.net.SarosSXETransmitter:
de.fu_berlin.inf.dpp.whiteboard.sxe.net.ISXETransmitter

List of all members.

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

Detailed Description

Uses Smack and Saros to establish the SXE communication.

It maintains invitation and record listener as well as the extension provider.

Author:
jurke

Constructor & Destructor Documentation

de.fu_berlin.inf.dpp.whiteboard.net.SarosSXETransmitter.SarosSXETransmitter ( ISarosSession  sarosSession)

Member Function Documentation

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]

Member Data Documentation

Initial value:
 Logger
        .getLogger(SarosSXETransmitter.class)
Initial value:
 Executors
        .newSingleThreadExecutor(new NamedThreadFactory(
            "Whiteboard-SXESending-Dispatch-"))
 All Classes Namespaces Files Functions Variables Enumerations