Errai 3.0.1-SNAPSHOT

org.jboss.errai.otec.server
Class ServerOTPeerImpl

java.lang.Object
  extended by org.jboss.errai.otec.server.ServerOTPeerImpl
All Implemented Interfaces:
OTPeer

public class ServerOTPeerImpl
extends Object
implements OTPeer

Author:
Mike Brock

Field Summary
protected  Map<Integer,org.jboss.errai.otec.server.ServerOTPeerImpl.PeerData> peerDataMap
           
protected  boolean synced
           
 
Constructor Summary
ServerOTPeerImpl(String remoteEngineId, MessageBus bus)
           
 
Method Summary
 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)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

peerDataMap

protected final Map<Integer,org.jboss.errai.otec.server.ServerOTPeerImpl.PeerData> peerDataMap

synced

protected volatile boolean synced
Constructor Detail

ServerOTPeerImpl

public ServerOTPeerImpl(String remoteEngineId,
                        MessageBus bus)
Method Detail

getId

public String getId()
Specified by:
getId in interface OTPeer

sendPurgeHint

public void sendPurgeHint(Integer entityId,
                          int revision)
Specified by:
sendPurgeHint in interface OTPeer

send

public void send(OTOperation operation)
Specified by:
send in interface OTPeer

forceResync

public void forceResync(Integer entityId,
                        int revision,
                        String state)
Specified by:
forceResync in interface OTPeer

isSynced

public boolean isSynced()
Specified by:
isSynced in interface OTPeer

setSynced

public void setSynced(boolean synced)

beginSyncRemoteEntity

public void beginSyncRemoteEntity(String peerId,
                                  int entityId,
                                  EntitySyncCompletionCallback<State> callback)
Specified by:
beginSyncRemoteEntity in interface OTPeer

setLastKnownRemoteSequence

public void setLastKnownRemoteSequence(Integer entity,
                                       int sequence)
Specified by:
setLastKnownRemoteSequence in interface OTPeer

getLastKnownRemoteSequence

public int getLastKnownRemoteSequence(Integer entity)
Specified by:
getLastKnownRemoteSequence in interface OTPeer

getLastTransmittedSequence

public int getLastTransmittedSequence(Integer entity)
Specified by:
getLastTransmittedSequence in interface OTPeer

getPeerData

protected org.jboss.errai.otec.server.ServerOTPeerImpl.PeerData getPeerData(Integer entityId)

Errai 3.0.1-SNAPSHOT

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