Errai 3.0.1-SNAPSHOT

org.jboss.errai.otec.client
Class SinglePeerState

java.lang.Object
  extended by org.jboss.errai.otec.client.SinglePeerState
All Implemented Interfaces:
PeerState

public class SinglePeerState
extends Object
implements PeerState

Author:
Mike Brock

Constructor Summary
SinglePeerState()
           
 
Method Summary
 EntityStreamRegistration addEntityStream(EntityChangeStream stream)
           
 void addResyncListener(Integer entity, ResyncListener resyncListener)
           
 void associateEntity(OTPeer peer, Integer entity)
           
 void deregisterPeer(OTPeer peer)
           
 void disassociateEntity(OTPeer peer, Integer entity)
           
 void flushEntityStreams(Integer entityId)
           
 void forceResyncAll(OTEntity entity)
           
 Map<Integer,Set<OTPeer>> getEntityPeerRelationshipMap()
           
 OTPeer getPeer(String peerId)
           
 Set<OTPeer> getPeersFor(Integer entity)
           
 boolean hasConflictResolutionPrecedence()
           
 void notifyResync(OTEntity entity)
           
 void registerPeer(OTPeer peer)
           
 boolean shouldForwardOperation(OTOperation operation)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

SinglePeerState

public SinglePeerState()
Method Detail

getPeer

public OTPeer getPeer(String peerId)
Specified by:
getPeer in interface PeerState

registerPeer

public void registerPeer(OTPeer peer)
Specified by:
registerPeer in interface PeerState

deregisterPeer

public void deregisterPeer(OTPeer peer)
Specified by:
deregisterPeer in interface PeerState

getEntityPeerRelationshipMap

public Map<Integer,Set<OTPeer>> getEntityPeerRelationshipMap()
Specified by:
getEntityPeerRelationshipMap in interface PeerState

getPeersFor

public Set<OTPeer> getPeersFor(Integer entity)
Specified by:
getPeersFor in interface PeerState

forceResyncAll

public void forceResyncAll(OTEntity entity)
Specified by:
forceResyncAll in interface PeerState

addResyncListener

public void addResyncListener(Integer entity,
                              ResyncListener resyncListener)
Specified by:
addResyncListener in interface PeerState

notifyResync

public void notifyResync(OTEntity entity)
Specified by:
notifyResync in interface PeerState

associateEntity

public void associateEntity(OTPeer peer,
                            Integer entity)
Specified by:
associateEntity in interface PeerState

disassociateEntity

public void disassociateEntity(OTPeer peer,
                               Integer entity)
Specified by:
disassociateEntity in interface PeerState

addEntityStream

public EntityStreamRegistration addEntityStream(EntityChangeStream stream)
Specified by:
addEntityStream in interface PeerState

flushEntityStreams

public void flushEntityStreams(Integer entityId)
Specified by:
flushEntityStreams in interface PeerState

shouldForwardOperation

public boolean shouldForwardOperation(OTOperation operation)
Specified by:
shouldForwardOperation in interface PeerState

hasConflictResolutionPrecedence

public boolean hasConflictResolutionPrecedence()
Specified by:
hasConflictResolutionPrecedence in interface PeerState

Errai 3.0.1-SNAPSHOT

Copyright © 2013-2014 JBoss, a division of Red Hat. All Rights Reserved.