public class TcpTransport extends AbstractTcpTransport
| Modifier and Type | Class and Description |
|---|---|
static class |
TcpTransport.Config |
static interface |
TcpTransport.Factory |
| Modifier and Type | Field and Description |
|---|---|
static String |
CK_USE_NULL_DELIMITER |
protected io.netty.buffer.ByteBuf[] |
delimiter |
protected int |
maxFrameLength |
childEventLoopGroup, configuration, parentEventLoopGroupCK_BIND_ADDRESS, CK_NUMBER_WORKER_THREADS, CK_PORT, CK_RECV_BUFFER_SIZE, eventLoopGroupFactory, localRegistry, socketAddress, throughputCounter, workerThreads| Constructor and Description |
|---|
TcpTransport(Configuration configuration,
io.netty.channel.EventLoopGroup eventLoopGroup,
EventLoopGroupFactory eventLoopGroupFactory,
NettyTransportConfiguration nettyTransportConfiguration,
ThroughputCounter throughputCounter,
LocalMetricRegistry localRegistry,
TLSProtocolsConfiguration tlsConfiguration) |
| Modifier and Type | Method and 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. |
getBootstrap, getChildChannelHandlers, getLocalAddress, launch, stopgetAggregator, getChannelHandlers, getChannelInitializer, getMetricSet, getRecvBufferSize, setMessageAggregatorpublic static final String CK_USE_NULL_DELIMITER
protected final io.netty.buffer.ByteBuf[] delimiter
protected final int maxFrameLength
public TcpTransport(Configuration configuration, io.netty.channel.EventLoopGroup eventLoopGroup, EventLoopGroupFactory eventLoopGroupFactory, NettyTransportConfiguration nettyTransportConfiguration, ThroughputCounter throughputCounter, LocalMetricRegistry localRegistry, TLSProtocolsConfiguration tlsConfiguration)
protected LinkedHashMap<String,Callable<? extends io.netty.channel.ChannelHandler>> getCustomChildChannelHandlers(MessageInput input)
NettyTransportchannel handlers at the end of the pipeline for child channels.getCustomChildChannelHandlers in class NettyTransportinput - The MessageInput for which these child channel handlers are being addedchannel handlers to add to the Netty channel pipeline for child channelsCopyright © 2012–2022 Graylog, Inc.. All rights reserved.