nl.nn.adapterframework.jta.btm

Class BtmDiskJournal

java.lang.Object

bitronix.tm.journal.DiskJournal

nl.nn.adapterframework.jta.btm.BtmDiskJournal

All Implemented Interfaces:

bitronix.tm.journal.Journal, bitronix.tm.journal.MigratableJournal, bitronix.tm.journal.ReadableJournal, bitronix.tm.utils.Service

public class BtmDiskJournal
extends bitronix.tm.journal.DiskJournal

This class exists to ensure the DiskJournal is accessible when updating the TransactionLog Since it's not possible to change the current transaction, the most we can do is attempt to retry the log/force actions and hope we don't break the tx-log even further.

Author:

Niels Meijer

See Also:

IbisSource issue, BTM issue

Constructor Summary

Constructors

Constructor and Description
BtmDiskJournal()

Method Summary

Modifier and Type	Method and Description
Map<bitronix.tm.utils.Uid,bitronix.tm.journal.JournalRecord>	collectDanglingRecords()
void	force()
void	log(int status, bitronix.tm.utils.Uid gtrid, Set<String> uniqueNames)

Methods inherited from class bitronix.tm.journal.DiskJournal

close, migrateTo, open, shutdown, unsafeReadRecordsInto

Methods inherited from class java.lang.Object

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

Constructor Detail

BtmDiskJournal

public BtmDiskJournal()

Method Detail

log

public void log(int status,
                bitronix.tm.utils.Uid gtrid,
                Set<String> uniqueNames)
         throws IOException

Specified by:

log in interface bitronix.tm.journal.Journal

Overrides:

log in class bitronix.tm.journal.DiskJournal

Throws:

IOException

force

public void force()
           throws IOException

Specified by:

force in interface bitronix.tm.journal.Journal

Overrides:

force in class bitronix.tm.journal.DiskJournal

Throws:

IOException

collectDanglingRecords

public Map<bitronix.tm.utils.Uid,bitronix.tm.journal.JournalRecord> collectDanglingRecords()
                                                                                    throws IOException

Specified by:

collectDanglingRecords in interface bitronix.tm.journal.Journal

Overrides:

collectDanglingRecords in class bitronix.tm.journal.DiskJournal

Throws:

IOException