org.graylog2.inputs.transports

Class TcpTransport

java.lang.Object

org.graylog2.plugin.inputs.transports.NettyTransport

org.graylog2.plugin.inputs.transports.AbstractTcpTransport

org.graylog2.inputs.transports.TcpTransport

All Implemented Interfaces:

Transport

Direct Known Subclasses:

SyslogTcpTransport

public class TcpTransport
extends AbstractTcpTransport

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	TcpTransport.Config
static interface	TcpTransport.Factory

Field Summary

Fields

Modifier and Type	Field and Description
static String	CK_USE_NULL_DELIMITER
protected org.jboss.netty.buffer.ChannelBuffer[]	delimiter
protected int	maxFrameLength

Fields inherited from class org.graylog2.plugin.inputs.transports.AbstractTcpTransport

bossExecutor, configuration, connectionCounter, workerExecutor

Fields inherited from class org.graylog2.plugin.inputs.transports.NettyTransport

CK_BIND_ADDRESS, CK_PORT, CK_RECV_BUFFER_SIZE, localRegistry, throughputCounter

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	TcpTransport(Configuration configuration, Executor bossPool, Executor workerPool, ThroughputCounter throughputCounter, ConnectionCounter connectionCounter, LocalMetricRegistry localRegistry)
	TcpTransport(Configuration configuration, Executor bossPool, ThroughputCounter throughputCounter, ConnectionCounter connectionCounter, LocalMetricRegistry localRegistry)

Method Summary

Methods

Modifier and Type	Method and Description
protected org.jboss.netty.bootstrap.Bootstrap	getBootstrap()
protected LinkedHashMap<String,Callable<? extends org.jboss.netty.channel.ChannelHandler>>	getFinalChannelHandlers(MessageInput input)

Methods inherited from class org.graylog2.plugin.inputs.transports.AbstractTcpTransport

getBaseChannelHandlers

Methods inherited from class org.graylog2.plugin.inputs.transports.NettyTransport

getLocalAddress, getMetricSet, getRecvBufferSize, launch, setMessageAggregator, stop

Methods inherited from class java.lang.Object

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

Field Detail

CK_USE_NULL_DELIMITER

public static final String CK_USE_NULL_DELIMITER

See Also:

Constant Field Values

delimiter

protected final org.jboss.netty.buffer.ChannelBuffer[] delimiter

maxFrameLength

protected final int maxFrameLength

Constructor Detail

TcpTransport

public TcpTransport(Configuration configuration,
            @Named(value="bossPool")
            Executor bossPool,
            ThroughputCounter throughputCounter,
            ConnectionCounter connectionCounter,
            LocalMetricRegistry localRegistry)

TcpTransport

protected TcpTransport(Configuration configuration,
            Executor bossPool,
            Executor workerPool,
            ThroughputCounter throughputCounter,
            ConnectionCounter connectionCounter,
            LocalMetricRegistry localRegistry)

Method Detail

getBootstrap

protected org.jboss.netty.bootstrap.Bootstrap getBootstrap()

Overrides:

getBootstrap in class AbstractTcpTransport

getFinalChannelHandlers

protected LinkedHashMap<String,Callable<? extends org.jboss.netty.channel.ChannelHandler>> getFinalChannelHandlers(MessageInput input)

Overrides:

getFinalChannelHandlers in class NettyTransport