public abstract class ERXRemoteSynchronizer
extends java.lang.Object
| Properties | |
er.extensions.remoteSynchronizer.enabled | if true, remote synchronization is enabled |
er.extensions.remoteSynchronizer | the class name of the remote synchronizer to use (default to ERXSimpleMulticastSynchronizer) |
er.extensions.remoteSynchronizer.includeEntities | er.extensions.remoteSynchronizer.includeEntities |
er.extensions.remoteSynchronizer.excludeEntities | er.extensions.remoteSynchronizer.excludeEntities |
| Modifier and Type | Class and Description |
|---|---|
static class |
ERXRemoteSynchronizer.RefByteArrayOutputStream |
| Modifier and Type | Field and Description |
|---|---|
static org.apache.log4j.Logger |
log |
| Constructor and Description |
|---|
ERXRemoteSynchronizer(ERXObjectStoreCoordinatorSynchronizer.IChangeListener listener) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
_readCacheChange(ERXObjectStoreCoordinatorSynchronizer.RemoteChange remoteChange,
java.io.DataInputStream dis) |
protected EOGlobalID |
_readGID(EOEntityClassDescription classDescription,
java.lang.String entityName,
java.io.DataInputStream dis) |
protected void |
_writeCacheChange(java.io.DataOutputStream dos,
ERXDatabase.CacheChange cacheChange) |
protected abstract void |
_writeCacheChanges(int transactionID,
NSArray<ERXDatabase.CacheChange> cacheChanges) |
protected void |
addChange(ERXObjectStoreCoordinatorSynchronizer.RemoteChange remoteChange) |
protected NSArray<ERXDatabase.CacheChange> |
filteredCacheChanges(NSArray<ERXDatabase.CacheChange> cacheChanges) |
NSDictionary<java.lang.String,NSSet<EOGlobalID>> |
globalIDsGroupedByEntity(NSArray<EOGlobalID> gids) |
protected boolean |
handleMessageType(int messageType,
ERXObjectStoreCoordinatorSynchronizer.RemoteChange remoteChange,
java.io.DataInputStream dis) |
abstract void |
join() |
abstract void |
leave() |
abstract void |
listen() |
static ERXRemoteSynchronizer |
newRemoteSynchronizer(ERXObjectStoreCoordinatorSynchronizer.IChangeListener changeListener) |
protected EOGlobalID |
readGID(java.io.DataInputStream dis) |
protected NSArray<EOGlobalID> |
readGIDs(java.io.DataInputStream dis) |
protected java.lang.Object |
readKey(java.io.DataInputStream dis) |
static boolean |
remoteSynchronizerEnabled() |
boolean |
shouldSynchronizeEntity(java.lang.String entityName) |
void |
writeCacheChanges(int transactionID,
NSArray<ERXDatabase.CacheChange> cacheChanges) |
protected void |
writeGID(java.io.DataOutputStream dos,
EOGlobalID gid) |
protected void |
writeGIDKeys(java.io.DataOutputStream dos,
EOKeyGlobalID gid) |
protected void |
writeGIDs(java.io.DataOutputStream dos,
NSArray<EOGlobalID> gids) |
protected void |
writeKey(java.io.DataOutputStream dos,
java.lang.Object key) |
protected void |
writeSnapshotCacheChange(java.io.DataOutputStream dos,
ERXDatabase.CacheChange cacheChange) |
public ERXRemoteSynchronizer(ERXObjectStoreCoordinatorSynchronizer.IChangeListener listener)
public static boolean remoteSynchronizerEnabled()
public static ERXRemoteSynchronizer newRemoteSynchronizer(ERXObjectStoreCoordinatorSynchronizer.IChangeListener changeListener) throws java.lang.Throwable
java.lang.Throwableprotected void _readCacheChange(ERXObjectStoreCoordinatorSynchronizer.RemoteChange remoteChange, java.io.DataInputStream dis) throws java.io.IOException
java.io.IOExceptionprotected boolean handleMessageType(int messageType,
ERXObjectStoreCoordinatorSynchronizer.RemoteChange remoteChange,
java.io.DataInputStream dis)
protected void _writeCacheChange(java.io.DataOutputStream dos,
ERXDatabase.CacheChange cacheChange)
throws java.io.IOException
java.io.IOExceptionprotected void writeSnapshotCacheChange(java.io.DataOutputStream dos,
ERXDatabase.CacheChange cacheChange)
throws java.io.IOException
java.io.IOExceptionprotected void writeGIDs(java.io.DataOutputStream dos,
NSArray<EOGlobalID> gids)
throws java.io.IOException
java.io.IOExceptionprotected void writeGID(java.io.DataOutputStream dos,
EOGlobalID gid)
throws java.io.IOException
java.io.IOExceptionprotected void writeGIDKeys(java.io.DataOutputStream dos,
EOKeyGlobalID gid)
throws java.io.IOException
java.io.IOExceptionprotected void writeKey(java.io.DataOutputStream dos,
java.lang.Object key)
throws java.io.IOException
java.io.IOExceptionprotected NSArray<EOGlobalID> readGIDs(java.io.DataInputStream dis) throws java.io.IOException
java.io.IOExceptionprotected EOGlobalID readGID(java.io.DataInputStream dis) throws java.io.IOException
java.io.IOExceptionprotected EOGlobalID _readGID(EOEntityClassDescription classDescription, java.lang.String entityName, java.io.DataInputStream dis) throws java.io.IOException
java.io.IOExceptionprotected java.lang.Object readKey(java.io.DataInputStream dis)
throws java.io.IOException
java.io.IOExceptionpublic boolean shouldSynchronizeEntity(java.lang.String entityName)
public NSDictionary<java.lang.String,NSSet<EOGlobalID>> globalIDsGroupedByEntity(NSArray<EOGlobalID> gids)
protected void addChange(ERXObjectStoreCoordinatorSynchronizer.RemoteChange remoteChange)
protected NSArray<ERXDatabase.CacheChange> filteredCacheChanges(NSArray<ERXDatabase.CacheChange> cacheChanges)
public abstract void join()
throws java.lang.Throwable
java.lang.Throwablepublic abstract void leave()
throws java.lang.Throwable
java.lang.Throwablepublic abstract void listen()
throws java.lang.Throwable
java.lang.Throwablepublic void writeCacheChanges(int transactionID,
NSArray<ERXDatabase.CacheChange> cacheChanges)
throws java.lang.Throwable
java.lang.Throwableprotected abstract void _writeCacheChanges(int transactionID,
NSArray<ERXDatabase.CacheChange> cacheChanges)
throws java.lang.Throwable
java.lang.ThrowableCopyright © 2002 – 2022 Project Wonder.