Package nablarch.integration.doma.batch.ee.listener

Class DomaTransactionItemWriteListener

java.lang.Object

nablarch.fw.batch.ee.listener.chunk.AbstractNablarchItemWriteListener

nablarch.integration.doma.batch.ee.listener.DomaTransactionItemWriteListener

All Implemented Interfaces:

NablarchItemWriteListener

public class DomaTransactionItemWriteListener
extends AbstractNablarchItemWriteListener

ItemWriteListenerレベルでDomaのトランザクション制御を行うNablarchItemWriteListenerの実装クラス。

前段に配置したDomaTransactionStepListenerからDomaのLocalTransactionを取得し、トランザクション制御を行う。

ItemWriterが正常に終了した場合には、トランザクションの確定(LocalTransaction.commit())を実行し、 その後にLocalTransactionを開始(LocalTransaction.begin())する。
ItemWriterでExceptionが発生した場合には、トランザクションの破棄(LocalTransaction.rollback()を行う。

Constructor Summary

Constructors

Constructor	Description
DomaTransactionItemWriteListener()

Method Summary

Modifier and Type	Method	Description
void	afterWrite(NablarchListenerContext context, List<Object> items)	ItemWriter.writeItems(List)の実行後の処理を行う。
void	onWriteError(NablarchListenerContext context, List<Object> items, Exception ex)	ItemWriter.writeItems(List)でExceptionが発生した場合の処理を行う。
void	setConnectionFactory(ConnectionFactoryFromDomaConnection connectionFactory)	コネクションファクトリを設定する。

Methods inherited from class nablarch.fw.batch.ee.listener.chunk.AbstractNablarchItemWriteListener

beforeWrite

Methods inherited from class java.lang.Object

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

Constructor Details

DomaTransactionItemWriteListener

public DomaTransactionItemWriteListener()

Method Details

afterWrite

public void afterWrite(NablarchListenerContext context,
 List<Object> items)

Description copied from interface: NablarchItemWriteListener

ItemWriter.writeItems(List)の実行後の処理を行う。

Specified by:

afterWrite in interface NablarchItemWriteListener

Overrides:

afterWrite in class AbstractNablarchItemWriteListener

Parameters:

context - NablarchListenerContext

items - 書き込み対象のオブジェクト

onWriteError

public void onWriteError(NablarchListenerContext context,
 List<Object> items,
 Exception ex)

Description copied from interface: NablarchItemWriteListener

ItemWriter.writeItems(List)でExceptionが発生した場合の処理を行う。

本メソッドは、Java Batch(JSR352)の仕様により、Error系が発生した場合はコールバックされない。

Specified by:

onWriteError in interface NablarchItemWriteListener

Overrides:

onWriteError in class AbstractNablarchItemWriteListener

Parameters:

context - NablarchListenerContext

items - 書き込み対象のオブジェクト

ex - 発生したException

setConnectionFactory

public void setConnectionFactory(ConnectionFactoryFromDomaConnection connectionFactory)

コネクションファクトリを設定する。

Parameters:

connectionFactory - コネクションファクトリ