er.jgroups

Class ERJGroupsSynchronizer

java.lang.Object

er.extensions.remoteSynchronizer.ERXRemoteSynchronizer

er.jgroups.ERJGroupsSynchronizer

public class ERJGroupsSynchronizer
extends ERXRemoteSynchronizer

A multicast synchronizer built on top of the JGroups library. This is a much more robust implementation than the default synchronizer used by ERXObjectStoreCoordinatorSynchronizer. See http://www.jgroups.org/manual/index.html#Transport for network transport configuration. By default in this repositors, jgroups is set up to use multicast with configurable local bind address, multicast address and multicast port via the jgroups-default.xml file.

Author:

mschrag

Properties

Name	Description
er.extensions.ERXObjectStoreCoordinatorPool.maxCoordinators	you should set this property to at least "1" to trigger ERXObjectStoreCoordinatorSynchronizer to turn on
er.extensions.jgroupsSynchronizer.applicationWillTerminateNotificationName	the name of the NSNotification that is sent when the application is terminating. Leave blank to disable this feature.
er.extensions.jgroupsSynchronizer.autoReconnect	whether to auto reconnect when shunned (defaults to false)
er.extensions.jgroupsSynchronizer.groupName	the JGroups group name to use (defaults to WOApplication.application.name)
er.extensions.jgroupsSynchronizer.properties	an XML JGroups configuration file (defaults to jgroups-default.xml in this framework)
er.extensions.jgroupsSynchronizer.localBindAddress	the local address to bind to when using the provided multicast configuration file (defaults to SITE_LOCAL)
er.extensions.jgroupsSynchronizer.multicastAddress	the multicast address to use when using the provided multicast configuration file (defaults to 230.0.0.1)
er.extensions.jgroupsSynchronizer.multicastPort	no longer used. Replaced by jgroups.udp.mcast_port
er.extensions.jgroupsSynchronizer.useShutdownHook	whether to register a JVM shutdown hook to clean up the JChannel (defaults to true)
er.extensions.remoteSynchronizer	"er.jgroups.ERJGroupsSynchronizer" for this implementation
er.extensions.remoteSynchronizer.enabled	if true, remote synchronization is enabled
er.extensions.remoteSynchronizer.excludeEntities	the list of entities to NOT synchronize (none by default)
er.extensions.remoteSynchronizer.includeEntities	the list of entities to synchronize (all by default)

Nested Class Summary

Nested classes/interfaces inherited from class er.extensions.remoteSynchronizer.ERXRemoteSynchronizer

ERXRemoteSynchronizer.RefByteArrayOutputStream

Constructor Summary

Constructors

Constructor and Description
ERJGroupsSynchronizer(ERXObjectStoreCoordinatorSynchronizer.IChangeListener listener)

Method Summary

Modifier and Type	Method and Description
void	_applicationWillTerminateNotification(NSNotification notification)
protected void	_writeCacheChanges(int transactionID, NSArray cacheChanges)
void	join()
void	leave()
void	listen()

Methods inherited from class er.extensions.remoteSynchronizer.ERXRemoteSynchronizer

_readCacheChange, _readGID, _writeCacheChange, addChange, filteredCacheChanges, globalIDsGroupedByEntity, handleMessageType, newRemoteSynchronizer, readGID, readGIDs, readKey, remoteSynchronizerEnabled, shouldSynchronizeEntity, writeCacheChanges, writeGID, writeGIDKeys, writeGIDs, writeKey, writeSnapshotCacheChange

Methods inherited from class java.lang.Object

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

Constructor Detail

ERJGroupsSynchronizer

public ERJGroupsSynchronizer(ERXObjectStoreCoordinatorSynchronizer.IChangeListener listener)
                      throws Exception

Throws:

Exception

Method Detail

join

public void join()
          throws Exception

Specified by:

join in class ERXRemoteSynchronizer

Throws:

Exception

leave

public void leave()

Specified by:

leave in class ERXRemoteSynchronizer

listen

public void listen()

Specified by:

listen in class ERXRemoteSynchronizer

_writeCacheChanges

protected void _writeCacheChanges(int transactionID,
                                  NSArray cacheChanges)
                           throws Exception,
                                  IOException

Specified by:

_writeCacheChanges in class ERXRemoteSynchronizer

Throws:

Exception

IOException

_applicationWillTerminateNotification

public void _applicationWillTerminateNotification(NSNotification notification)