com.raritantechnologies.google.connector
Class RTIDocumentList

java.lang.Object
  com.raritantechnologies.google.connector.RTIDocumentList

All Implemented Interfaces:

IGatewayListener

public class RTIDocumentList

extends java.lang.Object

implements IGatewayListener

Constructor Summary

RTIDocumentList(ICollectionGateway collGateway)

Method Summary

java.lang.String	checkpoint()
void	dataComplete(java.lang.Object gateway) Message sent by ICollectionGateway after the last IResultSet has been submitted for processing.
void	gatewayFailed(java.lang.String message)
Document	nextDocument()
void	processData(IResultSet resultSet) Command to process a set of results generated by an ICollectionGateway implementation.
void	resumeAt(java.lang.String checkPoint)
void	setBatchSize(int batchSize)
void	startGateway()

Methods inherited from class java.lang.Object

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

Constructor Detail

RTIDocumentList

public RTIDocumentList(ICollectionGateway collGateway)

Method Detail

startGateway

public void startGateway()

resumeAt

public void resumeAt(java.lang.String checkPoint)

setBatchSize

public void setBatchSize(int batchSize)

nextDocument

public Document nextDocument()
                      throws RepositoryException

Throws:

RepositoryException

checkpoint

public java.lang.String checkpoint()
                            throws RepositoryException

Throws:

RepositoryException

processData

public void processData(IResultSet resultSet)

Description copied from interface: IGatewayListener

Command to process a set of results generated by an ICollectionGateway implementation.

Specified by:

processData in interface IGatewayListener

dataComplete

public void dataComplete(java.lang.Object gateway)

Description copied from interface: IGatewayListener

Message sent by ICollectionGateway after the last IResultSet has been submitted for processing.

Specified by:

dataComplete in interface IGatewayListener

gatewayFailed

public void gatewayFailed(java.lang.String message)

Specified by:

gatewayFailed in interface IGatewayListener