er.extensions.remoteSynchronizer
Class ERXRemoteSynchronizer

java.lang.Object
  er.extensions.remoteSynchronizer.ERXRemoteSynchronizer

Direct Known Subclasses:

ERJGroupsSynchronizer, ERXSimpleMulticastSynchronizer

public abstract class ERXRemoteSynchronizer
extends java.lang.Object

The superclass of all remote EOF synchronizers.

Author:

mschrag

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)

Nested Class Summary

static class

ERXRemoteSynchronizer.RefByteArrayOutputStream

Field Summary

static org.apache.log4j.Logger

log

Constructor Summary

ERXRemoteSynchronizer(ERXObjectStoreCoordinatorSynchronizer.IChangeListener listener)

Method Summary

protected void	_readCacheChange(ERXObjectStoreCoordinatorSynchronizer.RemoteChange remoteChange, java.io.DataInputStream dis)
protected com.webobjects.eocontrol.EOGlobalID	_readGID(com.webobjects.eoaccess.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, com.webobjects.foundation.NSArray cacheChanges)
protected void	addChange(ERXObjectStoreCoordinatorSynchronizer.RemoteChange remoteChange)
protected com.webobjects.foundation.NSArray	filteredCacheChanges(com.webobjects.foundation.NSArray cacheChanges)
com.webobjects.foundation.NSDictionary	globalIDsGroupedByEntity(com.webobjects.foundation.NSArray 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 com.webobjects.eocontrol.EOGlobalID	readGID(java.io.DataInputStream dis)
protected com.webobjects.foundation.NSArray	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, com.webobjects.foundation.NSArray cacheChanges)
protected void	writeGID(java.io.DataOutputStream dos, com.webobjects.eocontrol.EOGlobalID gid)
protected void	writeGIDKeys(java.io.DataOutputStream dos, com.webobjects.eocontrol.EOKeyGlobalID gid)
protected void	writeGIDs(java.io.DataOutputStream dos, com.webobjects.foundation.NSArray gids)
protected void	writeKey(java.io.DataOutputStream dos, java.lang.Object key)
protected void	writeSnapshotCacheChange(java.io.DataOutputStream dos, ERXDatabase.CacheChange cacheChange)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

log

public static org.apache.log4j.Logger log

Constructor Detail

ERXRemoteSynchronizer

public ERXRemoteSynchronizer(ERXObjectStoreCoordinatorSynchronizer.IChangeListener listener)

Method Detail

remoteSynchronizerEnabled

public static boolean remoteSynchronizerEnabled()

newRemoteSynchronizer

public static ERXRemoteSynchronizer newRemoteSynchronizer(ERXObjectStoreCoordinatorSynchronizer.IChangeListener changeListener)
                                                   throws java.lang.Throwable

Throws:

java.lang.Throwable

_readCacheChange

protected void _readCacheChange(ERXObjectStoreCoordinatorSynchronizer.RemoteChange remoteChange,
                                java.io.DataInputStream dis)
                         throws java.io.IOException

Throws:

java.io.IOException

handleMessageType

protected boolean handleMessageType(int messageType,
                                    ERXObjectStoreCoordinatorSynchronizer.RemoteChange remoteChange,
                                    java.io.DataInputStream dis)

_writeCacheChange

protected void _writeCacheChange(java.io.DataOutputStream dos,
                                 ERXDatabase.CacheChange cacheChange)
                          throws java.io.IOException

Throws:

java.io.IOException

writeSnapshotCacheChange

protected void writeSnapshotCacheChange(java.io.DataOutputStream dos,
                                        ERXDatabase.CacheChange cacheChange)
                                 throws java.io.IOException

Throws:

java.io.IOException

writeGIDs

protected void writeGIDs(java.io.DataOutputStream dos,
                         com.webobjects.foundation.NSArray gids)
                  throws java.io.IOException

Throws:

java.io.IOException

writeGID

protected void writeGID(java.io.DataOutputStream dos,
                        com.webobjects.eocontrol.EOGlobalID gid)
                 throws java.io.IOException

Throws:

java.io.IOException

writeGIDKeys

protected void writeGIDKeys(java.io.DataOutputStream dos,
                            com.webobjects.eocontrol.EOKeyGlobalID gid)
                     throws java.io.IOException

Throws:

java.io.IOException

writeKey

protected void writeKey(java.io.DataOutputStream dos,
                        java.lang.Object key)
                 throws java.io.IOException

Throws:

java.io.IOException

readGIDs

protected com.webobjects.foundation.NSArray readGIDs(java.io.DataInputStream dis)
                                              throws java.io.IOException

Throws:

java.io.IOException

readGID

protected com.webobjects.eocontrol.EOGlobalID readGID(java.io.DataInputStream dis)
                                               throws java.io.IOException

Throws:

java.io.IOException

_readGID

protected com.webobjects.eocontrol.EOGlobalID _readGID(com.webobjects.eoaccess.EOEntityClassDescription classDescription,
                                                       java.lang.String entityName,
                                                       java.io.DataInputStream dis)
                                                throws java.io.IOException

Throws:

java.io.IOException

readKey

protected java.lang.Object readKey(java.io.DataInputStream dis)
                            throws java.io.IOException

Throws:

java.io.IOException

shouldSynchronizeEntity

public boolean shouldSynchronizeEntity(java.lang.String entityName)

globalIDsGroupedByEntity

public com.webobjects.foundation.NSDictionary globalIDsGroupedByEntity(com.webobjects.foundation.NSArray gids)

addChange

protected void addChange(ERXObjectStoreCoordinatorSynchronizer.RemoteChange remoteChange)

filteredCacheChanges

protected com.webobjects.foundation.NSArray filteredCacheChanges(com.webobjects.foundation.NSArray cacheChanges)

join

public abstract void join()
                   throws java.lang.Throwable

Throws:

java.lang.Throwable

leave

public abstract void leave()
                    throws java.lang.Throwable

Throws:

java.lang.Throwable

listen

public abstract void listen()
                     throws java.lang.Throwable

Throws:

java.lang.Throwable

writeCacheChanges

public void writeCacheChanges(int transactionID,
                              com.webobjects.foundation.NSArray cacheChanges)
                       throws java.lang.Throwable

Throws:

java.lang.Throwable

_writeCacheChanges

protected abstract void _writeCacheChanges(int transactionID,
                                           com.webobjects.foundation.NSArray cacheChanges)
                                    throws java.lang.Throwable

Throws:

java.lang.Throwable