com.thoughtworks.proxy.toys.hotswap

Class HotSwappingInvoker<T>

java.lang.Object

com.thoughtworks.proxy.toys.delegate.DelegatingInvoker<java.lang.Object>

com.thoughtworks.proxy.toys.hotswap.HotSwappingInvoker<T>

All Implemented Interfaces:

Invoker, java.io.Serializable

Direct Known Subclasses:

FailoverInvoker

public class HotSwappingInvoker<T>
extends DelegatingInvoker<java.lang.Object>

A DelegatingInvoker implementation that allows the exchange of the delegate.

Since:

0.1

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static interface	HotSwappingInvoker.CycleCheck Internal interface used to detect cyclic swapping activity.

Field Summary

Fields

Modifier and Type	Field and Description
private static java.lang.reflect.Method	checkForCycle
private java.lang.ThreadLocal<java.lang.Object>	delegate
private boolean	executed
private static java.lang.reflect.Method	hotswap
private static long	serialVersionUID
private java.lang.Class<?>[]	types

Constructor Summary

Constructors

Constructor and Description
HotSwappingInvoker(java.lang.Class<?>[] types, ProxyFactory proxyFactory, ObjectReference<java.lang.Object> delegateReference, DelegationMode delegationMode) Construct a HotSwappingInvoker.

Method Summary

Modifier and Type	Method and Description
protected java.lang.Object	delegate() Retrieve the delegated object in derived classes.
protected java.lang.Object	hotswap(java.lang.Object newDelegate) Exchange the current delegate.
java.lang.Object	invoke(java.lang.Object proxy, java.lang.reflect.Method method, java.lang.Object[] args) Invocation of a method of the proxied object.
T	proxy() Create a proxy for this Invoker.
private void	readObject(java.io.ObjectInputStream in)
private void	writeObject(java.io.ObjectOutputStream out)

Methods inherited from class com.thoughtworks.proxy.toys.delegate.DelegatingInvoker

equals, getDelegateReference, getMethodToInvoke, getProxyFactory, hashCode, invokeOnDelegate

Methods inherited from class java.lang.Object

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

Field Detail

serialVersionUID

private static final long serialVersionUID

See Also:

Constant Field Values

hotswap

private static final java.lang.reflect.Method hotswap

checkForCycle

private static final java.lang.reflect.Method checkForCycle

types

private java.lang.Class<?>[] types

executed

private transient boolean executed

delegate

private transient java.lang.ThreadLocal<java.lang.Object> delegate

Constructor Detail

HotSwappingInvoker

public HotSwappingInvoker(java.lang.Class<?>[] types,
                          ProxyFactory proxyFactory,
                          ObjectReference<java.lang.Object> delegateReference,
                          DelegationMode delegationMode)

Construct a HotSwappingInvoker.

Parameters:

types - the types of the proxy

proxyFactory - the ProxyFactory to use

delegateReference - the ObjectReference with the delegate

delegationMode - DelegationMode.DIRECT or DelegationMode.SIGNATURE

Since:

1.0

Method Detail

invoke

public java.lang.Object invoke(java.lang.Object proxy,
                               java.lang.reflect.Method method,
                               java.lang.Object[] args)
                        throws java.lang.Throwable

Description copied from interface: Invoker

Invocation of a method of the proxied object.

Specified by:

invoke in interface Invoker

Overrides:

invoke in class DelegatingInvoker<java.lang.Object>

Parameters:

proxy - the proxy instance.

method - the method to invoke.

args - the arguments of the method.

Returns:

the result of the invoked method.

Throws:

java.lang.Throwable - if the invoked method has thrown.

delegate

protected java.lang.Object delegate()

Description copied from class: DelegatingInvoker

Retrieve the delegated object in derived classes.

Overrides:

delegate in class DelegatingInvoker<java.lang.Object>

Returns:

the delegated object

hotswap

protected java.lang.Object hotswap(java.lang.Object newDelegate)

Exchange the current delegate.

Parameters:

newDelegate - the new delegate

Returns:

the old delegate

Throws:

java.lang.IllegalStateException - if cyclic swapping action is detected

Since:

0.1

proxy

public T proxy()

Create a proxy for this Invoker. The proxy implements all the types given as parameter to the constructor and implements additionally the Swappable interface.

Returns:

the new proxy

Since:

0.1

writeObject

private void writeObject(java.io.ObjectOutputStream out)
                  throws java.io.IOException

Throws:

java.io.IOException

readObject

private void readObject(java.io.ObjectInputStream in)
                 throws java.io.IOException,
                        java.lang.ClassNotFoundException

Throws:

java.io.IOException

java.lang.ClassNotFoundException