org.openanzo.services.impl
Class WSReplicationService

java.lang.Object
  org.openanzo.services.impl.WSBaseService
      org.openanzo.services.impl.WSReplicationService

All Implemented Interfaces:

IReplicationService, IService

public class WSReplicationService
extends WSBaseService
implements IReplicationService

Implementation of the IReplicationService that talks over WebService/Soap to a remote Anzo Server.

Author:

Matthew Roy ( mroy@cambridgesemantics.com )

Field Summary

Fields inherited from interface org.openanzo.services.IReplicationService

REPLICATION_AUTOMATIC, REPLICATION_IMMEDIATE_ASYNC, REPLICATION_IMMEDIATE_SYNC, REPLICATION_MANUAL

Constructor Summary

WSReplicationService(java.util.Properties properties)
Create new WSReplicationService with configuration properties provided in Properties object

WSReplicationService(java.lang.String serviceHostName, int servicePort, java.lang.String serviceUser, java.lang.String servicePassword, int serviceTimeout)
Create new WSReplicationService with given configuration properties

Method Summary

java.lang.Long

execReplicate(java.lang.Long markerIn, java.util.Set<ITracker> statementTrackers, java.util.Set<ITracker> newStatementTrackers, IRepositoryHandler handler) Replicate with the Anzo server

Methods inherited from class org.openanzo.services.impl.WSBaseService

getServiceHostName, getServicePassword, getServicePort, getServiceUser, setServiceHostName, setServicePassword, setServicePort, setServiceUser

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.openanzo.services.IService

getServicePassword, getServiceUser, setServicePassword, setServiceUser

Constructor Detail

WSReplicationService

public WSReplicationService(java.lang.String serviceHostName,
                            int servicePort,
                            java.lang.String serviceUser,
                            java.lang.String servicePassword,
                            int serviceTimeout)

Create new WSReplicationService with given configuration properties

Parameters:

serviceHostName - Hostname for Anzo server

servicePort - Port for Anzo server

serviceUser - Username for Anzo server

servicePassword - Password for Anzo server

serviceTimeout - Number of milliseconds to wait before timeing out call to server

WSReplicationService

public WSReplicationService(java.util.Properties properties)

Create new WSReplicationService with configuration properties provided in Properties object

Parameters:

properties - Configuration properties

Method Detail

execReplicate

public java.lang.Long execReplicate(java.lang.Long markerIn,
                                    java.util.Set<ITracker> statementTrackers,
                                    java.util.Set<ITracker> newStatementTrackers,
                                    IRepositoryHandler handler)
                             throws AnzoException

Description copied from interface: IReplicationService

Replicate with the Anzo server

Specified by:

execReplicate in interface IReplicationService

Parameters:

markerIn - Timestamp of last replication

statementTrackers - Set of already replicated notification trackers

newStatementTrackers - Set of new notification trackers

handler - 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