com.raritantechnologies.searchApp.dataCollection
Class CollectionBuilder

java.lang.Object
  extended bycom.raritantechnologies.searchApp.dataCollection.CollectionBuilder
All Implemented Interfaces:
ICollectionBuilder, IGatewayListener

public class CollectionBuilder
extends java.lang.Object
implements ICollectionBuilder, IGatewayListener

Central dispatcher for data collection and processing builds. Uses an ICollectionGateway to collect data for indexing (in form of IResultSet ).

Dispatches data to IGatewayOutputProcessor to process the IResultSet(s) and build the collections, style files, parametric indexes or other outputs.

Constructed from XML configuration file by XMLCollectionBuilderFactory.


Developed by Raritan Technologies .

Author:
Ted Sullivan

Field Summary
 
Fields inherited from interface com.raritantechnologies.searchApp.dataCollection.ICollectionBuilder
COMPLETED, FAILED, NOT_STARTED, PAUSED, STARTED
 
Constructor Summary
CollectionBuilder()
           
CollectionBuilder(ICollectionGateway gateway, IGatewayOutputProcessor gatewayProc)
           
 
Method Summary
 void addGatewayListener(IGatewayListener gatewayListener)
           
 void createCollection(java.lang.String[] args)
           
 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)
           
 int getBuildStatus()
           
 ICollectionGateway getCollectionGateway()
           
 TimeIntervalStatistics getGatewayIntervals()
           
 IGatewayOutputProcessor getGatewayOutputProcessor()
           
 TimeIntervalStatistics getProcessorIntervals()
           
static void main(java.lang.String[] args)
           
 void processData(IResultSet dataSet)
          processData method is part of the IGatewayListener interface.
 void setCollectionGateway(ICollectionGateway collGateway)
           
 void setGatewayProcessor(IGatewayOutputProcessor gatewayProc)
           
 void setLicenseFile(java.lang.String licenseFile)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

CollectionBuilder

public CollectionBuilder()

CollectionBuilder

public CollectionBuilder(ICollectionGateway gateway,
                         IGatewayOutputProcessor gatewayProc)
Method Detail

setCollectionGateway

public void setCollectionGateway(ICollectionGateway collGateway)

getCollectionGateway

public ICollectionGateway getCollectionGateway()
Specified by:
getCollectionGateway in interface ICollectionBuilder

setLicenseFile

public void setLicenseFile(java.lang.String licenseFile)

setGatewayProcessor

public void setGatewayProcessor(IGatewayOutputProcessor gatewayProc)

getGatewayOutputProcessor

public IGatewayOutputProcessor getGatewayOutputProcessor()
Specified by:
getGatewayOutputProcessor in interface ICollectionBuilder

createCollection

public void createCollection(java.lang.String[] args)
Specified by:
createCollection in interface ICollectionBuilder

processData

public void processData(IResultSet dataSet)
processData method is part of the IGatewayListener interface. called by the ICollectionGateway

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

addGatewayListener

public void addGatewayListener(IGatewayListener gatewayListener)
Specified by:
addGatewayListener in interface ICollectionBuilder

getBuildStatus

public int getBuildStatus()
Specified by:
getBuildStatus in interface ICollectionBuilder

getGatewayIntervals

public TimeIntervalStatistics getGatewayIntervals()

getProcessorIntervals

public TimeIntervalStatistics getProcessorIntervals()

main

public static void main(java.lang.String[] args)