net.openhft.chronicle.wire

Class VanillaMethodReader

java.lang.Object

net.openhft.chronicle.wire.VanillaMethodReader

All Implemented Interfaces:

Closeable, AutoCloseable, net.openhft.chronicle.bytes.MethodReader, net.openhft.chronicle.core.io.QueryCloseable

public class VanillaMethodReader
extends Object
implements net.openhft.chronicle.bytes.MethodReader

Field Summary

Fields inherited from interface net.openhft.chronicle.bytes.MethodReader

HISTORY

Constructor Summary

Constructors

Constructor and Description
VanillaMethodReader(MarshallableIn in, boolean ignoreDefault, WireParselet defaultParselet, FieldNumberParselet fieldNumberParselet, net.openhft.chronicle.bytes.MethodReaderInterceptorReturns methodReaderInterceptorReturns, Object... objects)
VanillaMethodReader(MarshallableIn in, boolean ignoreDefault, WireParselet defaultParselet, net.openhft.chronicle.bytes.MethodReaderInterceptorReturns methodReaderInterceptorReturns, Object... objects)

Method Summary

Modifier and Type	Method and Description
void	addParseletForMethod(Object o2, Object[] context, Supplier contextSupplier, @NotNull Method m)
void	addParseletForMethod(Object o2, Object[] context, Supplier contextSupplier, @NotNull Method m, @NotNull Class[] parameterTypes)
void	addParseletForMethod(Object o2, Object[] context, Supplier contextSupplier, @NotNull Method m, @NotNull Class[] parameterTypes, MethodFilterOnFirstArg methodFilterOnFirstArg)
void	addParseletForMethod(Object o2, Object[] context, Supplier contextSupplier, @NotNull Method m, Class<?> parameterType)
void	close()
@NotNull VanillaMethodReader	closeIn(boolean closeIn)
protected @NotNull MethodWireKey	createWireKey(@NotNull Method m, String name)
protected Object	invoke(Object o, @NotNull Method m, Object[] args)
boolean	isClosed()
boolean	lazyReadOne()
static void	logMessage(@NotNull CharSequence s, @NotNull ValueIn v)
net.openhft.chronicle.bytes.MethodReaderInterceptorReturns	methodReaderInterceptorReturns()
boolean	readOne() reads one message
protected @NotNull WireParser	wireParser()

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.core.io.Closeable

closeQuietly, closeQuietly, notifyClosing

Methods inherited from interface net.openhft.chronicle.core.io.QueryCloseable

isClosing, throwExceptionIfClosed

Constructor Detail

VanillaMethodReader

public VanillaMethodReader(MarshallableIn in,
                           boolean ignoreDefault,
                           WireParselet defaultParselet,
                           net.openhft.chronicle.bytes.MethodReaderInterceptorReturns methodReaderInterceptorReturns,
                           @NotNull
                           Object... objects)

VanillaMethodReader

public VanillaMethodReader(MarshallableIn in,
                           boolean ignoreDefault,
                           WireParselet defaultParselet,
                           FieldNumberParselet fieldNumberParselet,
                           net.openhft.chronicle.bytes.MethodReaderInterceptorReturns methodReaderInterceptorReturns,
                           @NotNull
                           Object... objects)

Method Detail

logMessage

public static void logMessage(@NotNull
                              @NotNull CharSequence s,
                              @NotNull
                              @NotNull ValueIn v)

closeIn

@NotNull
public @NotNull VanillaMethodReader closeIn(boolean closeIn)

Specified by:

closeIn in interface net.openhft.chronicle.bytes.MethodReader

addParseletForMethod

public void addParseletForMethod(Object o2,
                                 Object[] context,
                                 Supplier contextSupplier,
                                 @NotNull
                                 @NotNull Method m,
                                 Class<?> parameterType)

addParseletForMethod

public void addParseletForMethod(Object o2,
                                 Object[] context,
                                 Supplier contextSupplier,
                                 @NotNull
                                 @NotNull Method m)

createWireKey

@NotNull
protected @NotNull MethodWireKey createWireKey(@NotNull
                                                        @NotNull Method m,
                                                        String name)

addParseletForMethod

public void addParseletForMethod(Object o2,
                                 Object[] context,
                                 Supplier contextSupplier,
                                 @NotNull
                                 @NotNull Method m,
                                 @NotNull
                                 @NotNull Class[] parameterTypes)

addParseletForMethod

public void addParseletForMethod(Object o2,
                                 Object[] context,
                                 Supplier contextSupplier,
                                 @NotNull
                                 @NotNull Method m,
                                 @NotNull
                                 @NotNull Class[] parameterTypes,
                                 MethodFilterOnFirstArg methodFilterOnFirstArg)

invoke

protected Object invoke(Object o,
                        @NotNull
                        @NotNull Method m,
                        Object[] args)
                 throws net.openhft.chronicle.core.util.InvocationTargetRuntimeException

Throws:

net.openhft.chronicle.core.util.InvocationTargetRuntimeException

readOne

public boolean readOne()
                throws net.openhft.chronicle.core.util.InvocationTargetRuntimeException

reads one message

Specified by:

readOne in interface net.openhft.chronicle.bytes.MethodReader

Returns:

true if there was a message, or false if no more data is available. If we read a metadata message, true is returned even if it was ignored

Throws:

net.openhft.chronicle.core.util.InvocationTargetRuntimeException

lazyReadOne

public boolean lazyReadOne()

Specified by:

lazyReadOne in interface net.openhft.chronicle.bytes.MethodReader

close

public void close()

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

isClosed

public boolean isClosed()

Specified by:

isClosed in interface net.openhft.chronicle.core.io.QueryCloseable

methodReaderInterceptorReturns

public net.openhft.chronicle.bytes.MethodReaderInterceptorReturns methodReaderInterceptorReturns()

Specified by:

methodReaderInterceptorReturns in interface net.openhft.chronicle.bytes.MethodReader

wireParser

@NotNull
protected @NotNull WireParser wireParser()