net.openhft.chronicle.bytes

Class BinaryBytesMethodWriterInvocationHandler

java.lang.Object

net.openhft.chronicle.core.util.AbstractInvocationHandler

net.openhft.chronicle.bytes.BinaryBytesMethodWriterInvocationHandler

All Implemented Interfaces:

InvocationHandler, BytesMethodWriterInvocationHandler

public class BinaryBytesMethodWriterInvocationHandler
extends net.openhft.chronicle.core.util.AbstractInvocationHandler
implements BytesMethodWriterInvocationHandler

InvocationHandler that serialises method calls to a BytesOut using a MethodEncoder per method. Intended for proxy based one-way messaging.

Constructor Summary

Constructors

Constructor and Description
BinaryBytesMethodWriterInvocationHandler(Class<?> tClass, Function<Method,MethodEncoder> methodToId, BytesOut<?> out) Creates an instance for the supplied interface.

Method Summary

Modifier and Type	Method and Description
protected Object	doInvoke(Object proxy, Method method, Object[] args) Encodes the invocation and writes it to out.

Methods inherited from class net.openhft.chronicle.core.util.AbstractInvocationHandler

invoke, onClose

Methods inherited from class java.lang.Object

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

Methods inherited from interface net.openhft.chronicle.bytes.BytesMethodWriterInvocationHandler

onClose

Methods inherited from interface java.lang.reflect.InvocationHandler

invoke

Constructor Detail

BinaryBytesMethodWriterInvocationHandler

public BinaryBytesMethodWriterInvocationHandler(Class<?> tClass,
                                                Function<Method,MethodEncoder> methodToId,
                                                BytesOut<?> out)

Creates an instance for the supplied interface.

Parameters:

tClass - interface being proxied

methodToId - lookup supplying a MethodEncoder per method

out - target stream for the encoded calls

Method Detail

doInvoke

protected Object doInvoke(Object proxy,
                          Method method,
                          Object[] args)
                   throws IllegalStateException,
                          BufferOverflowException,
                          BufferUnderflowException,
                          IllegalArgumentException,
                          ArithmeticException,
                          net.openhft.chronicle.core.io.InvalidMarshallableException

Encodes the invocation and writes it to out. On failure the write position is rolled back to preserve stream integrity.

Specified by:

doInvoke in class net.openhft.chronicle.core.util.AbstractInvocationHandler

Throws:

IllegalStateException

BufferOverflowException

BufferUnderflowException

IllegalArgumentException

ArithmeticException

net.openhft.chronicle.core.io.InvalidMarshallableException