public abstract class AbstractOTEngine extends Object implements OTEngine
Modifier and Type | Class and Description |
---|---|
protected static class |
AbstractOTEngine.DefaultOTOperationsFactory |
Modifier and Type | Field and Description |
---|---|
protected String |
engineId |
protected OTEntityState |
entityState |
protected OTEngineMode |
mode |
protected String |
name |
protected PeerState |
peerState |
Constructor and Description |
---|
AbstractOTEngine(String name,
PeerState peerState) |
Modifier and Type | Method and Description |
---|---|
protected OTOperation |
applyFromRemote(OTOperation remoteOp) |
OTOperation |
applyLocally(OTOperation operation) |
void |
associateEntity(String peerId,
int entityId) |
void |
disassociateEntity(String peerId,
int entityId) |
OTEntityState |
getEntityStateSpace() |
String |
getId() |
InitialStateReceiveHandler |
getInitialStateReceiveHandler(String peerId,
int entityId) |
String |
getName() |
OTOperationsFactory |
getOperationsFactory() |
PeerState |
getPeerState() |
void |
notifyOperation(OTOperation operation) |
void |
notifyRemotes(OTOperation operation) |
void |
registerPeer(OTPeer peer) |
protected void |
setMode(OTEngineMode mode) |
void |
syncRemoteEntity(String peerId,
int entityId,
EntitySyncCompletionCallback callback) |
String |
toString() |
protected final String engineId
protected final PeerState peerState
protected final OTEntityState entityState
protected volatile OTEngineMode mode
protected String name
protected OTOperation applyFromRemote(OTOperation remoteOp)
public InitialStateReceiveHandler getInitialStateReceiveHandler(String peerId, int entityId)
getInitialStateReceiveHandler
in interface OTEngine
public void syncRemoteEntity(String peerId, int entityId, EntitySyncCompletionCallback callback)
syncRemoteEntity
in interface OTEngine
public void notifyOperation(OTOperation operation)
notifyOperation
in interface OTEngine
public OTOperation applyLocally(OTOperation operation)
public void notifyRemotes(OTOperation operation)
public OTOperationsFactory getOperationsFactory()
getOperationsFactory
in interface OTEngine
public OTEntityState getEntityStateSpace()
getEntityStateSpace
in interface OTEngine
public PeerState getPeerState()
getPeerState
in interface OTEngine
public void associateEntity(String peerId, int entityId)
associateEntity
in interface OTEngine
public void disassociateEntity(String peerId, int entityId)
disassociateEntity
in interface OTEngine
public void registerPeer(OTPeer peer)
registerPeer
in interface OTEngine
protected void setMode(OTEngineMode mode)
Copyright © 2013-2015 JBoss, a division of Red Hat. All Rights Reserved.