org.openanzo.services
Interface IReplicationService

All Superinterfaces:

IService

All Known Implementing Classes:

EmbeddedReplicationService, WSReplicationService

public interface IReplicationService
extends IService

IReplicationService provides an endpoint that Anzo replication operations are run against.

Author:

Matthew Roy ( mroy@cambridgesemantics.com )

Field Summary

static int	REPLICATION_AUTOMATIC REPLICATION_AUTOMATIC specifies that LocalModel should replicate automatically after a given time interval passes.
static int	REPLICATION_IMMEDIATE_ASYNC REPLICATION_IMMEDIATE_ASYNC specifies that LocalModel should replicate automatically after every transaction submission in a asynchronous manor.
static int	REPLICATION_IMMEDIATE_SYNC REPLICATION_IMMEDIATE_SYNC specifies that LocalModel should replicate automatically after every transaction submission in a synchronous manor.
static int	REPLICATION_MANUAL REPLICATION_MANUAL specifies that LocalModel should never replicate automatically.

Method Summary

java.lang.Long

execReplicate(java.lang.Long markerIn, java.util.Set<ITracker> notificationTrackers, java.util.Set<ITracker> newNotificationTrackers, IRepositoryHandler repositoryHandler) Replicate with the Anzo server

Methods inherited from interface org.openanzo.services.IService

getServicePassword, getServiceUser, setServicePassword, setServiceUser

Field Detail

REPLICATION_IMMEDIATE_SYNC

static final int REPLICATION_IMMEDIATE_SYNC

REPLICATION_IMMEDIATE_SYNC specifies that LocalModel should replicate automatically after every transaction submission in a synchronous manor.

See Also:

Constant Field Values

REPLICATION_AUTOMATIC

static final int REPLICATION_AUTOMATIC

REPLICATION_AUTOMATIC specifies that LocalModel should replicate automatically after a given time interval passes.

See Also:

Constant Field Values

REPLICATION_MANUAL

static final int REPLICATION_MANUAL

REPLICATION_MANUAL specifies that LocalModel should never replicate automatically. Replication can still be invoked by calling the 'replicate' method.

See Also:

Constant Field Values

REPLICATION_IMMEDIATE_ASYNC

static final int REPLICATION_IMMEDIATE_ASYNC

REPLICATION_IMMEDIATE_ASYNC specifies that LocalModel should replicate automatically after every transaction submission in a asynchronous manor.

See Also:

Constant Field Values

Method Detail

execReplicate

java.lang.Long execReplicate(java.lang.Long markerIn,
                             java.util.Set<ITracker> notificationTrackers,
                             java.util.Set<ITracker> newNotificationTrackers,
                             IRepositoryHandler repositoryHandler)
                             throws AnzoException

Replicate with the Anzo server

Parameters:

markerIn - Timestamp of last replication

notificationTrackers - Set of already replicated notification trackers

newNotificationTrackers - Set of new notification trackers

repositoryHandler - IRepositoryHandler to handle the results of the replication

Returns:

Return the timestamp for last transaction included in replication

Throws:

AnzoException - if there was an error replicating with the server