Package org.graylog2.inputs.transports

Class AbstractHttpTransport

java.lang.Object

org.graylog2.plugin.inputs.transports.NettyTransport

org.graylog2.plugin.inputs.transports.AbstractTcpTransport

org.graylog2.inputs.transports.AbstractHttpTransport

All Implemented Interfaces:

Transport

Direct Known Subclasses:

HttpTransport, RawHttpTransport

public abstract class AbstractHttpTransport
extends AbstractTcpTransport

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	AbstractHttpTransport.Config

Nested classes/interfaces inherited from interface org.graylog2.plugin.inputs.transports.Transport

Transport.Factory<T extends Transport>

Field Summary

Fields

Modifier and Type	Field	Description
protected static final int	DEFAULT_MAX_CHUNK_SIZE
protected final boolean	enableBulkReceiving
protected final boolean	enableCors
protected final int	maxChunkSize

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

childEventLoopGroup, configuration, parentEventLoopGroup

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

CK_BIND_ADDRESS, CK_NUMBER_WORKER_THREADS, CK_PORT, CK_RECV_BUFFER_SIZE, eventLoopGroupFactory, localRegistry, socketAddress, throughputCounter, workerThreads

Constructor Summary

Constructors

Constructor	Description
AbstractHttpTransport(Configuration configuration, io.netty.channel.EventLoopGroup eventLoopGroup, EventLoopGroupFactory eventLoopGroupFactory, NettyTransportConfiguration nettyTransportConfiguration, ThroughputCounter throughputCounter, LocalMetricRegistry localRegistry, TLSProtocolsConfiguration tlsConfiguration, String path)

Method Summary

Modifier and Type	Method	Description
protected LinkedHashMap<String,Callable<? extends io.netty.channel.ChannelHandler>>	getCustomChildChannelHandlers(MessageInput input)	Subclasses can override this to modify the channel handlers at the end of the pipeline for child channels.
void	launch(MessageInput input, InputFailureRecorder inputFailureRecorder)
protected static int	parseMaxChunkSize(Configuration configuration)

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

getBootstrap, getChildChannelHandlers, getLocalAddress, launch, stop

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

getAggregator, getChannelHandlers, getChannelInitializer, getMetricSet, getRecvBufferSize, setMessageAggregator

Methods inherited from class java.lang.Object

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

Field Details

DEFAULT_MAX_CHUNK_SIZE

protected static final int DEFAULT_MAX_CHUNK_SIZE

enableBulkReceiving

protected final boolean enableBulkReceiving

enableCors

protected final boolean enableCors

maxChunkSize

protected final int maxChunkSize

Constructor Details

AbstractHttpTransport

public AbstractHttpTransport(Configuration configuration,
 io.netty.channel.EventLoopGroup eventLoopGroup,
 EventLoopGroupFactory eventLoopGroupFactory,
 NettyTransportConfiguration nettyTransportConfiguration,
 ThroughputCounter throughputCounter,
 LocalMetricRegistry localRegistry,
 TLSProtocolsConfiguration tlsConfiguration,
 String path)

Method Details

parseMaxChunkSize

protected static int parseMaxChunkSize(Configuration configuration)

Returns:

If the configured Max Chunk Size is less than zero, return DEFAULT_MAX_CHUNK_SIZE.

getCustomChildChannelHandlers

protected LinkedHashMap<String,Callable<? extends io.netty.channel.ChannelHandler>> getCustomChildChannelHandlers(MessageInput input)

Description copied from class: NettyTransport

Subclasses can override this to modify the channel handlers at the end of the pipeline for child channels.

Overrides:

getCustomChildChannelHandlers in class NettyTransport

Parameters:

input - The MessageInput for which these child channel handlers are being added

Returns:

list of custom channel handlers to add to the Netty channel pipeline for child channels

launch

public void launch(MessageInput input,
 @Nullable
 InputFailureRecorder inputFailureRecorder)
            throws MisfireException

Throws:

MisfireException