com.hazelcast.nio.ascii

Class TextDecoder

java.lang.Object

com.hazelcast.internal.networking.ChannelHandler<InboundHandler,S,D>

com.hazelcast.internal.networking.InboundHandler<ByteBuffer,Void>

com.hazelcast.nio.ascii.TextDecoder

@PrivateApi
public class TextDecoder
extends InboundHandler<ByteBuffer,Void>

Field Summary

Fields inherited from class com.hazelcast.internal.networking.ChannelHandler

channel, dst, src

Constructor Summary

Constructors

Constructor and Description
TextDecoder(TcpIpConnection connection, TextEncoder encoder)

Method Summary

Modifier and Type	Method and Description
void	closeConnection()
TextEncoder	getEncoder()
HandlerStatus	onRead() A callback to indicate that data is available in the src to be processed.
void	publishRequest(TextCommand command)
void	sendResponse(TextCommand command)

Methods inherited from class com.hazelcast.internal.networking.InboundHandler

initSrcBuffer, initSrcBuffer

Methods inherited from class com.hazelcast.internal.networking.ChannelHandler

dst, dst, handlerAdded, interceptError, setChannel, src, src

Methods inherited from class java.lang.Object

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

Constructor Detail

TextDecoder

public TextDecoder(TcpIpConnection connection,
                   TextEncoder encoder)

Method Detail

sendResponse

public void sendResponse(TextCommand command)

onRead

public HandlerStatus onRead()
                     throws Exception

Description copied from class: InboundHandler

A callback to indicate that data is available in the src to be processed. InboundHandlers should be able to deal with spurious onReads (so a read even though there is nothing to be processed).

Specified by:

onRead in class InboundHandler<ByteBuffer,Void>

Returns:

HandlerStatus the status of the handler after processing the src.

Throws:

Exception - if something fails while reading data from the src or processing the data (e.g. when a Packet fails to get processed). When an exception is thrown, the ChannelErrorHandler is called.

publishRequest

public void publishRequest(TextCommand command)

getEncoder

public TextEncoder getEncoder()

closeConnection

public void closeConnection()