com.toolsverse.etl.core.connection

Class DefaultTransactionMonitor

Object

com.toolsverse.etl.core.connection.DefaultTransactionMonitor

All Implemented Interfaces:

TransactionMonitor

public class DefaultTransactionMonitor
extends Object
implements TransactionMonitor

The default implementation of the TransactionMonitor interface.

Since:

1.0

Version:

2.0

Constructor Summary

Constructors

Constructor and Description
DefaultTransactionMonitor() Instantiates a new default transaction monitor.
DefaultTransactionMonitor(EtlConnectionFactory connectionFactory) Instantiates a new default transaction monitor.

Method Summary

Modifier and Type	Method and Description
boolean	addConnection(Connection conn) Adds the connection.
boolean	addFile(String name) Adds the file.
void	commit() Commits transaction.
boolean	isTrackFiles() Checks if is track files flag is set.
void	rollback(Exception ex) Rollbacks transaction.
void	setConnectionFactory(EtlConnectionFactory connectionFactory) Sets the connection factory.
void	setTrackFiles(boolean trackFiles) Sets the track files flag.

Methods inherited from class Object

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

Constructor Detail

DefaultTransactionMonitor

public DefaultTransactionMonitor()

Instantiates a new default transaction monitor.

DefaultTransactionMonitor

public DefaultTransactionMonitor(EtlConnectionFactory connectionFactory)

Instantiates a new default transaction monitor.

Parameters:

connectionFactory - the connection factory

Method Detail

addConnection

public boolean addConnection(Connection conn)

Description copied from interface: TransactionMonitor

Adds the connection.

Specified by:

addConnection in interface TransactionMonitor

Parameters:

conn - the connection

Returns:

true, if successful

addFile

public boolean addFile(String name)

Description copied from interface: TransactionMonitor

Adds the file.

Specified by:

addFile in interface TransactionMonitor

Parameters:

name - the file name

Returns:

true, if successful

commit

public void commit()
            throws Exception

Description copied from interface: TransactionMonitor

Commits transaction.

Specified by:

commit in interface TransactionMonitor

Throws:

Exception - in case of any error

rollback

public void rollback(Exception ex)
              throws Exception

Description copied from interface: TransactionMonitor

Rollbacks transaction.

Specified by:

rollback in interface TransactionMonitor

Parameters:

ex - the exception

Throws:

Exception - in case of any error

setConnectionFactory

public void setConnectionFactory(EtlConnectionFactory connectionFactory)

Description copied from interface: TransactionMonitor

Sets the connection factory.

Specified by:

setConnectionFactory in interface TransactionMonitor

Parameters:

connectionFactory - the new connection factory

isTrackFiles

public boolean isTrackFiles()

Description copied from interface: TransactionMonitor

Checks if is track files flag is set.

Specified by:

isTrackFiles in interface TransactionMonitor

Returns:

true, if is track files flag is set

setTrackFiles

public void setTrackFiles(boolean trackFiles)

Description copied from interface: TransactionMonitor

Sets the track files flag.

Specified by:

setTrackFiles in interface TransactionMonitor

Parameters:

trackFiles - the new value of the track files flag