public class ERXSimpleMulticastSynchronizer extends ERXRemoteSynchronizer
| Properties | |
er.extensions.ERXObjectStoreCoordinatorPool.maxCoordinators | you should set this property to at least "1" to trigger ERXObjectStoreCoordinatorSynchronizer to turn on |
er.extensions.remoteSynchronizer.enabled | if true, remote synchronization is enabled |
er.extensions.remoteSynchronizer | "er.extensions.ERXSimpleMulticastSynchronizer" for this implementation |
er.extensions.multicastSynchronizer.localBindAddress | the local address to bind to |
er.extensions.multicastSynchronizer.group | the multicast address to send to |
er.extensions.multicastSynchronizer.port | the multicast port to send to |
er.extensions.multicastSynchronizer.whitelist | the comma-separated list of addresses that can send to this group |
er.extensions.multicastSynchronizer.maxPacketSize | the maximum multicast packet size |
er.extensions.multicastSynchronizer.identifier | the unique identifier for this host (autogenerated by default) |
er.extensions.remoteSynchronizer.includeEntities | the list of entities to synchronize (all by default) |
er.extensions.remoteSynchronizer.excludeEntities | the list of entities to NOT synchronize (none by default) |
| Modifier and Type | Class and Description |
|---|---|
protected class |
ERXSimpleMulticastSynchronizer.MulticastByteArrayOutputStream |
ERXRemoteSynchronizer.RefByteArrayOutputStream| Modifier and Type | Field and Description |
|---|---|
static int |
IDENTIFIER_LENGTH |
log| Constructor and Description |
|---|
ERXSimpleMulticastSynchronizer(ERXObjectStoreCoordinatorSynchronizer.IChangeListener listener) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
_writeCacheChanges(int transactionID,
NSArray<ERXDatabase.CacheChange> cacheChanges) |
protected boolean |
handleMessageType(int messageType,
ERXObjectStoreCoordinatorSynchronizer.RemoteChange remoteChange,
java.io.DataInputStream dis) |
void |
join() |
void |
leave() |
void |
listen() |
void |
writeCacheChange(ERXDatabase.CacheChange cacheChange,
int transactionID,
short transactionNum,
short transactionSize) |
_readCacheChange, _readGID, _writeCacheChange, addChange, filteredCacheChanges, globalIDsGroupedByEntity, newRemoteSynchronizer, readGID, readGIDs, readKey, remoteSynchronizerEnabled, shouldSynchronizeEntity, writeCacheChanges, writeGID, writeGIDKeys, writeGIDs, writeKey, writeSnapshotCacheChangepublic static final int IDENTIFIER_LENGTH
public ERXSimpleMulticastSynchronizer(ERXObjectStoreCoordinatorSynchronizer.IChangeListener listener) throws java.io.IOException
java.io.IOExceptionpublic void join()
throws java.io.IOException
join in class ERXRemoteSynchronizerjava.io.IOExceptionpublic void leave()
throws java.io.IOException
leave in class ERXRemoteSynchronizerjava.io.IOExceptionprotected boolean handleMessageType(int messageType,
ERXObjectStoreCoordinatorSynchronizer.RemoteChange remoteChange,
java.io.DataInputStream dis)
handleMessageType in class ERXRemoteSynchronizerpublic void listen()
throws java.io.IOException
listen in class ERXRemoteSynchronizerjava.io.IOExceptionprotected void _writeCacheChanges(int transactionID,
NSArray<ERXDatabase.CacheChange> cacheChanges)
throws java.io.IOException
_writeCacheChanges in class ERXRemoteSynchronizerjava.io.IOExceptionpublic void writeCacheChange(ERXDatabase.CacheChange cacheChange, int transactionID, short transactionNum, short transactionSize) throws java.io.IOException
java.io.IOExceptionCopyright © 2002 – 2022 Project Wonder.