Package com.netflix.hystrix.strategy.concurrency

Class HystrixLifecycleForwardingRequestVariable<T>

java.lang.Object

com.netflix.hystrix.strategy.concurrency.HystrixRequestVariableDefault<T>

com.netflix.hystrix.strategy.concurrency.HystrixLifecycleForwardingRequestVariable<T>

All Implemented Interfaces:

HystrixRequestVariable<T>, HystrixRequestVariableLifecycle<T>

public class HystrixLifecycleForwardingRequestVariable<T>
extends HystrixRequestVariableDefault<T>

Implementation of HystrixRequestVariable which forwards to the wrapped HystrixRequestVariableLifecycle.

This implementation also returns null when get() is called while the HystrixRequestContext has not been initialized rather than throwing an exception, allowing for use in a HystrixConcurrencyStrategy which does not depend on an a HystrixRequestContext

Constructor Summary

Constructors

Constructor and Description
HystrixLifecycleForwardingRequestVariable(HystrixRequestVariableLifecycle<T> lifecycle) Creates a HystrixRequestVariable which will return data as provided by the HystrixRequestVariableLifecycle

Method Summary

Modifier and Type	Method and Description
T	get() Return null if the HystrixRequestContext has not been initialized for the current thread.
T	initialValue() Delegates to the wrapped HystrixRequestVariableLifecycle
void	shutdown(T value) Delegates to the wrapped HystrixRequestVariableLifecycle

Methods inherited from class com.netflix.hystrix.strategy.concurrency.HystrixRequestVariableDefault

remove, set

Methods inherited from class java.lang.Object

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

Constructor Detail

HystrixLifecycleForwardingRequestVariable

public HystrixLifecycleForwardingRequestVariable(HystrixRequestVariableLifecycle<T> lifecycle)

Creates a HystrixRequestVariable which will return data as provided by the HystrixRequestVariableLifecycle

Parameters:

lifecycle - lifecycle used to provide values. Must have the same type parameter as the constructed instance.

Method Detail

initialValue

public T initialValue()

Delegates to the wrapped HystrixRequestVariableLifecycle

Specified by:

initialValue in interface HystrixRequestVariableLifecycle<T>

Overrides:

initialValue in class HystrixRequestVariableDefault<T>

Returns:

T with initial value or null if none.

shutdown

public void shutdown(T value)

Delegates to the wrapped HystrixRequestVariableLifecycle

Specified by:

shutdown in interface HystrixRequestVariableLifecycle<T>

Overrides:

shutdown in class HystrixRequestVariableDefault<T>

Parameters:

value - of request variable to allow cleanup activity.

If nothing needs to be cleaned up then nothing needs to be done in this method.

get

public T get()

Return null if the HystrixRequestContext has not been initialized for the current thread.

If HystrixRequestContext has been initialized then call method in superclass: HystrixRequestVariableDefault.get()

Specified by:

get in interface HystrixRequestVariable<T>

Overrides:

get in class HystrixRequestVariableDefault<T>

Returns:

the value of the variable for the current request, or null if no value has been set and there is no initial value