org.hornetq.core.transaction.impl

Class ResourceManagerImpl

java.lang.Object

org.hornetq.core.transaction.impl.ResourceManagerImpl

All Implemented Interfaces:

HornetQComponent, ResourceManager

public class ResourceManagerImpl
extends Object
implements ResourceManager, HornetQComponent

A ResourceManagerImpl

Author:

Tim Fox

Constructor Summary

Constructors

Constructor and Description
ResourceManagerImpl(int defaultTimeoutSeconds, long txTimeoutScanPeriod, ScheduledExecutorService scheduledThreadPool)

Method Summary

Methods

Modifier and Type	Method and Description
List<Xid>	getHeuristicCommittedTransactions()
List<Xid>	getHeuristicRolledbackTransactions()
List<Xid>	getPreparedTransactions()
Map<Xid,Long>	getPreparedTransactionsWithCreationTime()
int	getTimeoutSeconds()
Transaction	getTransaction(Xid xid)
boolean	isStarted()
void	putHeuristicCompletion(long recordID, Xid xid, boolean isCommit)
boolean	putTransaction(Xid xid, Transaction tx)
long	removeHeuristicCompletion(Xid xid)
Transaction	removeTransaction(Xid xid)
void	start()
void	stop()

Methods inherited from class java.lang.Object

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

Constructor Detail

ResourceManagerImpl

public ResourceManagerImpl(int defaultTimeoutSeconds,
                   long txTimeoutScanPeriod,
                   ScheduledExecutorService scheduledThreadPool)

Method Detail

start

public void start()
           throws Exception

Specified by:

start in interface HornetQComponent

Throws:

Exception

stop

public void stop()
          throws Exception

Specified by:

stop in interface HornetQComponent

Throws:

Exception

isStarted

public boolean isStarted()

Specified by:

isStarted in interface HornetQComponent

getTransaction

public Transaction getTransaction(Xid xid)

Specified by:

getTransaction in interface ResourceManager

putTransaction

public boolean putTransaction(Xid xid,
                     Transaction tx)

Specified by:

putTransaction in interface ResourceManager

removeTransaction

public Transaction removeTransaction(Xid xid)

Specified by:

removeTransaction in interface ResourceManager

getTimeoutSeconds

public int getTimeoutSeconds()

Specified by:

getTimeoutSeconds in interface ResourceManager

getPreparedTransactions

public List<Xid> getPreparedTransactions()

Specified by:

getPreparedTransactions in interface ResourceManager

getPreparedTransactionsWithCreationTime

public Map<Xid,Long> getPreparedTransactionsWithCreationTime()

Specified by:

getPreparedTransactionsWithCreationTime in interface ResourceManager

putHeuristicCompletion

public void putHeuristicCompletion(long recordID,
                          Xid xid,
                          boolean isCommit)

Specified by:

putHeuristicCompletion in interface ResourceManager

getHeuristicCommittedTransactions

public List<Xid> getHeuristicCommittedTransactions()

Specified by:

getHeuristicCommittedTransactions in interface ResourceManager

getHeuristicRolledbackTransactions

public List<Xid> getHeuristicRolledbackTransactions()

Specified by:

getHeuristicRolledbackTransactions in interface ResourceManager

removeHeuristicCompletion

public long removeHeuristicCompletion(Xid xid)

Specified by:

removeHeuristicCompletion in interface ResourceManager