org.thales.punch.netty.impl

Class NettyTupleImpl<T>

java.lang.Object

org.thales.punch.netty.impl.NettyTupleImpl<T>

Type Parameters:

T -

All Implemented Interfaces:

INettyTuple<T>

public class NettyTupleImpl<T>
extends Object
implements INettyTuple<T>

The basic single value tuple implementation. It can hold string or byte arrays.

Author:

dimi

Constructor Summary

Constructors

Constructor and Description
NettyTupleImpl(T data, InetSocketAddress local, InetSocketAddress remote) Create a NettyTuple to be notified to a receiver.

Method Summary

Modifier and Type	Method and Description
void	ack() Acknowledge that NettyData.
void	fail() Signal the peer about the failure to process that NettyData.
T	getData() The general case is to receive a Json document (as is, or lumberjack encoded), made of key value pairs.
int	getDataLength()
InetSocketAddress	getLocalAddress() Get the local (i.e.
InetSocketAddress	getRemoteAddress() Get the remote (i.e.
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

NettyTupleImpl

public NettyTupleImpl(T data,
                      InetSocketAddress local,
                      InetSocketAddress remote)

Create a NettyTuple to be notified to a receiver.

Parameters:

data - the data

local - the receiving address

remote - the remote peer address

Method Detail

getLocalAddress

public InetSocketAddress getLocalAddress()

Description copied from interface: INettyTuple

Get the local (i.e. listening) address.

Specified by:

getLocalAddress in interface INettyTuple<T>

Returns:

the local address

getRemoteAddress

public InetSocketAddress getRemoteAddress()

Description copied from interface: INettyTuple

Get the remote (i.e. the peer) address.

Specified by:

getRemoteAddress in interface INettyTuple<T>

Returns:

the peer address

getData

public T getData()

Description copied from interface: INettyTuple

The general case is to receive a Json document (as is, or lumberjack encoded), made of key value pairs. The map returned will then contains several entries. This occurs for instance with the Lumberjack protocol.

If however a single String is received, for instance from a syslog plain client, then you will find a single entry. To avoid the burden and the performance penalty to always retrieve it from a map, you can use the getSingleData method.

Specified by:

getData in interface INettyTuple<T>

Returns:

the data

fail

public void fail()

Description copied from interface: INettyTuple

Signal the peer about the failure to process that NettyData.

What action will be taken is up to the underlying connector. It will be a no-operation if the connector does not support an acknowledged mode.

Specified by:

fail in interface INettyTuple<T>

ack

public void ack()

Description copied from interface: INettyTuple

Acknowledge that NettyData.

What happens is up to the underlying connector. It will be a no-operation if the connector does not support an acknowledged mode.

Specified by:

ack in interface INettyTuple<T>

toString

public String toString()

Overrides:

toString in class Object

getDataLength

public int getDataLength()

Specified by:

getDataLength in interface INettyTuple<T>