Modifier and Type | Field and Description |
---|---|
protected Map<Integer,org.jboss.errai.otec.server.ServerOTPeerImpl.PeerData> |
peerDataMap |
protected boolean |
synced |
Constructor and Description |
---|
ServerOTPeerImpl(String remoteEngineId,
MessageBus bus) |
Modifier and Type | Method and Description |
---|---|
void |
beginSyncRemoteEntity(String peerId,
int entityId,
EntitySyncCompletionCallback<State> callback) |
void |
forceResync(Integer entityId,
int revision,
String state) |
String |
getId() |
int |
getLastKnownRemoteSequence(Integer entity) |
int |
getLastTransmittedSequence(Integer entity) |
protected org.jboss.errai.otec.server.ServerOTPeerImpl.PeerData |
getPeerData(Integer entityId) |
boolean |
isSynced() |
void |
send(OTOperation operation) |
void |
sendPurgeHint(Integer entityId,
int revision) |
void |
setLastKnownRemoteSequence(Integer entity,
int sequence) |
void |
setSynced(boolean synced) |
protected final Map<Integer,org.jboss.errai.otec.server.ServerOTPeerImpl.PeerData> peerDataMap
protected volatile boolean synced
public ServerOTPeerImpl(String remoteEngineId, MessageBus bus)
public void sendPurgeHint(Integer entityId, int revision)
sendPurgeHint
in interface OTPeer
public void send(OTOperation operation)
public void forceResync(Integer entityId, int revision, String state)
forceResync
in interface OTPeer
public void setSynced(boolean synced)
public void beginSyncRemoteEntity(String peerId, int entityId, EntitySyncCompletionCallback<State> callback)
beginSyncRemoteEntity
in interface OTPeer
public void setLastKnownRemoteSequence(Integer entity, int sequence)
setLastKnownRemoteSequence
in interface OTPeer
public int getLastKnownRemoteSequence(Integer entity)
getLastKnownRemoteSequence
in interface OTPeer
public int getLastTransmittedSequence(Integer entity)
getLastTransmittedSequence
in interface OTPeer
protected org.jboss.errai.otec.server.ServerOTPeerImpl.PeerData getPeerData(Integer entityId)
Copyright © 2013-2015 JBoss, a division of Red Hat. All Rights Reserved.