org.thales.punch.netty.impl

Class NettyHttpTuple

java.lang.Object

org.thales.punch.netty.impl.NettyHttpTuple

All Implemented Interfaces:

INettyTuple<Map<String,Object>>

public class NettyHttpTuple
extends Object
implements INettyTuple<Map<String,Object>>

Netty Tuple to receive http content.

Author:

dimi

Field Summary

Fields

Modifier and Type	Field and Description
static String	CONTENT Field used to pass the data received from POST requests.

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.
io.netty.channel.ChannelHandlerContext	getChannel()
Map<String,Object>	getData() The general case is to receive a Json document (as is, or lumberjack encoded), made of key value pairs.
int	getDataLength()
boolean	getDirectResponse()
boolean	getKeepAlive()
InetSocketAddress	getLocalAddress() Get the local (i.e.
InetSocketAddress	getRemoteAddress() Get the remote (i.e.
String	getUniqueID()
void	setDirectResponse(boolean directResponse)
void	setKeepAlive(boolean ka)
void	setUniqueID(String s)
String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

CONTENT

public static final String CONTENT

Field used to pass the data received from POST requests.

See Also:

Constant Field Values

Method Detail

getLocalAddress

public InetSocketAddress getLocalAddress()

Description copied from interface: INettyTuple

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

Specified by:

getLocalAddress in interface INettyTuple<Map<String,Object>>

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<Map<String,Object>>

Returns:

the peer address

getData

public Map<String,Object> 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<Map<String,Object>>

Returns:

the data

getChannel

public io.netty.channel.ChannelHandlerContext getChannel()

setKeepAlive

public void setKeepAlive(boolean ka)

getKeepAlive

public boolean getKeepAlive()

setUniqueID

public void setUniqueID(String s)

getUniqueID

public String getUniqueID()

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<Map<String,Object>>

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<Map<String,Object>>

toString

public String toString()

Overrides:

toString in class Object

setDirectResponse

public void setDirectResponse(boolean directResponse)

getDirectResponse

public boolean getDirectResponse()

getDataLength

public int getDataLength()

Specified by:

getDataLength in interface INettyTuple<Map<String,Object>>