com.northconcepts.datapipeline.job

Class AbstractJobCallback<R extends DataReader,W extends DataWriter>

java.lang.Object

com.northconcepts.datapipeline.job.AbstractJobCallback<R,W>

All Implemented Interfaces:

JobCallback<R,W>

Direct Known Subclasses:

DefaultJobCallback

public abstract class AbstractJobCallback<R extends DataReader,W extends DataWriter>
extends Object
implements JobCallback<R,W>

A default, abstract implementation of JobCallback.

Nested Class Summary

Nested classes/interfaces inherited from interface com.northconcepts.datapipeline.job.JobCallback

JobCallback.Helper

Field Summary

Fields inherited from interface com.northconcepts.datapipeline.job.JobCallback

NULL

Constructor Summary

Constructors

Constructor and Description
AbstractJobCallback()

Method Summary

Modifier and Type	Method and Description
void	onFailure(R reader, W writer, Record currentRecord, Throwable exception)
void	onProgress(R reader, W writer, Record currentRecord)
void	onSuccess(R reader, W writer)

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractJobCallback

public AbstractJobCallback()

Method Detail

onProgress

public void onProgress(R reader,
                       W writer,
                       Record currentRecord)
                throws Throwable

Specified by:

onProgress in interface JobCallback<R extends DataReader,W extends DataWriter>

Throws:

Throwable

onSuccess

public void onSuccess(R reader,
                      W writer)
               throws Throwable

Specified by:

onSuccess in interface JobCallback<R extends DataReader,W extends DataWriter>

Throws:

Throwable

onFailure

public void onFailure(R reader,
                      W writer,
                      Record currentRecord,
                      Throwable exception)
               throws Throwable

Specified by:

onFailure in interface JobCallback<R extends DataReader,W extends DataWriter>

Throws:

Throwable