org.rvpf.store.server.som

Class SOMReplicator

Object

Replicator.Abstract

SOMReplicator

All Implemented Interfaces:

Replicator

public final class SOMReplicator
extends Replicator.Abstract

SOM replicator.

Nested Class Summary

Nested classes/interfaces inherited from interface Replicator

Replicator.Abstract, Replicator.Partner, Replicator.Target

Field Summary

Fields

Modifier and Type	Field and Description
static String	PARTNER_QUEUE_PROPERTIES Partner queue properties.

Fields inherited from class Replicator.Abstract

PARTNER_PROPERTIES, REPLICATE_CONVERTS_PROPERTY, REPLICATED_DEFAULTS_PROPERTY, REPLICATED_TRACES, REPLICATOR_PROPERTIES, STORE_NAME_PROPERTY

Constructor Summary

Constructors

Constructor and Description
SOMReplicator()

Method Summary

Modifier and Type	Method and Description
protected void	close(Replicator.Partner partner) Closes the connection with a partner.
protected void	commit(Replicator.Partner partner) Commits.
protected SOMReplicator.SOMPartner	newPartner(KeyedGroups partnerProperties) Returns a new partner informations object.
protected boolean	open(Replicator.Partner partner) Opens a connection with a partner.
protected void	replicate(ReplicatedValue replicatedValue, Replicator.Partner partner) Replicates a point value to a partner.
boolean	setUpImpl() Sets up the implementation for processing.

Methods inherited from class Replicator.Abstract

close, commit, filter, getAnonymousPartners, getMetadata, getPartnerNames, getPartners, getService, getStats, getTargets, getThisLogger, isEnabled, isReplicated, join, replicate, setUp, start, tearDown, useNewMetadata

Methods inherited from class Object

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

Field Detail

PARTNER_QUEUE_PROPERTIES

public static final String PARTNER_QUEUE_PROPERTIES

Partner queue properties.

See Also:

Constant Field Values

Constructor Detail

SOMReplicator

public SOMReplicator()

Method Detail

setUpImpl

public boolean setUpImpl()

Sets up the implementation for processing.

Specified by:

setUpImpl in interface Replicator

Overrides:

setUpImpl in class Replicator.Abstract

Returns:

True if successful.

close

protected void close(Replicator.Partner partner)

Closes the connection with a partner.

Specified by:

close in class Replicator.Abstract

Parameters:

partner - The partner.

commit

protected void commit(Replicator.Partner partner)
               throws InterruptedException

Commits.

Specified by:

commit in class Replicator.Abstract

Parameters:

partner - The partner.

Throws:

InterruptedException - When interrupted.

newPartner

protected SOMReplicator.SOMPartner newPartner(KeyedGroups partnerProperties)

Returns a new partner informations object.

Specified by:

newPartner in class Replicator.Abstract

Parameters:

partnerProperties - The partner configuration properties.

Returns:

The new partner informations object.

open

protected boolean open(Replicator.Partner partner)

Opens a connection with a partner.

Specified by:

open in class Replicator.Abstract

Parameters:

partner - The partner.

Returns:

True on success.

replicate

protected void replicate(ReplicatedValue replicatedValue,
                         Replicator.Partner partner)
                  throws InterruptedException

Replicates a point value to a partner.

Specified by:

replicate in class Replicator.Abstract

Parameters:

replicatedValue - The point value.

partner - The partner.

Throws:

InterruptedException - When interrupted.