salto.batch.appender
Interface IBatchAppender

All Superinterfaces:

java.io.Serializable

All Known Subinterfaces:

IJdbcAppender

All Known Implementing Classes:

FileAppender, JdbcAppender, JdbcErrorAppender, MemoryAppender

public interface IBatchAppender
extends java.io.Serializable

Interface permettant d'assurer la persistence des batchs en cours de traitement La persistence en cours de traitement permet la reprise sur incident. Cette interface doit donc etre averti des evenements suivants :

• mise en file d'attente d'un traitement (existence)
• demarrage d'un traitement
• fin d'un traitement avec un resultat OK
• fin d'un traitement avec un traitement KO

Chaque batch peut gerer lui-meme le traitement des resultats (OK / KO). Cette interface permet de gerer uniquement les resulats KO lorsque ceux ci sont remontes au niveau du batch (interception des exceptions)

Author:

Etienne Loiez, Philippe Mouawad

Method Summary

void	batchEnded(java.lang.String batchName, java.util.Date endDate, int nbLinesRead, int nbErrors, java.lang.Throwable t) Deprecated.
void	batchEnded(java.lang.String batchName, java.util.Date endDate, LanceurExecutionStatusEnum executionStatusEnum, int nbLinesRead, int nbErrors, java.lang.Throwable t) fin d'un batch
DoBatchTrt[]	batchResumed(java.lang.String batchName, long batchId) Fonction permettant de recuperer les donnees d'un traitement
java.lang.Long	batchStarted(java.lang.String batchName, java.util.Date startDate) demarrage d'un batch
java.lang.Object	clone() Les appenders doivent etre thread-safe.
IBatchAppender	copy()
void	trtAdded(java.lang.Object datas, java.lang.Object ids) Ajout d'un traitement unitaire dans la file des traitements
void	trtEnded(long numJob, java.lang.Object data, java.lang.Object ids, long endDate, java.lang.Throwable fail) Fin d'un traitement unitaire
void	trtStarted(long numJob, java.lang.Object data, java.lang.Object ids, long startDate) Demarage d'un traitement unitaire
void	validate()

Method Detail

batchStarted

java.lang.Long batchStarted(java.lang.String batchName,
                            java.util.Date startDate)

demarrage d'un batch

Parameters:

batchName - nom unique du batch (suit la nomenclature RMI)

startDate - date de debut du batch

Returns:

Long batch Id

batchEnded

void batchEnded(java.lang.String batchName,
                java.util.Date endDate,
                int nbLinesRead,
                int nbErrors,
                java.lang.Throwable t)

Deprecated.

fin d'un batch

Parameters:

batchName - nom unique du batch (suit la nomenclature RMI)

endDate - date & heure de fin du batch

nbLinesRead - Number of lines read

nbErrors - Number of errors

t - Throwable

batchEnded

void batchEnded(java.lang.String batchName,
                java.util.Date endDate,
                LanceurExecutionStatusEnum executionStatusEnum,
                int nbLinesRead,
                int nbErrors,
                java.lang.Throwable t)

fin d'un batch

Parameters:

batchName - nom unique du batch (suit la nomenclature RMI)

endDate - date & heure de fin du batch

executionStatusEnum -

nbLinesRead - Number of lines read

nbErrors - Number of errors

t - Throwable

trtAdded

void trtAdded(java.lang.Object datas,
              java.lang.Object ids)

Ajout d'un traitement unitaire dans la file des traitements

Parameters:

datas - Object donnees permettant d'assurer l'unicite du traitement

ids - Object IDs

trtStarted

void trtStarted(long numJob,
                java.lang.Object data,
                java.lang.Object ids,
                long startDate)

Demarage d'un traitement unitaire

Parameters:

numJob - long Job id

batchName - nom unique du batch (suit la nomenclature RMI)

data - donnees permettant d'assurer l'unicite du traitement

ids - Object

startDate - date de depart (em ms.)

trtEnded

void trtEnded(long numJob,
              java.lang.Object data,
              java.lang.Object ids,
              long endDate,
              java.lang.Throwable fail)

Fin d'un traitement unitaire

Parameters:

numJob - Job ID

batchName - nom unique du batch (suit la nomenclature RMI)

data - donnees permettant d'assurer l'unicite du traitement

ids - Object ID

endDate - date & heure de fin du traitement (em ms.)

fail - boolean permettant de connaitre le resultat de fin du batch (false = fin OK, true : KO)

batchResumed

DoBatchTrt[] batchResumed(java.lang.String batchName,
                          long batchId)
                          throws BatchException

Fonction permettant de recuperer les donnees d'un traitement

Parameters:

batchName - String Full batch name

batchId - long Batch ID

Returns:

DoBatchTrt[]

Throws:

BatchException

clone

java.lang.Object clone()
                       throws java.lang.CloneNotSupportedException

Les appenders doivent etre thread-safe. Dans le cas des appenders utilisant des API non thread-safe, cas des drivers JDBC, il faut pouvoir cloner les appenders afin d'eviter les problemes lies aux acces concurrents.

Throws:

java.lang.CloneNotSupportedException

copy

IBatchAppender copy()

Returns:

IBatchAppender

validate

void validate()