Interface NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder
-
- All Superinterfaces:
org.apache.camel.builder.EndpointConsumerBuilder
,org.apache.camel.EndpointConsumerResolver
- All Known Subinterfaces:
NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointBuilder
- Enclosing interface:
- NettyHttpEndpointBuilderFactory
public static interface NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder extends org.apache.camel.builder.EndpointConsumerBuilder
Advanced builder for endpoint consumers for the Netty HTTP component.
-
-
Method Summary
All Methods Instance Methods Default Methods Modifier and Type Method Description default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder
allowSerializedHeaders(boolean allowSerializedHeaders)
Only used for TCP when transferExchange is true.default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder
allowSerializedHeaders(String allowSerializedHeaders)
Only used for TCP when transferExchange is true.default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder
backlog(int backlog)
Allows to configure a backlog for netty consumer (server).default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder
backlog(String backlog)
Allows to configure a backlog for netty consumer (server).default NettyHttpEndpointBuilderFactory.NettyHttpEndpointConsumerBuilder
basic()
default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder
bossCount(int bossCount)
When netty works on nio mode, it uses default bossCount parameter from Netty, which is 1.default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder
bossCount(String bossCount)
When netty works on nio mode, it uses default bossCount parameter from Netty, which is 1.default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder
bossGroup(Object bossGroup)
Set the BossGroup which could be used for handling the new connection of the server side across the NettyEndpoint.default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder
bossGroup(String bossGroup)
Set the BossGroup which could be used for handling the new connection of the server side across the NettyEndpoint.default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder
channelGroup(Object channelGroup)
To use a explicit ChannelGroup.default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder
channelGroup(String channelGroup)
To use a explicit ChannelGroup.default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder
chunkedMaxContentLength(int chunkedMaxContentLength)
Value in bytes the max content length per chunked frame received on the Netty HTTP server.default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder
chunkedMaxContentLength(String chunkedMaxContentLength)
Value in bytes the max content length per chunked frame received on the Netty HTTP server.default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder
compression(boolean compression)
Allow using gzip/deflate for compression on the Netty HTTP server if the client supports it from the HTTP headers.default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder
compression(String compression)
Allow using gzip/deflate for compression on the Netty HTTP server if the client supports it from the HTTP headers.default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder
configuration(Object configuration)
To use a custom configured NettyHttpConfiguration for configuring this endpoint.default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder
configuration(String configuration)
To use a custom configured NettyHttpConfiguration for configuring this endpoint.default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder
disableStreamCache(boolean disableStreamCache)
Determines whether or not the raw input stream from Netty HttpRequest#getContent() or HttpResponset#getContent() is cached or not (Camel will read the stream into a in light-weight memory based Stream caching) cache.default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder
disableStreamCache(String disableStreamCache)
Determines whether or not the raw input stream from Netty HttpRequest#getContent() or HttpResponset#getContent() is cached or not (Camel will read the stream into a in light-weight memory based Stream caching) cache.default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder
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 NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder
disconnectOnNoReply(String disconnectOnNoReply)
If sync is enabled then this option dictates NettyConsumer if it should disconnect where there is no reply to send back.default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder
exceptionHandler(String exceptionHandler)
To let the consumer use a custom ExceptionHandler.default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder
exceptionHandler(org.apache.camel.spi.ExceptionHandler exceptionHandler)
To let the consumer use a custom ExceptionHandler.default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder
exchangePattern(String exchangePattern)
Sets the exchange pattern when the consumer creates an exchange.default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder
exchangePattern(org.apache.camel.ExchangePattern exchangePattern)
Sets the exchange pattern when the consumer creates an exchange.default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder
headerFilterStrategy(String headerFilterStrategy)
To use a custom org.apache.camel.spi.HeaderFilterStrategy to filter headers.default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder
headerFilterStrategy(org.apache.camel.spi.HeaderFilterStrategy headerFilterStrategy)
To use a custom org.apache.camel.spi.HeaderFilterStrategy to filter headers.default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder
httpMethodRestrict(String httpMethodRestrict)
To disable HTTP methods on the Netty HTTP consumer.default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder
logWarnOnBadRequest(boolean logWarnOnBadRequest)
Whether Netty HTTP server should log a WARN if decoding the HTTP request failed and a HTTP Status 400 (bad request) is returned.default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder
logWarnOnBadRequest(String logWarnOnBadRequest)
Whether Netty HTTP server should log a WARN if decoding the HTTP request failed and a HTTP Status 400 (bad request) is returned.default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder
mapHeaders(boolean mapHeaders)
If this option is enabled, then during binding from Netty to Camel Message then the headers will be mapped as well (eg added as header to the Camel Message as well).default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder
mapHeaders(String mapHeaders)
If this option is enabled, then during binding from Netty to Camel Message then the headers will be mapped as well (eg added as header to the Camel Message as well).default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder
maxHeaderSize(int maxHeaderSize)
The maximum length of all headers.default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder
maxHeaderSize(String maxHeaderSize)
The maximum length of all headers.default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder
nativeTransport(boolean nativeTransport)
Whether to use native transport instead of NIO.default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder
nativeTransport(String nativeTransport)
Whether to use native transport instead of NIO.default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder
nettyHttpBinding(Object nettyHttpBinding)
To use a custom org.apache.camel.component.netty.http.NettyHttpBinding for binding to/from Netty and Camel Message API.default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder
nettyHttpBinding(String nettyHttpBinding)
To use a custom org.apache.camel.component.netty.http.NettyHttpBinding for binding to/from Netty and Camel Message API.default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder
nettyServerBootstrapFactory(Object nettyServerBootstrapFactory)
To use a custom NettyServerBootstrapFactory.default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder
nettyServerBootstrapFactory(String nettyServerBootstrapFactory)
To use a custom NettyServerBootstrapFactory.default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder
nettySharedHttpServer(Object nettySharedHttpServer)
To use a shared Netty HTTP server.default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder
nettySharedHttpServer(String nettySharedHttpServer)
To use a shared Netty HTTP server.default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder
noReplyLogLevel(String 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 NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder
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 NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder
options(String key, Object value)
Allows to configure additional netty options using option.default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder
options(Map values)
Allows to configure additional netty options using option.default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder
receiveBufferSize(int receiveBufferSize)
The TCP/UDP buffer sizes to be used during inbound communication.default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder
receiveBufferSize(String receiveBufferSize)
The TCP/UDP buffer sizes to be used during inbound communication.default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder
receiveBufferSizePredictor(int receiveBufferSizePredictor)
Configures the buffer size predictor.default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder
receiveBufferSizePredictor(String receiveBufferSizePredictor)
Configures the buffer size predictor.default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder
sendBufferSize(int sendBufferSize)
The TCP/UDP buffer sizes to be used during outbound communication.default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder
sendBufferSize(String sendBufferSize)
The TCP/UDP buffer sizes to be used during outbound communication.default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder
serverClosedChannelExceptionCaughtLogLevel(String serverClosedChannelExceptionCaughtLogLevel)
If the server (NettyConsumer) catches an java.nio.channels.ClosedChannelException then its logged using this logging level.default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder
serverClosedChannelExceptionCaughtLogLevel(org.apache.camel.LoggingLevel serverClosedChannelExceptionCaughtLogLevel)
If the server (NettyConsumer) catches an java.nio.channels.ClosedChannelException then its logged using this logging level.default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder
serverExceptionCaughtLogLevel(String serverExceptionCaughtLogLevel)
If the server (NettyConsumer) catches an exception then its logged using this logging level.default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder
serverExceptionCaughtLogLevel(org.apache.camel.LoggingLevel serverExceptionCaughtLogLevel)
If the server (NettyConsumer) catches an exception then its logged using this logging level.default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder
serverInitializerFactory(Object serverInitializerFactory)
To use a custom ServerInitializerFactory.default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder
serverInitializerFactory(String serverInitializerFactory)
To use a custom ServerInitializerFactory.default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder
synchronous(boolean synchronous)
Sets whether synchronous processing should be strictly used, or Camel is allowed to use asynchronous processing (if supported).default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder
synchronous(String synchronous)
Sets whether synchronous processing should be strictly used, or Camel is allowed to use asynchronous processing (if supported).default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder
traceEnabled(boolean traceEnabled)
Specifies whether to enable HTTP TRACE for this Netty HTTP consumer.default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder
traceEnabled(String traceEnabled)
Specifies whether to enable HTTP TRACE for this Netty HTTP consumer.default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder
transferException(boolean transferException)
If enabled and an Exchange failed processing on the consumer side, and if the caused Exception was send back serialized in the response as a application/x-java-serialized-object content type.default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder
transferException(String transferException)
If enabled and an Exchange failed processing on the consumer side, and if the caused Exception was send back serialized in the response as a application/x-java-serialized-object content type.default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder
transferExchange(boolean transferExchange)
Only used for TCP.default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder
transferExchange(String transferExchange)
Only used for TCP.default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder
urlDecodeHeaders(boolean urlDecodeHeaders)
If this option is enabled, then during binding from Netty to Camel Message then the header values will be URL decoded (eg %20 will be a space character.default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder
urlDecodeHeaders(String urlDecodeHeaders)
If this option is enabled, then during binding from Netty to Camel Message then the header values will be URL decoded (eg %20 will be a space character.default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder
usingExecutorService(boolean usingExecutorService)
Whether to use ordered thread pool, to ensure events are processed orderly on the same channel.default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder
usingExecutorService(String usingExecutorService)
Whether to use ordered thread pool, to ensure events are processed orderly on the same channel.default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder
workerCount(int workerCount)
When netty works on nio mode, it uses default workerCount parameter from Netty (which is cpu_core_threads x 2).default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder
workerCount(String workerCount)
When netty works on nio mode, it uses default workerCount parameter from Netty (which is cpu_core_threads x 2).default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder
workerGroup(Object workerGroup)
To use a explicit EventLoopGroup as the boss thread pool.default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder
workerGroup(String workerGroup)
To use a explicit EventLoopGroup as the boss thread pool.
-
-
-
Method Detail
-
basic
default NettyHttpEndpointBuilderFactory.NettyHttpEndpointConsumerBuilder basic()
-
backlog
default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder backlog(int backlog)
Allows to configure a backlog for netty consumer (server). Note the backlog is just a best effort depending on the OS. Setting this option to a value such as 200, 500 or 1000, tells the TCP stack how long the accept queue can be If this option is not configured, then the backlog depends on OS setting. The option is a:int
type. Group: consumer (advanced)
-
backlog
default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder backlog(String backlog)
Allows to configure a backlog for netty consumer (server). Note the backlog is just a best effort depending on the OS. Setting this option to a value such as 200, 500 or 1000, tells the TCP stack how long the accept queue can be If this option is not configured, then the backlog depends on OS setting. The option will be converted to aint
type. Group: consumer (advanced)
-
bossCount
default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder bossCount(int bossCount)
When netty works on nio mode, it uses default bossCount parameter from Netty, which is 1. User can use this option to override the default bossCount from Netty. The option is a:int
type. Default: 1 Group: consumer (advanced)
-
bossCount
default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder bossCount(String bossCount)
When netty works on nio mode, it uses default bossCount parameter from Netty, which is 1. User can use this option to override the default bossCount from Netty. The option will be converted to aint
type. Default: 1 Group: consumer (advanced)
-
bossGroup
default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder bossGroup(Object bossGroup)
Set the BossGroup which could be used for handling the new connection of the server side across the NettyEndpoint. The option is a:io.netty.channel.EventLoopGroup
type. Group: consumer (advanced)
-
bossGroup
default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder bossGroup(String bossGroup)
Set the BossGroup which could be used for handling the new connection of the server side across the NettyEndpoint. The option will be converted to aio.netty.channel.EventLoopGroup
type. Group: consumer (advanced)
-
chunkedMaxContentLength
default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder chunkedMaxContentLength(int chunkedMaxContentLength)
Value in bytes the max content length per chunked frame received on the Netty HTTP server. The option is a:int
type. Default: 1048576 Group: consumer (advanced)
-
chunkedMaxContentLength
default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder chunkedMaxContentLength(String chunkedMaxContentLength)
Value in bytes the max content length per chunked frame received on the Netty HTTP server. The option will be converted to aint
type. Default: 1048576 Group: consumer (advanced)
-
compression
default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder compression(boolean compression)
Allow using gzip/deflate for compression on the Netty HTTP server if the client supports it from the HTTP headers. The option is a:boolean
type. Default: false Group: consumer (advanced)
-
compression
default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder compression(String compression)
Allow using gzip/deflate for compression on the Netty HTTP server if the client supports it from the HTTP headers. The option will be converted to aboolean
type. Default: false Group: consumer (advanced)
-
disconnectOnNoReply
default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder disconnectOnNoReply(boolean disconnectOnNoReply)
If sync is enabled then this option dictates NettyConsumer if it should disconnect where there is no reply to send back. The option is a:boolean
type. Default: true Group: consumer (advanced)
-
disconnectOnNoReply
default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder disconnectOnNoReply(String disconnectOnNoReply)
If sync is enabled then this option dictates NettyConsumer if it should disconnect where there is no reply to send back. The option will be converted to aboolean
type. Default: true Group: consumer (advanced)
-
exceptionHandler
default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder exceptionHandler(org.apache.camel.spi.ExceptionHandler exceptionHandler)
To let the consumer use a custom ExceptionHandler. Notice if the option bridgeErrorHandler is enabled then this option is not in use. By default the consumer will deal with exceptions, that will be logged at WARN or ERROR level and ignored. The option is a:org.apache.camel.spi.ExceptionHandler
type. Group: consumer (advanced)
-
exceptionHandler
default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder exceptionHandler(String exceptionHandler)
To let the consumer use a custom ExceptionHandler. Notice if the option bridgeErrorHandler is enabled then this option is not in use. By default the consumer will deal with exceptions, that will be logged at WARN or ERROR level and ignored. The option will be converted to aorg.apache.camel.spi.ExceptionHandler
type. Group: consumer (advanced)
-
exchangePattern
default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder exchangePattern(org.apache.camel.ExchangePattern exchangePattern)
Sets the exchange pattern when the consumer creates an exchange. The option is a:org.apache.camel.ExchangePattern
type. Group: consumer (advanced)
-
exchangePattern
default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder exchangePattern(String exchangePattern)
Sets the exchange pattern when the consumer creates an exchange. The option will be converted to aorg.apache.camel.ExchangePattern
type. Group: consumer (advanced)
-
httpMethodRestrict
default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder httpMethodRestrict(String httpMethodRestrict)
To disable HTTP methods on the Netty HTTP consumer. You can specify multiple separated by comma. The option is a:java.lang.String
type. Group: consumer (advanced)
-
logWarnOnBadRequest
default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder logWarnOnBadRequest(boolean logWarnOnBadRequest)
Whether Netty HTTP server should log a WARN if decoding the HTTP request failed and a HTTP Status 400 (bad request) is returned. The option is a:boolean
type. Default: true Group: consumer (advanced)
-
logWarnOnBadRequest
default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder logWarnOnBadRequest(String logWarnOnBadRequest)
Whether Netty HTTP server should log a WARN if decoding the HTTP request failed and a HTTP Status 400 (bad request) is returned. The option will be converted to aboolean
type. Default: true Group: consumer (advanced)
-
mapHeaders
default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder mapHeaders(boolean mapHeaders)
If this option is enabled, then during binding from Netty to Camel Message then the headers will be mapped as well (eg added as header to the Camel Message as well). You can turn off this option to disable this. The headers can still be accessed from the org.apache.camel.component.netty.http.NettyHttpMessage message with the method getHttpRequest() that returns the Netty HTTP request io.netty.handler.codec.http.HttpRequest instance. The option is a:boolean
type. Default: true Group: consumer (advanced)
-
mapHeaders
default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder mapHeaders(String mapHeaders)
If this option is enabled, then during binding from Netty to Camel Message then the headers will be mapped as well (eg added as header to the Camel Message as well). You can turn off this option to disable this. The headers can still be accessed from the org.apache.camel.component.netty.http.NettyHttpMessage message with the method getHttpRequest() that returns the Netty HTTP request io.netty.handler.codec.http.HttpRequest instance. The option will be converted to aboolean
type. Default: true Group: consumer (advanced)
-
maxHeaderSize
default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder maxHeaderSize(int maxHeaderSize)
The maximum length of all headers. If the sum of the length of each header exceeds this value, a io.netty.handler.codec.TooLongFrameException will be raised. The option is a:int
type. Default: 8192 Group: consumer (advanced)
-
maxHeaderSize
default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder maxHeaderSize(String maxHeaderSize)
The maximum length of all headers. If the sum of the length of each header exceeds this value, a io.netty.handler.codec.TooLongFrameException will be raised. The option will be converted to aint
type. Default: 8192 Group: consumer (advanced)
-
nettyServerBootstrapFactory
default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder nettyServerBootstrapFactory(Object nettyServerBootstrapFactory)
To use a custom NettyServerBootstrapFactory. The option is a:org.apache.camel.component.netty.NettyServerBootstrapFactory
type. Group: consumer (advanced)
-
nettyServerBootstrapFactory
default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder nettyServerBootstrapFactory(String nettyServerBootstrapFactory)
To use a custom NettyServerBootstrapFactory. The option will be converted to aorg.apache.camel.component.netty.NettyServerBootstrapFactory
type. Group: consumer (advanced)
-
nettySharedHttpServer
default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder nettySharedHttpServer(Object nettySharedHttpServer)
To use a shared Netty HTTP server. See Netty HTTP Server Example for more details. The option is a:org.apache.camel.component.netty.http.NettySharedHttpServer
type. Group: consumer (advanced)
-
nettySharedHttpServer
default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder nettySharedHttpServer(String nettySharedHttpServer)
To use a shared Netty HTTP server. See Netty HTTP Server Example for more details. The option will be converted to aorg.apache.camel.component.netty.http.NettySharedHttpServer
type. Group: consumer (advanced)
-
noReplyLogLevel
default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder 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. The option is a:org.apache.camel.LoggingLevel
type. Default: WARN Group: consumer (advanced)
-
noReplyLogLevel
default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder noReplyLogLevel(String noReplyLogLevel)
If sync is enabled this option dictates NettyConsumer which logging level to use when logging a there is no reply to send back. The option will be converted to aorg.apache.camel.LoggingLevel
type. Default: WARN Group: consumer (advanced)
-
serverClosedChannelExceptionCaughtLogLevel
default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder serverClosedChannelExceptionCaughtLogLevel(org.apache.camel.LoggingLevel serverClosedChannelExceptionCaughtLogLevel)
If the server (NettyConsumer) catches an java.nio.channels.ClosedChannelException then its logged using this logging level. This is used to avoid logging the closed channel exceptions, as clients can disconnect abruptly and then cause a flood of closed exceptions in the Netty server. The option is a:org.apache.camel.LoggingLevel
type. Default: DEBUG Group: consumer (advanced)
-
serverClosedChannelExceptionCaughtLogLevel
default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder serverClosedChannelExceptionCaughtLogLevel(String serverClosedChannelExceptionCaughtLogLevel)
If the server (NettyConsumer) catches an java.nio.channels.ClosedChannelException then its logged using this logging level. This is used to avoid logging the closed channel exceptions, as clients can disconnect abruptly and then cause a flood of closed exceptions in the Netty server. The option will be converted to aorg.apache.camel.LoggingLevel
type. Default: DEBUG Group: consumer (advanced)
-
serverExceptionCaughtLogLevel
default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder serverExceptionCaughtLogLevel(org.apache.camel.LoggingLevel serverExceptionCaughtLogLevel)
If the server (NettyConsumer) catches an exception then its logged using this logging level. The option is a:org.apache.camel.LoggingLevel
type. Default: WARN Group: consumer (advanced)
-
serverExceptionCaughtLogLevel
default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder serverExceptionCaughtLogLevel(String serverExceptionCaughtLogLevel)
If the server (NettyConsumer) catches an exception then its logged using this logging level. The option will be converted to aorg.apache.camel.LoggingLevel
type. Default: WARN Group: consumer (advanced)
-
serverInitializerFactory
default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder serverInitializerFactory(Object serverInitializerFactory)
To use a custom ServerInitializerFactory. The option is a:org.apache.camel.component.netty.ServerInitializerFactory
type. Group: consumer (advanced)
-
serverInitializerFactory
default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder serverInitializerFactory(String serverInitializerFactory)
To use a custom ServerInitializerFactory. The option will be converted to aorg.apache.camel.component.netty.ServerInitializerFactory
type. Group: consumer (advanced)
-
traceEnabled
default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder traceEnabled(boolean traceEnabled)
Specifies whether to enable HTTP TRACE for this Netty HTTP consumer. By default TRACE is turned off. The option is a:boolean
type. Default: false Group: consumer (advanced)
-
traceEnabled
default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder traceEnabled(String traceEnabled)
Specifies whether to enable HTTP TRACE for this Netty HTTP consumer. By default TRACE is turned off. The option will be converted to aboolean
type. Default: false Group: consumer (advanced)
-
urlDecodeHeaders
default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder urlDecodeHeaders(boolean urlDecodeHeaders)
If this option is enabled, then during binding from Netty to Camel Message then the header values will be URL decoded (eg %20 will be a space character. Notice this option is used by the default org.apache.camel.component.netty.http.NettyHttpBinding and therefore if you implement a custom org.apache.camel.component.netty.http.NettyHttpBinding then you would need to decode the headers accordingly to this option. The option is a:boolean
type. Default: false Group: consumer (advanced)
-
urlDecodeHeaders
default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder urlDecodeHeaders(String urlDecodeHeaders)
If this option is enabled, then during binding from Netty to Camel Message then the header values will be URL decoded (eg %20 will be a space character. Notice this option is used by the default org.apache.camel.component.netty.http.NettyHttpBinding and therefore if you implement a custom org.apache.camel.component.netty.http.NettyHttpBinding then you would need to decode the headers accordingly to this option. The option will be converted to aboolean
type. Default: false Group: consumer (advanced)
-
usingExecutorService
default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder usingExecutorService(boolean usingExecutorService)
Whether to use ordered thread pool, to ensure events are processed orderly on the same channel. The option is a:boolean
type. Default: true Group: consumer (advanced)
-
usingExecutorService
default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder usingExecutorService(String usingExecutorService)
Whether to use ordered thread pool, to ensure events are processed orderly on the same channel. The option will be converted to aboolean
type. Default: true Group: consumer (advanced)
-
allowSerializedHeaders
default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder allowSerializedHeaders(boolean allowSerializedHeaders)
Only used for TCP when transferExchange is true. When set to true, serializable objects in headers and properties will be added to the exchange. Otherwise Camel will exclude any non-serializable objects and log it at WARN level. The option is a:boolean
type. Default: false Group: advanced
-
allowSerializedHeaders
default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder allowSerializedHeaders(String allowSerializedHeaders)
Only used for TCP when transferExchange is true. When set to true, serializable objects in headers and properties will be added to the exchange. Otherwise Camel will exclude any non-serializable objects and log it at WARN level. The option will be converted to aboolean
type. Default: false Group: advanced
-
channelGroup
default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder channelGroup(Object channelGroup)
To use a explicit ChannelGroup. The option is a:io.netty.channel.group.ChannelGroup
type. Group: advanced
-
channelGroup
default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder channelGroup(String channelGroup)
To use a explicit ChannelGroup. The option will be converted to aio.netty.channel.group.ChannelGroup
type. Group: advanced
-
configuration
default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder configuration(Object configuration)
To use a custom configured NettyHttpConfiguration for configuring this endpoint. The option is a:org.apache.camel.component.netty.http.NettyHttpConfiguration
type. Group: advanced
-
configuration
default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder configuration(String configuration)
To use a custom configured NettyHttpConfiguration for configuring this endpoint. The option will be converted to aorg.apache.camel.component.netty.http.NettyHttpConfiguration
type. Group: advanced
-
disableStreamCache
default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder disableStreamCache(boolean disableStreamCache)
Determines whether or not the raw input stream from Netty HttpRequest#getContent() or HttpResponset#getContent() is cached or not (Camel will read the stream into a in light-weight memory based Stream caching) cache. By default Camel will cache the Netty input stream to support reading it multiple times to ensure it Camel can retrieve all data from the stream. However you can set this option to true when you for example need to access the raw stream, such as streaming it directly to a file or other persistent store. Mind that if you enable this option, then you cannot read the Netty stream multiple times out of the box, and you would need manually to reset the reader index on the Netty raw stream. Also Netty will auto-close the Netty stream when the Netty HTTP server/HTTP client is done processing, which means that if the asynchronous routing engine is in use then any asynchronous thread that may continue routing the org.apache.camel.Exchange may not be able to read the Netty stream, because Netty has closed it. The option is a:boolean
type. Default: false Group: advanced
-
disableStreamCache
default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder disableStreamCache(String disableStreamCache)
Determines whether or not the raw input stream from Netty HttpRequest#getContent() or HttpResponset#getContent() is cached or not (Camel will read the stream into a in light-weight memory based Stream caching) cache. By default Camel will cache the Netty input stream to support reading it multiple times to ensure it Camel can retrieve all data from the stream. However you can set this option to true when you for example need to access the raw stream, such as streaming it directly to a file or other persistent store. Mind that if you enable this option, then you cannot read the Netty stream multiple times out of the box, and you would need manually to reset the reader index on the Netty raw stream. Also Netty will auto-close the Netty stream when the Netty HTTP server/HTTP client is done processing, which means that if the asynchronous routing engine is in use then any asynchronous thread that may continue routing the org.apache.camel.Exchange may not be able to read the Netty stream, because Netty has closed it. The option will be converted to aboolean
type. Default: false Group: advanced
-
headerFilterStrategy
default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder headerFilterStrategy(org.apache.camel.spi.HeaderFilterStrategy headerFilterStrategy)
To use a custom org.apache.camel.spi.HeaderFilterStrategy to filter headers. The option is a:org.apache.camel.spi.HeaderFilterStrategy
type. Group: advanced
-
headerFilterStrategy
default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder headerFilterStrategy(String headerFilterStrategy)
To use a custom org.apache.camel.spi.HeaderFilterStrategy to filter headers. The option will be converted to aorg.apache.camel.spi.HeaderFilterStrategy
type. Group: advanced
-
nativeTransport
default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder nativeTransport(boolean nativeTransport)
Whether to use native transport instead of NIO. Native transport takes advantage of the host operating system and is only supported on some platforms. You need to add the netty JAR for the host operating system you are using. See more details at: http://netty.io/wiki/native-transports.html. The option is a:boolean
type. Default: false Group: advanced
-
nativeTransport
default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder nativeTransport(String nativeTransport)
Whether to use native transport instead of NIO. Native transport takes advantage of the host operating system and is only supported on some platforms. You need to add the netty JAR for the host operating system you are using. See more details at: http://netty.io/wiki/native-transports.html. The option will be converted to aboolean
type. Default: false Group: advanced
-
nettyHttpBinding
default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder nettyHttpBinding(Object nettyHttpBinding)
To use a custom org.apache.camel.component.netty.http.NettyHttpBinding for binding to/from Netty and Camel Message API. The option is a:org.apache.camel.component.netty.http.NettyHttpBinding
type. Group: advanced
-
nettyHttpBinding
default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder nettyHttpBinding(String nettyHttpBinding)
To use a custom org.apache.camel.component.netty.http.NettyHttpBinding for binding to/from Netty and Camel Message API. The option will be converted to aorg.apache.camel.component.netty.http.NettyHttpBinding
type. Group: advanced
-
options
default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder options(String key, Object value)
Allows to configure additional netty options using option. as prefix. For example option.child.keepAlive=false to set the netty option child.keepAlive=false. See the Netty documentation for possible options that can be used. The option is a:java.util.Map<java.lang.String, java.lang.Object>
type. The option is multivalued, and you can use the options(String, Object) method to add a value (call the method multiple times to set more values). Group: advanced
-
options
default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder options(Map values)
Allows to configure additional netty options using option. as prefix. For example option.child.keepAlive=false to set the netty option child.keepAlive=false. See the Netty documentation for possible options that can be used. The option is a:java.util.Map<java.lang.String, java.lang.Object>
type. The option is multivalued, and you can use the options(String, Object) method to add a value (call the method multiple times to set more values). Group: advanced
-
receiveBufferSize
default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder receiveBufferSize(int receiveBufferSize)
The TCP/UDP buffer sizes to be used during inbound communication. Size is bytes. The option is a:int
type. Default: 65536 Group: advanced
-
receiveBufferSize
default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder receiveBufferSize(String receiveBufferSize)
The TCP/UDP buffer sizes to be used during inbound communication. Size is bytes. The option will be converted to aint
type. Default: 65536 Group: advanced
-
receiveBufferSizePredictor
default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder receiveBufferSizePredictor(int receiveBufferSizePredictor)
Configures the buffer size predictor. See details at Jetty documentation and this mail thread. The option is a:int
type. Group: advanced
-
receiveBufferSizePredictor
default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder receiveBufferSizePredictor(String receiveBufferSizePredictor)
Configures the buffer size predictor. See details at Jetty documentation and this mail thread. The option will be converted to aint
type. Group: advanced
-
sendBufferSize
default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder sendBufferSize(int sendBufferSize)
The TCP/UDP buffer sizes to be used during outbound communication. Size is bytes. The option is a:int
type. Default: 65536 Group: advanced
-
sendBufferSize
default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder sendBufferSize(String sendBufferSize)
The TCP/UDP buffer sizes to be used during outbound communication. Size is bytes. The option will be converted to aint
type. Default: 65536 Group: advanced
-
synchronous
default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder synchronous(boolean synchronous)
Sets whether synchronous processing should be strictly used, or Camel is allowed to use asynchronous processing (if supported). The option is a:boolean
type. Default: false Group: advanced
-
synchronous
default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder synchronous(String synchronous)
Sets whether synchronous processing should be strictly used, or Camel is allowed to use asynchronous processing (if supported). The option will be converted to aboolean
type. Default: false Group: advanced
-
transferException
default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder transferException(boolean transferException)
If enabled and an Exchange failed processing on the consumer side, and if the caused Exception was send back serialized in the response as a application/x-java-serialized-object content type. On the producer side the exception will be deserialized and thrown as is, instead of the HttpOperationFailedException. The caused exception is required to be serialized. This is by default turned off. If you enable this then be aware that Java will deserialize the incoming data from the request to Java and that can be a potential security risk. The option is a:boolean
type. Default: false Group: advanced
-
transferException
default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder transferException(String transferException)
If enabled and an Exchange failed processing on the consumer side, and if the caused Exception was send back serialized in the response as a application/x-java-serialized-object content type. On the producer side the exception will be deserialized and thrown as is, instead of the HttpOperationFailedException. The caused exception is required to be serialized. This is by default turned off. If you enable this then be aware that Java will deserialize the incoming data from the request to Java and that can be a potential security risk. The option will be converted to aboolean
type. Default: false Group: advanced
-
transferExchange
default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder transferExchange(boolean transferExchange)
Only used for TCP. You can transfer the exchange over the wire instead of just the body. The following fields are transferred: In body, Out body, fault body, In headers, Out headers, fault headers, exchange properties, exchange exception. This requires that the objects are serializable. Camel will exclude any non-serializable objects and log it at WARN level. The option is a:boolean
type. Default: false Group: advanced
-
transferExchange
default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder transferExchange(String transferExchange)
Only used for TCP. You can transfer the exchange over the wire instead of just the body. The following fields are transferred: In body, Out body, fault body, In headers, Out headers, fault headers, exchange properties, exchange exception. This requires that the objects are serializable. Camel will exclude any non-serializable objects and log it at WARN level. The option will be converted to aboolean
type. Default: false Group: advanced
-
workerCount
default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder workerCount(int workerCount)
When netty works on nio mode, it uses default workerCount parameter from Netty (which is cpu_core_threads x 2). User can use this option to override the default workerCount from Netty. The option is a:int
type. Group: advanced
-
workerCount
default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder workerCount(String workerCount)
When netty works on nio mode, it uses default workerCount parameter from Netty (which is cpu_core_threads x 2). User can use this option to override the default workerCount from Netty. The option will be converted to aint
type. Group: advanced
-
workerGroup
default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder workerGroup(Object workerGroup)
To use a explicit EventLoopGroup as the boss thread pool. For example to share a thread pool with multiple consumers or producers. By default each consumer or producer has their own worker pool with 2 x cpu count core threads. The option is a:io.netty.channel.EventLoopGroup
type. Group: advanced
-
workerGroup
default NettyHttpEndpointBuilderFactory.AdvancedNettyHttpEndpointConsumerBuilder workerGroup(String workerGroup)
To use a explicit EventLoopGroup as the boss thread pool. For example to share a thread pool with multiple consumers or producers. By default each consumer or producer has their own worker pool with 2 x cpu count core threads. The option will be converted to aio.netty.channel.EventLoopGroup
type. Group: advanced
-
-