com.atomikos.recovery.fs

Class InMemoryRepository

java.lang.Object

com.atomikos.recovery.fs.InMemoryRepository

All Implemented Interfaces:

Repository

public class InMemoryRepository
extends java.lang.Object
implements Repository

Constructor Summary

Constructors

Constructor and Description
InMemoryRepository()

Method Summary

Modifier and Type	Method and Description
void	close()
java.util.Collection<PendingTransactionRecord>	findAllCommittingCoordinatorLogEntries()
PendingTransactionRecord	get(java.lang.String coordinatorId)
java.util.Collection<PendingTransactionRecord>	getAllCoordinatorLogEntries()
void	init()
boolean	isClosed()
void	put(java.lang.String id, PendingTransactionRecord coordinatorLogEntry)
void	writeCheckpoint(java.util.Collection<PendingTransactionRecord> checkpointContent)

Methods inherited from class java.lang.Object

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

Constructor Detail

InMemoryRepository

public InMemoryRepository()

Method Detail

init

public void init()

Specified by:

init in interface Repository

put

public void put(java.lang.String id,
                PendingTransactionRecord coordinatorLogEntry)
         throws java.lang.IllegalArgumentException

Specified by:

put in interface Repository

Throws:

java.lang.IllegalArgumentException

get

public PendingTransactionRecord get(java.lang.String coordinatorId)

Specified by:

get in interface Repository

findAllCommittingCoordinatorLogEntries

public java.util.Collection<PendingTransactionRecord> findAllCommittingCoordinatorLogEntries()

Specified by:

findAllCommittingCoordinatorLogEntries in interface Repository

close

public void close()

Specified by:

close in interface Repository

getAllCoordinatorLogEntries

public java.util.Collection<PendingTransactionRecord> getAllCoordinatorLogEntries()

Specified by:

getAllCoordinatorLogEntries in interface Repository

writeCheckpoint

public void writeCheckpoint(java.util.Collection<PendingTransactionRecord> checkpointContent)

Specified by:

writeCheckpoint in interface Repository

isClosed

public boolean isClosed()