net.openhft.chronicle.bytes

Class BytesMethodReader

java.lang.Object

net.openhft.chronicle.core.io.SimpleCloseable

net.openhft.chronicle.bytes.BytesMethodReader

All Implemented Interfaces:

Closeable, AutoCloseable, MethodReader, net.openhft.chronicle.core.io.ManagedCloseable, net.openhft.chronicle.core.io.QueryCloseable, net.openhft.chronicle.core.io.ReferenceOwner

public class BytesMethodReader
extends net.openhft.chronicle.core.io.SimpleCloseable
implements MethodReader

Concrete MethodReader that reads method calls serialised in a binary format from a BytesIn stream and dispatches them to target objects. MethodEncoder instances, typically obtained via MethodEncoderLookup, are used to decode arguments. This reader is not thread-safe and extends SimpleCloseable.

Field Summary

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

HISTORY, MESSAGE_HISTORY_METHOD_ID

Fields inherited from interface net.openhft.chronicle.core.io.ReferenceOwner

INIT, TMP

Constructor Summary

Constructors

Constructor and Description
BytesMethodReader(BytesIn<?> in, BytesParselet defaultParselet, MethodEncoderLookup methodEncoderLookup, Object[] objects)

Method Summary

Modifier and Type	Method and Description
MethodReader	closeIn(boolean closeIn) This implementation does not currently close the underlying BytesIn when invoked.
MethodReaderInterceptorReturns	methodReaderInterceptorReturns() Interceptors for method reader returns are not supported by this implementation.
boolean	readOne() Reads the next method call from the input stream.

Methods inherited from class net.openhft.chronicle.core.io.SimpleCloseable

close, isClosed, performClose

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

close, closeQuietly, closeQuietly

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

isClosed, isClosing

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

referenceId, referenceName, temporary

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

createdHere, throwExceptionIfClosed, warnAndCloseIfNotClosed

Constructor Detail

BytesMethodReader

public BytesMethodReader(BytesIn<?> in,
                         BytesParselet defaultParselet,
                         MethodEncoderLookup methodEncoderLookup,
                         Object[] objects)

Parameters:

in - the BytesIn stream from which messages are read

defaultParselet - handler for messages with unrecognised IDs

methodEncoderLookup - strategy for obtaining MethodEncoder instances

objects - target objects whose methods may be invoked

Method Detail

methodReaderInterceptorReturns

public MethodReaderInterceptorReturns methodReaderInterceptorReturns()

Interceptors for method reader returns are not supported by this implementation.

Specified by:

methodReaderInterceptorReturns in interface MethodReader

Returns:

a MethodReaderInterceptorReturns instance

Throws:

UnsupportedOperationException - always

readOne

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

Reads the next method call from the input stream. The message ID is read using stop bit encoding and used to look up a handler. If none is found the defaultParselet is invoked.

Specified by:

readOne in interface MethodReader

Returns:

true if a message was processed, false if no data was available

Throws:

net.openhft.chronicle.core.util.InvocationTargetRuntimeException - if the target method throws an exception

BufferUnderflowException - if the stream ends prematurely

net.openhft.chronicle.core.io.ClosedIllegalStateException - if the BytesIn has been released

net.openhft.chronicle.core.io.ThreadingIllegalStateException - if accessed by multiple threads unsafely

IllegalStateException

closeIn

public MethodReader closeIn(boolean closeIn)

This implementation does not currently close the underlying BytesIn when invoked. The parameter is ignored.

Specified by:

closeIn in interface MethodReader

Parameters:

closeIn - ignored

Returns:

this reader