org.apache.juddi.replication

Class ReplicationNotifier

java.lang.Object

java.util.TimerTask

org.apache.juddi.replication.ReplicationNotifier

All Implemented Interfaces:

Runnable

public class ReplicationNotifier
extends TimerTask

Handles when local records have been changed, change journal storage and notifications to all remote replication nodes that something has been altered.

Author:

Alex O'Ree

Constructor Summary

Constructors

Constructor and Description
ReplicationNotifier() default constructor

Method Summary

Modifier and Type	Method and Description
boolean	cancel()
static void	enqueue(ChangeRecord change)
static void	EnqueueRetransmit(org.uddi.repl_v3.ChangeRecord change)
static org.uddi.repl_v3.ReplicationConfiguration	FetchEdges() returns the latest version of the replication config or null if there is no config
protected void	ProcessChangeRecord(ChangeRecord j) Note: this is for locally originated changes only, see null null null PersistChangeRecord for how remote changes are processed
void	run()

Methods inherited from class java.util.TimerTask

scheduledExecutionTime

Methods inherited from class java.lang.Object

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

Constructor Detail

ReplicationNotifier

public ReplicationNotifier()
                    throws org.apache.commons.configuration.ConfigurationException

default constructor

Throws:

org.apache.commons.configuration.ConfigurationException

Method Detail

cancel

public boolean cancel()

Overrides:

cancel in class TimerTask

enqueue

public static void enqueue(ChangeRecord change)

EnqueueRetransmit

public static void EnqueueRetransmit(org.uddi.repl_v3.ChangeRecord change)

ProcessChangeRecord

protected void ProcessChangeRecord(ChangeRecord j)

Note: this is for locally originated changes only, see null null null PersistChangeRecord for how remote changes are processed

Parameters:

j - must be one of the UDDI save APIs

run

public void run()

Specified by:

run in interface Runnable

Specified by:

run in class TimerTask

FetchEdges

public static org.uddi.repl_v3.ReplicationConfiguration FetchEdges()

returns the latest version of the replication config or null if there is no config

Returns: