net.bluemind.ips.vertx.impl

Class ByteBufProcParser

java.lang.Object

net.bluemind.ips.vertx.impl.ByteBufProcParser

All Implemented Interfaces:

IRecordParser, org.vertx.java.core.Handler<io.netty.buffer.ByteBuf>

public final class ByteBufProcParser
extends java.lang.Object
implements org.vertx.java.core.Handler<io.netty.buffer.ByteBuf>, IRecordParser

Field Summary

Fields

Modifier and Type	Field and Description
static byte	CR
static byte	LF

Method Summary

Modifier and Type	Method and Description
void	delimitedMode() Flip the parser into delimited mode, and where the delimiter can be represented by the delimiter.
void	fixedSizeMode(int size) Flip the parser into fixed size mode, where the record size is specified by size in bytes.
void	handle(org.vertx.java.core.buffer.Buffer b)
void	handle(io.netty.buffer.ByteBuf buffer) This method is called to provide the parser with data.
static ByteBufProcParser	newDelimited(org.vertx.java.core.net.NetSocket crapSource, java.lang.String logPrefix, IParsedChunksDrainer drainer) Create a new RecordParser instance, initially in delimited mode, and where the delimiter can be represented by the byte[] delim.

Methods inherited from class java.lang.Object

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

Field Detail

CR

public static final byte CR

See Also:

Constant Field Values

LF

public static final byte LF

See Also:

Constant Field Values

Method Detail

newDelimited

public static ByteBufProcParser newDelimited(org.vertx.java.core.net.NetSocket crapSource,
                                             java.lang.String logPrefix,
                                             IParsedChunksDrainer drainer)

Create a new RecordParser instance, initially in delimited mode, and where the delimiter can be represented by the byte[] delim.

output Will receive whole records which have been parsed.

delimitedMode

public void delimitedMode()

Flip the parser into delimited mode, and where the delimiter can be represented by the delimiter.

Specified by:

delimitedMode in interface IRecordParser

fixedSizeMode

public void fixedSizeMode(int size)

Flip the parser into fixed size mode, where the record size is specified by size in bytes.

This method can be called multiple times with different values of size while data is being parsed.

Specified by:

fixedSizeMode in interface IRecordParser

handle

public void handle(org.vertx.java.core.buffer.Buffer b)

handle

public void handle(io.netty.buffer.ByteBuf buffer)

This method is called to provide the parser with data.

Specified by:

handle in interface IRecordParser

Specified by:

handle in interface org.vertx.java.core.Handler<io.netty.buffer.ByteBuf>

Parameters:

buffer -