org.thales.punch.netty.impl

Class NettyLumberjackDecoder

java.lang.Object

org.thales.punch.netty.impl.NettyLumberjackDecoder

public class NettyLumberjackDecoder
extends Object

This class is a slight facade on top of the plain LimberjackDecoder. It simply adds the passing of the metric context counters.

Author:

dimi

Constructor Summary

Constructors

Constructor and Description
NettyLumberjackDecoder() Test constructor.
NettyLumberjackDecoder(org.thales.punch.libraries.metrics.api.IMetricContext metricsContext) Ctor

Method Summary

Modifier and Type	Method and Description
List<org.thales.punch.lumberjack.LumberjackFrame>	decode(byte[] in) Decode a received payload and return the lumberjack frames contained in it.
List<org.thales.punch.lumberjack.LumberjackFrame>	decode(byte[] in, int offset) Decode a received payload at some starting offset and return the lumberjack frames contained in it.
List<org.thales.punch.lumberjack.LumberjackFrame>	decode(io.netty.buffer.ByteBuf in) Decode a received payload and return the lumberjack frames contained in it.
List<org.thales.punch.lumberjack.LumberjackFrame>	decodeComplete(ByteBuffer in) Decode a received payload.

Methods inherited from class java.lang.Object

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

Constructor Detail

NettyLumberjackDecoder

public NettyLumberjackDecoder()

Test constructor.

NettyLumberjackDecoder

public NettyLumberjackDecoder(org.thales.punch.libraries.metrics.api.IMetricContext metricsContext)

Ctor

Parameters:

metricsContext - the metrics context

Method Detail

decode

public List<org.thales.punch.lumberjack.LumberjackFrame> decode(io.netty.buffer.ByteBuf in)

Decode a received payload and return the lumberjack frames contained in it. If the payload is not complete, an empty list is returned. The next calls will succeeds (eventually).

Parameters:

in - the input payload ByteBuf

Returns:

the decoded frames

decode

public List<org.thales.punch.lumberjack.LumberjackFrame> decode(byte[] in)

Decode a received payload and return the lumberjack frames contained in it. If the payload is not complete, an empty list is returned. The next calls will succeeds (eventually).

Parameters:

in - the input payload byte array

Returns:

the decoded frames

Throws:

IllegalArgumentException - if the data cannot be lumberjack decoded

decodeComplete

public List<org.thales.punch.lumberjack.LumberjackFrame> decodeComplete(ByteBuffer in)

Decode a received payload. This form accepts a ByteBuffer, handy to get data from a Kafka message.

Parameters:

in -

Returns:

the list of frame

decode

public List<org.thales.punch.lumberjack.LumberjackFrame> decode(byte[] in,
                                                                int offset)

Decode a received payload at some starting offset and return the lumberjack frames contained in it. If the payload is not complete, an empty list is returned. The next calls will succeeds (eventually).

Parameters:

in - the input payload byte array

offset - the starting offset

Returns:

the decoded frames

Throws:

IllegalArgumentException - if the data cannot be lumberjack decoded