default NettyComponentBuilderFactory.NettyComponentBuilder |
NettyComponentBuilderFactory.NettyComponentBuilder.allowDefaultCodec(boolean allowDefaultCodec) |
The netty component installs a default codec if both, encoder/decoder
is null and textline is false.
|
default NettyComponentBuilderFactory.NettyComponentBuilder |
NettyComponentBuilderFactory.NettyComponentBuilder.allowSerializedHeaders(boolean allowSerializedHeaders) |
Only used for TCP when transferExchange is true.
|
default NettyComponentBuilderFactory.NettyComponentBuilder |
NettyComponentBuilderFactory.NettyComponentBuilder.autoAppendDelimiter(boolean autoAppendDelimiter) |
Whether or not to auto append missing end delimiter when sending
using the textline codec.
|
default NettyComponentBuilderFactory.NettyComponentBuilder |
NettyComponentBuilderFactory.NettyComponentBuilder.autowiredEnabled(boolean autowiredEnabled) |
Whether autowiring is enabled.
|
default NettyComponentBuilderFactory.NettyComponentBuilder |
NettyComponentBuilderFactory.NettyComponentBuilder.backlog(int backlog) |
Allows to configure a backlog for netty consumer (server).
|
default NettyComponentBuilderFactory.NettyComponentBuilder |
NettyComponentBuilderFactory.NettyComponentBuilder.bossCount(int bossCount) |
When netty works on nio mode, it uses default bossCount parameter
from Netty, which is 1.
|
default NettyComponentBuilderFactory.NettyComponentBuilder |
NettyComponentBuilderFactory.NettyComponentBuilder.bossGroup(io.netty.channel.EventLoopGroup bossGroup) |
Set the BossGroup which could be used for handling the new connection
of the server side across the NettyEndpoint.
|
default NettyComponentBuilderFactory.NettyComponentBuilder |
NettyComponentBuilderFactory.NettyComponentBuilder.bridgeErrorHandler(boolean bridgeErrorHandler) |
Allows for bridging the consumer to the Camel routing Error Handler,
which mean any exceptions occurred while the consumer is trying to
pickup incoming messages, or the likes, will now be processed as a
message and handled by the routing Error Handler.
|
default NettyComponentBuilderFactory.NettyComponentBuilder |
NettyComponentBuilderFactory.NettyComponentBuilder.broadcast(boolean broadcast) |
Setting to choose Multicast over UDP.
|
default NettyComponentBuilderFactory.NettyComponentBuilder |
NettyComponentBuilderFactory.NettyComponentBuilder.channelGroup(io.netty.channel.group.ChannelGroup channelGroup) |
To use a explicit ChannelGroup.
|
default NettyComponentBuilderFactory.NettyComponentBuilder |
NettyComponentBuilderFactory.NettyComponentBuilder.clientInitializerFactory(org.apache.camel.component.netty.ClientInitializerFactory clientInitializerFactory) |
To use a custom ClientInitializerFactory.
|
default NettyComponentBuilderFactory.NettyComponentBuilder |
NettyComponentBuilderFactory.NettyComponentBuilder.clientMode(boolean clientMode) |
If the clientMode is true, netty consumer will connect the address as
a TCP client.
|
default NettyComponentBuilderFactory.NettyComponentBuilder |
NettyComponentBuilderFactory.NettyComponentBuilder.configuration(org.apache.camel.component.netty.NettyConfiguration configuration) |
To use the NettyConfiguration as configuration when creating
endpoints.
|
default NettyComponentBuilderFactory.NettyComponentBuilder |
NettyComponentBuilderFactory.NettyComponentBuilder.connectTimeout(int connectTimeout) |
Time to wait for a socket connection to be available.
|
default NettyComponentBuilderFactory.NettyComponentBuilder |
NettyComponentBuilderFactory.NettyComponentBuilder.correlationManager(org.apache.camel.component.netty.NettyCamelStateCorrelationManager correlationManager) |
To use a custom correlation manager to manage how request and reply
messages are mapped when using request/reply with the netty producer.
|
default NettyComponentBuilderFactory.NettyComponentBuilder |
NettyComponentBuilderFactory.NettyComponentBuilder.decoderMaxLineLength(int decoderMaxLineLength) |
The max line length to use for the textline codec.
|
default NettyComponentBuilderFactory.NettyComponentBuilder |
NettyComponentBuilderFactory.NettyComponentBuilder.decoders(List<io.netty.channel.ChannelHandler> decoders) |
A list of decoders to be used.
|
default NettyComponentBuilderFactory.NettyComponentBuilder |
NettyComponentBuilderFactory.NettyComponentBuilder.delimiter(org.apache.camel.component.netty.TextLineDelimiter delimiter) |
The delimiter to use for the textline codec.
|
default NettyComponentBuilderFactory.NettyComponentBuilder |
NettyComponentBuilderFactory.NettyComponentBuilder.disconnect(boolean disconnect) |
Whether or not to disconnect(close) from Netty Channel right after
use.
|
default NettyComponentBuilderFactory.NettyComponentBuilder |
NettyComponentBuilderFactory.NettyComponentBuilder.disconnectOnNoReply(boolean disconnectOnNoReply) |
If sync is enabled then this option dictates NettyConsumer if it
should disconnect where there is no reply to send back.
|
default NettyComponentBuilderFactory.NettyComponentBuilder |
NettyComponentBuilderFactory.NettyComponentBuilder.enabledProtocols(String enabledProtocols) |
Which protocols to enable when using SSL.
|
default NettyComponentBuilderFactory.NettyComponentBuilder |
NettyComponentBuilderFactory.NettyComponentBuilder.encoders(List<io.netty.channel.ChannelHandler> encoders) |
A list of encoders to be used.
|
default NettyComponentBuilderFactory.NettyComponentBuilder |
NettyComponentBuilderFactory.NettyComponentBuilder.encoding(String encoding) |
The encoding (a charset name) to use for the textline codec.
|
default NettyComponentBuilderFactory.NettyComponentBuilder |
NettyComponentBuilderFactory.NettyComponentBuilder.executorService(io.netty.util.concurrent.EventExecutorGroup executorService) |
To use the given EventExecutorGroup.
|
default NettyComponentBuilderFactory.NettyComponentBuilder |
NettyComponentBuilderFactory.NettyComponentBuilder.hostnameVerification(boolean hostnameVerification) |
To enable/disable hostname verification on SSLEngine.
|
default NettyComponentBuilderFactory.NettyComponentBuilder |
NettyComponentBuilderFactory.NettyComponentBuilder.keepAlive(boolean keepAlive) |
Setting to ensure socket is not closed due to inactivity.
|
default NettyComponentBuilderFactory.NettyComponentBuilder |
NettyComponentBuilderFactory.NettyComponentBuilder.keyStoreFile(File keyStoreFile) |
Client side certificate keystore to be used for encryption.
|
default NettyComponentBuilderFactory.NettyComponentBuilder |
NettyComponentBuilderFactory.NettyComponentBuilder.keyStoreFormat(String keyStoreFormat) |
Keystore format to be used for payload encryption.
|
default NettyComponentBuilderFactory.NettyComponentBuilder |
NettyComponentBuilderFactory.NettyComponentBuilder.keyStoreResource(String keyStoreResource) |
Client side certificate keystore to be used for encryption.
|
default NettyComponentBuilderFactory.NettyComponentBuilder |
NettyComponentBuilderFactory.NettyComponentBuilder.lazyChannelCreation(boolean lazyChannelCreation) |
Channels can be lazily created to avoid exceptions, if the remote
server is not up and running when the Camel producer is started.
|
default NettyComponentBuilderFactory.NettyComponentBuilder |
NettyComponentBuilderFactory.NettyComponentBuilder.lazyStartProducer(boolean lazyStartProducer) |
Whether the producer should be started lazy (on the first message).
|
default NettyComponentBuilderFactory.NettyComponentBuilder |
NettyComponentBuilderFactory.NettyComponentBuilder.maximumPoolSize(int maximumPoolSize) |
Sets a maximum thread pool size for the netty consumer ordered thread
pool.
|
default NettyComponentBuilderFactory.NettyComponentBuilder |
NettyComponentBuilderFactory.NettyComponentBuilder.nativeTransport(boolean nativeTransport) |
Whether to use native transport instead of NIO.
|
default NettyComponentBuilderFactory.NettyComponentBuilder |
NettyComponentBuilderFactory.NettyComponentBuilder.needClientAuth(boolean needClientAuth) |
Configures whether the server needs client authentication when using
SSL.
|
static NettyComponentBuilderFactory.NettyComponentBuilder |
NettyComponentBuilderFactory.netty() |
Netty (camel-netty)
Socket level networking using TCP or UDP with the Netty 4.x.
|
default NettyComponentBuilderFactory.NettyComponentBuilder |
NettyComponentBuilderFactory.NettyComponentBuilder.nettyServerBootstrapFactory(org.apache.camel.component.netty.NettyServerBootstrapFactory nettyServerBootstrapFactory) |
To use a custom NettyServerBootstrapFactory.
|
default NettyComponentBuilderFactory.NettyComponentBuilder |
NettyComponentBuilderFactory.NettyComponentBuilder.networkInterface(String networkInterface) |
When using UDP then this option can be used to specify a network
interface by its name, such as eth0 to join a multicast group.
|
default NettyComponentBuilderFactory.NettyComponentBuilder |
NettyComponentBuilderFactory.NettyComponentBuilder.noReplyLogLevel(org.apache.camel.LoggingLevel noReplyLogLevel) |
If sync is enabled this option dictates NettyConsumer which logging
level to use when logging a there is no reply to send back.
|
default NettyComponentBuilderFactory.NettyComponentBuilder |
NettyComponentBuilderFactory.NettyComponentBuilder.options(Map<String,Object> options) |
Allows to configure additional netty options using option.
|
default NettyComponentBuilderFactory.NettyComponentBuilder |
NettyComponentBuilderFactory.NettyComponentBuilder.passphrase(String passphrase) |
Password setting to use in order to encrypt/decrypt payloads sent
using SSH.
|
default NettyComponentBuilderFactory.NettyComponentBuilder |
NettyComponentBuilderFactory.NettyComponentBuilder.producerPoolEnabled(boolean producerPoolEnabled) |
Whether producer pool is enabled or not.
|
default NettyComponentBuilderFactory.NettyComponentBuilder |
NettyComponentBuilderFactory.NettyComponentBuilder.producerPoolMaxActive(int producerPoolMaxActive) |
Sets the cap on the number of objects that can be allocated by the
pool (checked out to clients, or idle awaiting checkout) at a given
time.
|
default NettyComponentBuilderFactory.NettyComponentBuilder |
NettyComponentBuilderFactory.NettyComponentBuilder.producerPoolMaxIdle(int producerPoolMaxIdle) |
Sets the cap on the number of idle instances in the pool.
|
default NettyComponentBuilderFactory.NettyComponentBuilder |
NettyComponentBuilderFactory.NettyComponentBuilder.producerPoolMinEvictableIdle(long producerPoolMinEvictableIdle) |
Sets the minimum amount of time (value in millis) an object may sit
idle in the pool before it is eligible for eviction by the idle
object evictor.
|
default NettyComponentBuilderFactory.NettyComponentBuilder |
NettyComponentBuilderFactory.NettyComponentBuilder.producerPoolMinIdle(int producerPoolMinIdle) |
Sets the minimum number of instances allowed in the producer pool
before the evictor thread (if active) spawns new objects.
|
default NettyComponentBuilderFactory.NettyComponentBuilder |
NettyComponentBuilderFactory.NettyComponentBuilder.receiveBufferSize(int receiveBufferSize) |
The TCP/UDP buffer sizes to be used during inbound communication.
|
default NettyComponentBuilderFactory.NettyComponentBuilder |
NettyComponentBuilderFactory.NettyComponentBuilder.receiveBufferSizePredictor(int receiveBufferSizePredictor) |
Configures the buffer size predictor.
|
default NettyComponentBuilderFactory.NettyComponentBuilder |
NettyComponentBuilderFactory.NettyComponentBuilder.reconnect(boolean reconnect) |
Used only in clientMode in consumer, the consumer will attempt to
reconnect on disconnection if this is enabled.
|
default NettyComponentBuilderFactory.NettyComponentBuilder |
NettyComponentBuilderFactory.NettyComponentBuilder.reconnectInterval(int reconnectInterval) |
Used if reconnect and clientMode is enabled.
|
default NettyComponentBuilderFactory.NettyComponentBuilder |
NettyComponentBuilderFactory.NettyComponentBuilder.requestTimeout(long requestTimeout) |
Allows to use a timeout for the Netty producer when calling a remote
server.
|
default NettyComponentBuilderFactory.NettyComponentBuilder |
NettyComponentBuilderFactory.NettyComponentBuilder.reuseAddress(boolean reuseAddress) |
Setting to facilitate socket multiplexing.
|
default NettyComponentBuilderFactory.NettyComponentBuilder |
NettyComponentBuilderFactory.NettyComponentBuilder.reuseChannel(boolean reuseChannel) |
This option allows producers and consumers (in client mode) to reuse
the same Netty Channel for the lifecycle of processing the Exchange.
|
default NettyComponentBuilderFactory.NettyComponentBuilder |
NettyComponentBuilderFactory.NettyComponentBuilder.securityProvider(String securityProvider) |
Security provider to be used for payload encryption.
|
default NettyComponentBuilderFactory.NettyComponentBuilder |
NettyComponentBuilderFactory.NettyComponentBuilder.sendBufferSize(int sendBufferSize) |
The TCP/UDP buffer sizes to be used during outbound communication.
|
default NettyComponentBuilderFactory.NettyComponentBuilder |
NettyComponentBuilderFactory.NettyComponentBuilder.serverClosedChannelExceptionCaughtLogLevel(org.apache.camel.LoggingLevel serverClosedChannelExceptionCaughtLogLevel) |
If the server (NettyConsumer) catches an
java.nio.channels.ClosedChannelException then its logged using this
logging level.
|
default NettyComponentBuilderFactory.NettyComponentBuilder |
NettyComponentBuilderFactory.NettyComponentBuilder.serverExceptionCaughtLogLevel(org.apache.camel.LoggingLevel serverExceptionCaughtLogLevel) |
If the server (NettyConsumer) catches an exception then its logged
using this logging level.
|
default NettyComponentBuilderFactory.NettyComponentBuilder |
NettyComponentBuilderFactory.NettyComponentBuilder.serverInitializerFactory(org.apache.camel.component.netty.ServerInitializerFactory serverInitializerFactory) |
To use a custom ServerInitializerFactory.
|
default NettyComponentBuilderFactory.NettyComponentBuilder |
NettyComponentBuilderFactory.NettyComponentBuilder.ssl(boolean ssl) |
Setting to specify whether SSL encryption is applied to this
endpoint.
|
default NettyComponentBuilderFactory.NettyComponentBuilder |
NettyComponentBuilderFactory.NettyComponentBuilder.sslClientCertHeaders(boolean sslClientCertHeaders) |
When enabled and in SSL mode, then the Netty consumer will enrich the
Camel Message with headers having information about the client
certificate such as subject name, issuer name, serial number, and the
valid date range.
|
default NettyComponentBuilderFactory.NettyComponentBuilder |
NettyComponentBuilderFactory.NettyComponentBuilder.sslContextParameters(org.apache.camel.support.jsse.SSLContextParameters sslContextParameters) |
To configure security using SSLContextParameters.
|
default NettyComponentBuilderFactory.NettyComponentBuilder |
NettyComponentBuilderFactory.NettyComponentBuilder.sslHandler(io.netty.handler.ssl.SslHandler sslHandler) |
Reference to a class that could be used to return an SSL Handler.
|
default NettyComponentBuilderFactory.NettyComponentBuilder |
NettyComponentBuilderFactory.NettyComponentBuilder.sync(boolean sync) |
Setting to set endpoint as one-way or request-response.
|
default NettyComponentBuilderFactory.NettyComponentBuilder |
NettyComponentBuilderFactory.NettyComponentBuilder.tcpNoDelay(boolean tcpNoDelay) |
Setting to improve TCP protocol performance.
|
default NettyComponentBuilderFactory.NettyComponentBuilder |
NettyComponentBuilderFactory.NettyComponentBuilder.textline(boolean textline) |
Only used for TCP.
|
default NettyComponentBuilderFactory.NettyComponentBuilder |
NettyComponentBuilderFactory.NettyComponentBuilder.transferExchange(boolean transferExchange) |
Only used for TCP.
|
default NettyComponentBuilderFactory.NettyComponentBuilder |
NettyComponentBuilderFactory.NettyComponentBuilder.trustStoreFile(File trustStoreFile) |
Server side certificate keystore to be used for encryption.
|
default NettyComponentBuilderFactory.NettyComponentBuilder |
NettyComponentBuilderFactory.NettyComponentBuilder.trustStoreResource(String trustStoreResource) |
Server side certificate keystore to be used for encryption.
|
default NettyComponentBuilderFactory.NettyComponentBuilder |
NettyComponentBuilderFactory.NettyComponentBuilder.udpByteArrayCodec(boolean udpByteArrayCodec) |
For UDP only.
|
default NettyComponentBuilderFactory.NettyComponentBuilder |
NettyComponentBuilderFactory.NettyComponentBuilder.udpConnectionlessSending(boolean udpConnectionlessSending) |
This option supports connection less udp sending which is a real fire
and forget.
|
default NettyComponentBuilderFactory.NettyComponentBuilder |
NettyComponentBuilderFactory.NettyComponentBuilder.useByteBuf(boolean useByteBuf) |
If the useByteBuf is true, netty producer will turn the message body
into ByteBuf before sending it out.
|
default NettyComponentBuilderFactory.NettyComponentBuilder |
NettyComponentBuilderFactory.NettyComponentBuilder.useGlobalSslContextParameters(boolean useGlobalSslContextParameters) |
Enable usage of global SSL context parameters.
|
default NettyComponentBuilderFactory.NettyComponentBuilder |
NettyComponentBuilderFactory.NettyComponentBuilder.usingExecutorService(boolean usingExecutorService) |
Whether to use ordered thread pool, to ensure events are processed
orderly on the same channel.
|
default NettyComponentBuilderFactory.NettyComponentBuilder |
NettyComponentBuilderFactory.NettyComponentBuilder.workerCount(int workerCount) |
When netty works on nio mode, it uses default workerCount parameter
from Netty (which is cpu_core_threads x 2).
|
default NettyComponentBuilderFactory.NettyComponentBuilder |
NettyComponentBuilderFactory.NettyComponentBuilder.workerGroup(io.netty.channel.EventLoopGroup workerGroup) |
To use a explicit EventLoopGroup as the boss thread pool.
|