org.graylog2.inputs.transports

Class SyslogTcpTransport

java.lang.Object

org.graylog2.plugin.inputs.transports.NettyTransport

org.graylog2.plugin.inputs.transports.AbstractTcpTransport

org.graylog2.inputs.transports.TcpTransport

org.graylog2.inputs.transports.SyslogTcpTransport

All Implemented Interfaces:

Transport

public class SyslogTcpTransport
extends TcpTransport

Nested Class Summary

Nested Classes

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

Field Summary

Fields inherited from class org.graylog2.inputs.transports.TcpTransport

CK_USE_NULL_DELIMITER, delimiter, 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

Constructor and Description
SyslogTcpTransport(Configuration configuration, Executor bossPool, ThroughputCounter throughputCounter, ConnectionCounter connectionCounter, LocalMetricRegistry localRegistry)

Method Summary

Methods

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

Methods inherited from class org.graylog2.inputs.transports.TcpTransport

getBootstrap

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

Constructor Detail

SyslogTcpTransport

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

Method Detail

getFinalChannelHandlers

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

Overrides:

getFinalChannelHandlers in class TcpTransport