ca.bc.gov.open.cpf.api.web.controller

Class AbstractJobController

java.lang.Object

ca.bc.gov.open.cpf.api.web.controller.AbstractJobController

All Implemented Interfaces:

JobController

Direct Known Subclasses:

DatabaseJobController, FileJobController

public abstract class AbstractJobController
extends Object
implements JobController

Field Summary

Fields inherited from interface ca.bc.gov.open.cpf.api.web.controller.JobController

GROUP_ERRORS, GROUP_INPUTS, GROUP_RESULTS, JOB_INPUTS, JOB_RESULTS

Constructor Summary

Constructors

Constructor and Description
AbstractJobController(CpfDataAccessObject dataAccessObject)

Method Summary

Modifier and Type	Method and Description
CpfDataAccessObject	getDataAccessObject()
protected abstract String	getFileContentType(com.revolsys.identifier.Identifier jobId, String path, int sequenceNumber)
protected abstract long	getFileSize(com.revolsys.identifier.Identifier jobId, String path, int sequenceNumber)
protected abstract InputStream	getFileStream(com.revolsys.identifier.Identifier jobId, String path, int sequenceNumber)
protected abstract InputStream	getFileStream(com.revolsys.identifier.Identifier jobId, String path, int sequenceNumber, long fromIndex, long toIndex)
com.revolsys.io.map.MapReader	getGroupErrorReader(com.revolsys.identifier.Identifier jobId, int sequenceNumber)
String	getGroupInputContentType(com.revolsys.identifier.Identifier batchJobId, int sequenceNumber)
InputStream	getGroupInputStream(com.revolsys.identifier.Identifier jobId, int sequenceNumber)
String	getGroupInputString(com.revolsys.identifier.Identifier jobId, int sequenceNumber)
com.revolsys.io.map.MapReader	getGroupResultReader(com.revolsys.identifier.Identifier jobId, int sequenceNumber)
InputStream	getGroupResultStream(com.revolsys.identifier.Identifier jobId, int sequenceNumber)
InputStream	getJobInputStream(com.revolsys.identifier.Identifier jobId)
long	getJobResultSize(com.revolsys.identifier.Identifier jobId, int sequenceNumber)
InputStream	getJobResultStream(com.revolsys.identifier.Identifier jobId, int sequenceNumber)
InputStream	getJobResultStream(com.revolsys.identifier.Identifier jobId, int sequenceNumber, long fromIndex, long toIndex)
void	newJobInputFile(com.revolsys.identifier.Identifier jobId, String contentType, Object data)
void	setGroupError(com.revolsys.identifier.Identifier jobId, int sequenceNumber, Object data)
void	setGroupInput(com.revolsys.identifier.Identifier jobId, int sequenceNumber, String contentType, Object data)
void	setGroupResult(com.revolsys.identifier.Identifier jobId, int sequenceNumber, InputStream in)
void	setJobResult(com.revolsys.identifier.Identifier jobId, int sequenceNumber, String contentType, Object data)
void	writeFile(javax.servlet.http.HttpServletResponse response, com.revolsys.identifier.Identifier jobId, String path, int sequenceNumber)

Methods inherited from class java.lang.Object

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

Methods inherited from interface ca.bc.gov.open.cpf.api.web.controller.JobController

cancelJob, deleteJob, getFiles, getKey, newJobFile, newPreProcessGroup, writeGroupInput

Constructor Detail

AbstractJobController

public AbstractJobController(CpfDataAccessObject dataAccessObject)

Method Detail

getDataAccessObject

public CpfDataAccessObject getDataAccessObject()

Specified by:

getDataAccessObject in interface JobController

getFileContentType

protected abstract String getFileContentType(com.revolsys.identifier.Identifier jobId,
                                             String path,
                                             int sequenceNumber)

getFileSize

protected abstract long getFileSize(com.revolsys.identifier.Identifier jobId,
                                    String path,
                                    int sequenceNumber)

getFileStream

protected abstract InputStream getFileStream(com.revolsys.identifier.Identifier jobId,
                                             String path,
                                             int sequenceNumber)

getFileStream

protected abstract InputStream getFileStream(com.revolsys.identifier.Identifier jobId,
                                             String path,
                                             int sequenceNumber,
                                             long fromIndex,
                                             long toIndex)

getGroupErrorReader

public com.revolsys.io.map.MapReader getGroupErrorReader(com.revolsys.identifier.Identifier jobId,
                                                         int sequenceNumber)

Specified by:

getGroupErrorReader in interface JobController

getGroupInputContentType

public String getGroupInputContentType(com.revolsys.identifier.Identifier batchJobId,
                                       int sequenceNumber)

Specified by:

getGroupInputContentType in interface JobController

getGroupInputStream

public InputStream getGroupInputStream(com.revolsys.identifier.Identifier jobId,
                                       int sequenceNumber)

Specified by:

getGroupInputStream in interface JobController

getGroupInputString

public String getGroupInputString(com.revolsys.identifier.Identifier jobId,
                                  int sequenceNumber)

Specified by:

getGroupInputString in interface JobController

getGroupResultReader

public com.revolsys.io.map.MapReader getGroupResultReader(com.revolsys.identifier.Identifier jobId,
                                                          int sequenceNumber)

Specified by:

getGroupResultReader in interface JobController

getGroupResultStream

public InputStream getGroupResultStream(com.revolsys.identifier.Identifier jobId,
                                        int sequenceNumber)

Specified by:

getGroupResultStream in interface JobController

getJobInputStream

public InputStream getJobInputStream(com.revolsys.identifier.Identifier jobId)

Specified by:

getJobInputStream in interface JobController

getJobResultSize

public long getJobResultSize(com.revolsys.identifier.Identifier jobId,
                             int sequenceNumber)

Specified by:

getJobResultSize in interface JobController

getJobResultStream

public InputStream getJobResultStream(com.revolsys.identifier.Identifier jobId,
                                      int sequenceNumber)

Specified by:

getJobResultStream in interface JobController

getJobResultStream

public InputStream getJobResultStream(com.revolsys.identifier.Identifier jobId,
                                      int sequenceNumber,
                                      long fromIndex,
                                      long toIndex)

Specified by:

getJobResultStream in interface JobController

newJobInputFile

public void newJobInputFile(com.revolsys.identifier.Identifier jobId,
                            String contentType,
                            Object data)

Specified by:

newJobInputFile in interface JobController

setGroupError

public void setGroupError(com.revolsys.identifier.Identifier jobId,
                          int sequenceNumber,
                          Object data)

Specified by:

setGroupError in interface JobController

setGroupInput

public void setGroupInput(com.revolsys.identifier.Identifier jobId,
                          int sequenceNumber,
                          String contentType,
                          Object data)

Specified by:

setGroupInput in interface JobController

setGroupResult

public void setGroupResult(com.revolsys.identifier.Identifier jobId,
                           int sequenceNumber,
                           InputStream in)

Specified by:

setGroupResult in interface JobController

setJobResult

public void setJobResult(com.revolsys.identifier.Identifier jobId,
                         int sequenceNumber,
                         String contentType,
                         Object data)

Specified by:

setJobResult in interface JobController

writeFile

public void writeFile(javax.servlet.http.HttpServletResponse response,
                      com.revolsys.identifier.Identifier jobId,
                      String path,
                      int sequenceNumber)
               throws IOException

Specified by:

writeFile in interface JobController

Throws:

IOException