Package org.apache.activemq.artemis.core.transaction.impl

Class ResourceManagerImpl

java.lang.Object

org.apache.activemq.artemis.core.transaction.impl.ResourceManagerImpl

All Implemented Interfaces:

ActiveMQComponent, ResourceManager

public class ResourceManagerImpl
extends Object
implements ResourceManager

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
List<Xid>	getHeuristicCommittedTransactions()
List<Xid>	getHeuristicRolledbackTransactions()
List<Xid>	getInDoubtTransactions()
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, RemotingConnection remotingConnection)
long	removeHeuristicCompletion(Xid xid)
Transaction	removeTransaction(Xid xid, RemotingConnection remotingConnection)
int	size()
void	start()
void	stop()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.activemq.artemis.core.server.ActiveMQComponent

asyncStop

Constructor Details

ResourceManagerImpl

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

Method Details

size

public int size()

Specified by:

size in interface ResourceManager

start

public void start()
           throws Exception

Specified by:

start in interface ActiveMQComponent

Throws:

Exception

stop

public void stop()
          throws Exception

Specified by:

stop in interface ActiveMQComponent

Throws:

Exception

isStarted

public boolean isStarted()

Specified by:

isStarted in interface ActiveMQComponent

getTransaction

public Transaction getTransaction(Xid xid)

Specified by:

getTransaction in interface ResourceManager

putTransaction

public boolean putTransaction(Xid xid,
 Transaction tx,
 RemotingConnection remotingConnection)
                       throws ActiveMQException

Specified by:

putTransaction in interface ResourceManager

Throws:

ActiveMQException

removeTransaction

public Transaction removeTransaction(Xid xid,
 RemotingConnection remotingConnection)
                              throws ActiveMQException

Specified by:

removeTransaction in interface ResourceManager

Throws:

ActiveMQException

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

getInDoubtTransactions

public List<Xid> getInDoubtTransactions()

Specified by:

getInDoubtTransactions in interface ResourceManager