Package org.apache.ignite.client.handler

Class ClientResourceRegistry

java.lang.Object

org.apache.ignite.client.handler.ClientResourceRegistry

public class ClientResourceRegistry
extends Object

Per-connection resource registry.

Constructor Summary

Constructors

Constructor	Description
ClientResourceRegistry()

Method Summary

Modifier and Type	Method	Description
void	addTxCleaner(UUID txId, int tableId, int partitionId, org.apache.ignite.internal.tx.TxManager txManager, org.apache.ignite.internal.table.IgniteTablesInternal tables)	Records that a remote transaction enlisted a partition on this node.
void	close()	Closes the registry and releases all resources.
ClientResource	get(long id)	Gets the resource by id.
long	put(ClientResource obj)	Stores the resource and returns the generated id.
ClientResource	remove(long id)	Removes the resource.
void	removeTxCleaner(UUID txId)	Removes the transaction cleaner associated with the given transaction ID.
int	size()

Methods inherited from class java.lang.Object

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

Constructor Details

ClientResourceRegistry

public ClientResourceRegistry()

Method Details

put

public long put(ClientResource obj)
         throws org.apache.ignite.internal.lang.IgniteInternalCheckedException

Stores the resource and returns the generated id.

Parameters:

obj - Object.

Returns:

Id.

Throws:

org.apache.ignite.internal.lang.IgniteInternalCheckedException

get

public ClientResource get(long id)
                   throws org.apache.ignite.internal.lang.IgniteInternalCheckedException

Gets the resource by id.

Parameters:

id - Id.

Returns:

Object.

Throws:

org.apache.ignite.internal.lang.IgniteInternalCheckedException

remove

public ClientResource remove(long id)
                      throws org.apache.ignite.internal.lang.IgniteInternalCheckedException

Removes the resource.

Parameters:

id - Id.

Throws:

org.apache.ignite.internal.lang.IgniteInternalCheckedException

addTxCleaner

public void addTxCleaner(UUID txId,
 int tableId,
 int partitionId,
 org.apache.ignite.internal.tx.TxManager txManager,
 org.apache.ignite.internal.table.IgniteTablesInternal tables)
                  throws org.apache.ignite.internal.lang.IgniteInternalCheckedException

Records that a remote transaction enlisted a partition on this node.

Parameters:

txId - Transaction ID.

tableId - Table ID.

partitionId - Partition ID.

txManager - Transaction manager responsible for coordinating and cleaning up the transaction.

tables - Tables facade used to resolve table information for enlisted partitions.

Throws:

org.apache.ignite.internal.lang.IgniteInternalCheckedException

removeTxCleaner

public void removeTxCleaner(UUID txId)
                     throws org.apache.ignite.internal.lang.IgniteInternalCheckedException

Removes the transaction cleaner associated with the given transaction ID.

Parameters:

txId - Transaction ID whose cleaner should be removed.

Throws:

org.apache.ignite.internal.lang.IgniteInternalCheckedException

close

public void close()

Closes the registry and releases all resources.

size

@TestOnly
public int size()