org.openanzo.server.repository
Class ReplicationService

java.lang.Object
  org.openanzo.server.repository.ReplicationService

public class ReplicationService
extends java.lang.Object

ReplicationService handles determining the replication changes between 2 points in time

Author:

Matthew Roy ( mroy@cambridgesemantics.com )

Constructor Summary

ReplicationService(RepositoryConnection repositoryConnection)
Create a new ReplicationService with given RepositoryConnection

Method Summary

java.lang.Long

replicate(java.util.Set<ITracker> trackers, java.util.Set<ITracker> newTrackers, java.lang.Long marker, java.lang.Long userId, IRepositoryHandler handler) Determine delta changes between marker and last transaction committed on server

Methods inherited from class java.lang.Object

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

Constructor Detail

ReplicationService

public ReplicationService(RepositoryConnection repositoryConnection)

Create a new ReplicationService with given RepositoryConnection

Parameters:

repositoryConnection -

Method Detail

replicate

public java.lang.Long replicate(java.util.Set<ITracker> trackers,
                                java.util.Set<ITracker> newTrackers,
                                java.lang.Long marker,
                                java.lang.Long userId,
                                IRepositoryHandler handler)
                         throws AnzoException

Determine delta changes between marker and last transaction committed on server

Parameters:

trackers - Trackers that have already been replicated

newTrackers - New trackers that haven't been replicated yet

marker - Timestamp when replication was last run

userId - Userid of user replicating

handler - Handler to which changes are written

Returns:

the timestamp of the last replication time

Throws:

AnzoException