com.atomikos.logcloud.recovery

Class JDBCRecoveryLog

java.lang.Object

com.atomikos.logcloud.recovery.JDBCRecoveryLog

All Implemented Interfaces:

OltpLog, RecoveryLog, RemotingRecoveryLog

public class JDBCRecoveryLog
extends Object
implements RemotingRecoveryLog, OltpLog

LICENSED TO CUSTOMERS OF A COMMERCIAL SUBSCRIPTION ONLY!

Constructor Summary

Constructors

Constructor and Description
JDBCRecoveryLog(DataSource ds)

Method Summary

Modifier and Type	Method and Description
void	close()
void	closed()
void	closing()
boolean	containsRecordsForDomain(String recoveryDomainName)
void	forget(String coordinatorId)
void	forgetRemoteParticipantLogEntry(RemoteParticipantLogEntry participant)
void	forgetTransactionRecords(Collection<PendingTransactionRecord> coordinators)
PendingTransactionRecord	get(String coordinatorId)
Collection<PendingTransactionRecord>	getExpiredPendingCommittingTransactionRecordsAt(long time)
Collection<PendingTransactionRecord>	getIndoubtTransactionRecords()
Collection<PendingTransactionRecord>	getPendingTransactionRecords()
Collection<RemoteParticipantLogEntry>	getRemoteParticipantLogEntries()
void	init()
boolean	isActive()
void	recordAsCommitting(String coordinatorId)
void	write(PendingTransactionRecord record)

Methods inherited from class java.lang.Object

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

Constructor Detail

JDBCRecoveryLog

public JDBCRecoveryLog(DataSource ds)

Method Detail

init

public void init()

getExpiredPendingCommittingTransactionRecordsAt

public Collection<PendingTransactionRecord> getExpiredPendingCommittingTransactionRecordsAt(long time)
                                                                                     throws LogReadException

Specified by:

getExpiredPendingCommittingTransactionRecordsAt in interface RecoveryLog

Throws:

LogReadException

getIndoubtTransactionRecords

public Collection<PendingTransactionRecord> getIndoubtTransactionRecords()
                                                                  throws LogReadException

Specified by:

getIndoubtTransactionRecords in interface RecoveryLog

Throws:

LogReadException

isActive

public boolean isActive()

Specified by:

isActive in interface RecoveryLog

forgetTransactionRecords

public void forgetTransactionRecords(Collection<PendingTransactionRecord> coordinators)

Specified by:

forgetTransactionRecords in interface RecoveryLog

recordAsCommitting

public void recordAsCommitting(String coordinatorId)
                        throws LogException

Specified by:

recordAsCommitting in interface RecoveryLog

Throws:

LogException

forget

public void forget(String coordinatorId)

Specified by:

forget in interface RecoveryLog

get

public PendingTransactionRecord get(String coordinatorId)
                             throws LogReadException

Specified by:

get in interface RecoveryLog

Throws:

LogReadException

write

public void write(PendingTransactionRecord record)
           throws LogWriteException

Specified by:

write in interface OltpLog

Throws:

LogWriteException

closing

public void closing()

Specified by:

closing in interface RecoveryLog

closed

public void closed()

Specified by:

closed in interface RecoveryLog

close

public void close()

Specified by:

close in interface OltpLog

getPendingTransactionRecords

public Collection<PendingTransactionRecord> getPendingTransactionRecords()
                                                                  throws LogReadException

Specified by:

getPendingTransactionRecords in interface RecoveryLog

Throws:

LogReadException

getRemoteParticipantLogEntries

public Collection<RemoteParticipantLogEntry> getRemoteParticipantLogEntries()
                                                                     throws LogReadException

Specified by:

getRemoteParticipantLogEntries in interface RemotingRecoveryLog

Throws:

LogReadException

forgetRemoteParticipantLogEntry

public void forgetRemoteParticipantLogEntry(RemoteParticipantLogEntry participant)

Specified by:

forgetRemoteParticipantLogEntry in interface RemotingRecoveryLog

containsRecordsForDomain

public boolean containsRecordsForDomain(String recoveryDomainName)

Specified by:

containsRecordsForDomain in interface RemotingRecoveryLog