com.thoughtworks.proxy.toys.multicast

Class MulticastingInvoker<T>

java.lang.Object

com.thoughtworks.proxy.toys.multicast.MulticastingInvoker<T>

All Implemented Interfaces:

Invoker, java.io.Serializable

public class MulticastingInvoker<T>
extends java.lang.Object
implements Invoker

A Invoker implementation that multicasts calls to multiple targets. Proxies generated by this class will forward all method invocations to an array of underlying objects. The behavior is recursive, so return values will also be multicasting objects.

Since:

0.1

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
private static java.lang.reflect.Method	getTargetsInArray
private static java.lang.reflect.Method	getTargetsInTypedArray
private static java.lang.reflect.Method	multicastTargetsDirect
private static java.lang.reflect.Method	multicastTargetsIndirect
private ProxyFactory	proxyFactory
private static long	serialVersionUID
private java.lang.Object[]	targets
private java.lang.Class<?>[]	types

Constructor Summary

Constructors

Constructor and Description
MulticastingInvoker(java.lang.Class<?>[] type, ProxyFactory proxyFactory, java.lang.Object[] targets) Construct a MulticastingInvoker.

Method Summary

Modifier and Type	Method and Description
private static java.lang.Byte	addBytes(java.lang.Object[] args)
private static java.lang.Character	addChars(java.lang.Object[] args)
private static java.lang.Double	addDoubles(java.lang.Object[] args)
private static java.lang.Float	addFloats(java.lang.Object[] args)
private static java.lang.Integer	addIntegers(java.lang.Object[] args)
private static java.lang.Long	addLongs(java.lang.Object[] args)
private static java.lang.Short	addShorts(java.lang.Object[] args)
private static java.lang.Boolean	andBooleans(java.lang.Object[] args)
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.

Methods inherited from class java.lang.Object

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

Field Detail

serialVersionUID

private static final long serialVersionUID

See Also:

Constant Field Values

multicastTargetsDirect

private static final java.lang.reflect.Method multicastTargetsDirect

multicastTargetsIndirect

private static final java.lang.reflect.Method multicastTargetsIndirect

getTargetsInArray

private static final java.lang.reflect.Method getTargetsInArray

getTargetsInTypedArray

private static final java.lang.reflect.Method getTargetsInTypedArray

types

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

proxyFactory

private ProxyFactory proxyFactory

targets

private java.lang.Object[] targets

Constructor Detail

MulticastingInvoker

public MulticastingInvoker(java.lang.Class<?>[] type,
                           ProxyFactory proxyFactory,
                           java.lang.Object[] targets)

Construct a MulticastingInvoker.

Parameters:

type - the implemented types

proxyFactory - the ProxyFactory to use

targets - the target instances where the proxy delegates a call

Since:

0.1

Method Detail

proxy

public T proxy()

Create a proxy for this Invoker.

Returns:

the new proxy

Since:

0.1

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

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.

addBytes

private static java.lang.Byte addBytes(java.lang.Object[] args)

addChars

private static java.lang.Character addChars(java.lang.Object[] args)

addShorts

private static java.lang.Short addShorts(java.lang.Object[] args)

addIntegers

private static java.lang.Integer addIntegers(java.lang.Object[] args)

addLongs

private static java.lang.Long addLongs(java.lang.Object[] args)

addFloats

private static java.lang.Float addFloats(java.lang.Object[] args)

addDoubles

private static java.lang.Double addDoubles(java.lang.Object[] args)

andBooleans

private static java.lang.Boolean andBooleans(java.lang.Object[] args)