com.threerings.crowd.peer.server

Class CrowdPeerManager

java.lang.Object

com.threerings.presents.peer.server.PeerManager

com.threerings.crowd.peer.server.CrowdPeerManager

All Implemented Interfaces:

Lifecycle.BaseComponent, Lifecycle.ShutdownComponent, ChatProvider.ChatForwarder, CrowdPeerProvider, PeerProvider, ClientManager.ClientObserver, InvocationProvider

public abstract class CrowdPeerManager
extends PeerManager
implements CrowdPeerProvider, ChatProvider.ChatForwarder

Extends the standard peer manager and bridges certain Crowd services.

Nested Class Summary

Nested classes/interfaces inherited from class com.threerings.presents.peer.server.PeerManager

PeerManager.DroppedLockObserver, PeerManager.LockedOperation, PeerManager.NodeAction, PeerManager.NodeApplicant, PeerManager.NodeRequest, PeerManager.StaleCacheObserver, PeerManager.Stats

Constructor Summary

Constructors

Constructor and Description
CrowdPeerManager(Lifecycle cycle) Creates an uninitialized peer manager.

Method Summary

Modifier and Type	Method and Description
void	deliverBroadcast(ClientObject caller, Name from, byte levelOrMode, String bundle, String msg) Handles a CrowdPeerService.deliverBroadcast(com.threerings.util.Name, byte, java.lang.String, java.lang.String) request.
void	deliverTell(ClientObject caller, UserMessage message, Name target, ChatService.TellListener listener) Handles a CrowdPeerService.deliverTell(com.threerings.crowd.chat.data.UserMessage, com.threerings.util.Name, com.threerings.crowd.chat.client.ChatService.TellListener) request.
void	forwardBroadcast(Name from, byte levelOrMode, String bundle, String msg) Requests that the supplied broadcast message be delivered on other servers.
boolean	forwardTell(UserMessage message, Name target, ChatService.TellListener listener) Requests that the supplied tell message be delivered to the appropriate destination.
void	shutdown()

Methods inherited from class com.threerings.presents.peer.server.PeerManager

acquireLock, addDroppedLockObserver, addStaleCacheObserver, broadcastStaleCacheData, clientSessionDidEnd, clientSessionDidStart, clientSubscribedToNode, clientUnsubscribedFromNode, findApplicableNodes, generateReport, getNodeObject, getNodeObjects, getPeerClient, getPeerInternalHostName, getPeerNodeObject, getPeerPort, getPeerPublicHostName, getStats, init, init, init, init, invokeAction, invokeNodeAction, invokeNodeAction, invokeNodeAction, invokeNodeRequest, invokeNodeRequest, invokeOnNodes, invokeRequest, isAuthenticPeer, locateClient, lookupNodeDatum, performWithLock, proxyRemoteObject, proxyRemoteObject, queryLock, queryLock, ratifyLockAction, reacquireLock, releaseLock, removeDroppedLockObserver, removeStaleCacheObserver, unproxyRemoteObject, unproxyRemoteObject

Methods inherited from class java.lang.Object

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

Constructor Detail

CrowdPeerManager

@Inject
public CrowdPeerManager(Lifecycle cycle)

Creates an uninitialized peer manager.

Method Detail

deliverTell

public void deliverTell(ClientObject caller,
                        UserMessage message,
                        Name target,
                        ChatService.TellListener listener)
                 throws InvocationException

Description copied from interface: CrowdPeerProvider

Handles a CrowdPeerService.deliverTell(com.threerings.crowd.chat.data.UserMessage, com.threerings.util.Name, com.threerings.crowd.chat.client.ChatService.TellListener) request.

Specified by:

deliverTell in interface CrowdPeerProvider

Throws:

InvocationException

deliverBroadcast

public void deliverBroadcast(ClientObject caller,
                             Name from,
                             byte levelOrMode,
                             String bundle,
                             String msg)

Description copied from interface: CrowdPeerProvider

Handles a CrowdPeerService.deliverBroadcast(com.threerings.util.Name, byte, java.lang.String, java.lang.String) request.

Specified by:

deliverBroadcast in interface CrowdPeerProvider

forwardTell

public boolean forwardTell(UserMessage message,
                           Name target,
                           ChatService.TellListener listener)

Description copied from interface: ChatProvider.ChatForwarder

Requests that the supplied tell message be delivered to the appropriate destination.

Specified by:

forwardTell in interface ChatProvider.ChatForwarder

Returns:

true if the tell was delivered, false otherwise.

forwardBroadcast

public void forwardBroadcast(Name from,
                             byte levelOrMode,
                             String bundle,
                             String msg)

Description copied from interface: ChatProvider.ChatForwarder

Requests that the supplied broadcast message be delivered on other servers.

Specified by:

forwardBroadcast in interface ChatProvider.ChatForwarder

shutdown

public void shutdown()

Specified by:

shutdown in interface Lifecycle.ShutdownComponent

Overrides:

shutdown in class PeerManager