org.springframework.amqp.rabbit.connection

Class SimpleResourceHolder

java.lang.Object

org.springframework.amqp.rabbit.connection.SimpleResourceHolder

public final class SimpleResourceHolder
extends java.lang.Object

Central helper that manages resources per thread to be used by resource management code.

Supports one resource per key without overwriting, that is, a resource needs to be removed before a new one can be set for the same key.

Resource management code should check for thread-bound resources via has(Object).

This helper isn't designed for transaction synchronization cases. Use TransactionSynchronizationManager and ResourceHolder instead.

Since:

1.3

Field Summary

Fields

Modifier and Type	Field and Description
private static org.apache.commons.logging.Log	logger
private static java.lang.ThreadLocal<java.util.Map<java.lang.Object,java.lang.Object>>	resources

Constructor Summary

Constructors

Modifier	Constructor and Description
private	SimpleResourceHolder()

Method Summary

Modifier and Type	Method and Description
static void	bind(java.lang.Object key, java.lang.Object value) Bind the given resource for the given key to the current thread.
static void	clear() Clear resources for the current thread.
private static java.lang.Object	doGet(java.lang.Object actualKey) Actually check the value of the resource that is bound for the given key.
static java.lang.Object	get(java.lang.Object key) Retrieve a resource for the given key that is bound to the current thread.
static java.util.Map<java.lang.Object,java.lang.Object>	getResources() Return all resources that are bound to the current thread.
static boolean	has(java.lang.Object key) Check if there is a resource for the given key bound to the current thread.
static java.lang.Object	unbind(java.lang.Object key) Unbind a resource for the given key from the current thread.
static java.lang.Object	unbindIfPossible(java.lang.Object key) Unbind a resource for the given key from the current thread.

Methods inherited from class java.lang.Object

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

Field Detail

logger

private static final org.apache.commons.logging.Log logger

resources

private static final java.lang.ThreadLocal<java.util.Map<java.lang.Object,java.lang.Object>> resources

Constructor Detail

SimpleResourceHolder

private SimpleResourceHolder()

Method Detail

getResources

public static java.util.Map<java.lang.Object,java.lang.Object> getResources()

Return all resources that are bound to the current thread.

Mainly for debugging purposes. Resource managers should always invoke hasResource for a specific resource key that they are interested in.

Returns:

a Map with resource keys (usually the resource factory) and resource values (usually the active resource object), or an empty Map if there are currently no resources bound

See Also:

has(java.lang.Object)

has

public static boolean has(java.lang.Object key)

Check if there is a resource for the given key bound to the current thread.

Parameters:

key - the key to check (usually the resource factory)

Returns:

if there is a value bound to the current thread

get

public static java.lang.Object get(java.lang.Object key)

Retrieve a resource for the given key that is bound to the current thread.

Parameters:

key - the key to check (usually the resource factory)

Returns:

a value bound to the current thread (usually the active resource object), or null if none

doGet

private static java.lang.Object doGet(java.lang.Object actualKey)

Actually check the value of the resource that is bound for the given key.

bind

public static void bind(java.lang.Object key,
                        java.lang.Object value)

Bind the given resource for the given key to the current thread.

Parameters:

key - the key to bind the value to (usually the resource factory)

value - the value to bind (usually the active resource object)

Throws:

java.lang.IllegalStateException - if there is already a value bound to the thread

unbind

public static java.lang.Object unbind(java.lang.Object key)
                               throws java.lang.IllegalStateException

Unbind a resource for the given key from the current thread.

Parameters:

key - the key to unbind (usually the resource factory)

Returns:

the previously bound value (usually the active resource object)

Throws:

java.lang.IllegalStateException - if there is no value bound to the thread

unbindIfPossible

public static java.lang.Object unbindIfPossible(java.lang.Object key)

Unbind a resource for the given key from the current thread.

Parameters:

key - the key to unbind (usually the resource factory)

Returns:

the previously bound value, or null if none bound

clear

public static void clear()

Clear resources for the current thread.