Constructor and Description |
---|
SinglePeerState() |
Modifier and Type | Method and Description |
---|---|
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) |
public void registerPeer(OTPeer peer)
registerPeer
in interface PeerState
public void deregisterPeer(OTPeer peer)
deregisterPeer
in interface PeerState
public Map<Integer,Set<OTPeer>> getEntityPeerRelationshipMap()
getEntityPeerRelationshipMap
in interface PeerState
public Set<OTPeer> getPeersFor(Integer entity)
getPeersFor
in interface PeerState
public void forceResyncAll(OTEntity entity)
forceResyncAll
in interface PeerState
public void addResyncListener(Integer entity, ResyncListener resyncListener)
addResyncListener
in interface PeerState
public void notifyResync(OTEntity entity)
notifyResync
in interface PeerState
public void associateEntity(OTPeer peer, Integer entity)
associateEntity
in interface PeerState
public void disassociateEntity(OTPeer peer, Integer entity)
disassociateEntity
in interface PeerState
public EntityStreamRegistration addEntityStream(EntityChangeStream stream)
addEntityStream
in interface PeerState
public void flushEntityStreams(Integer entityId)
flushEntityStreams
in interface PeerState
public boolean shouldForwardOperation(OTOperation operation)
shouldForwardOperation
in interface PeerState
public boolean hasConflictResolutionPrecedence()
hasConflictResolutionPrecedence
in interface PeerState
Copyright © 2013-2015 JBoss, a division of Red Hat. All Rights Reserved.