You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2021/02/03 07:57:38 UTC
[camel] branch master updated (4260485 -> 440a147)
This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git.
from 4260485 Regen for commit 2a1be0cdc4e0ec7a92341aedf0f5219fe40fd7c6
new 6e8a249 CAMEL-16129: camel-netty - Avoid reflection when configuring endpoints.
new ce48dea Polished
new bc9a0ac Regen
new 883a1b8 Revert "CAMEL-16129: camel-netty - Avoid reflection when configuring endpoints."
new 2933b9c CAMEL-16129: camel-netty - Avoid reflection when configuring endpoints.
new 440a147 CAMEL-16129: camel-netty - Avoid reflection when configuring endpoints.
The 6 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../apache/camel/catalog/components/aws2-sns.json | 4 +-
components/camel-netty-http/pom.xml | 18 +
.../http/NettyHttpConfigurationConfigurer.java | 578 +++++++++++++++++++++
...el.component.netty.http.NettyHttpConfiguration} | 2 +-
components/camel-netty/pom.xml | 22 +-
.../netty/NettyConfigurationConfigurer.java | 476 +++++++++++++++++
...apache.camel.component.netty.NettyConfiguration | 2 +
.../camel/component/netty/NettyConfiguration.java | 16 +-
.../component/vertx/http/VertxHttpProducer.java | 6 +-
9 files changed, 1114 insertions(+), 10 deletions(-)
create mode 100644 components/camel-netty-http/src/generated/java/org/apache/camel/component/netty/http/NettyHttpConfigurationConfigurer.java
copy components/{camel-twilio/src/generated/resources/META-INF/services/org/apache/camel/configurer/org.apache.camel.component.twilio.QueueEndpointConfiguration => camel-netty-http/src/generated/resources/META-INF/services/org/apache/camel/configurer/org.apache.camel.component.netty.http.NettyHttpConfiguration} (52%)
create mode 100644 components/camel-netty/src/generated/java/org/apache/camel/component/netty/NettyConfigurationConfigurer.java
create mode 100644 components/camel-netty/src/generated/resources/META-INF/services/org/apache/camel/configurer/org.apache.camel.component.netty.NettyConfiguration
[camel] 05/06: CAMEL-16129: camel-netty - Avoid reflection when
configuring endpoints.
Posted by da...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 2933b9c38961933a8b50095ceef2e1b556dfe083
Author: Claus Ibsen <cl...@gmail.com>
AuthorDate: Wed Feb 3 07:33:15 2021 +0100
CAMEL-16129: camel-netty - Avoid reflection when configuring endpoints.
---
components/camel-netty/pom.xml | 22 +-
.../netty/NettyConfigurationConfigurer.java | 476 +++++++++++++++++++++
...apache.camel.component.netty.NettyConfiguration | 2 +
.../camel/component/netty/NettyConfiguration.java | 16 +-
4 files changed, 513 insertions(+), 3 deletions(-)
diff --git a/components/camel-netty/pom.xml b/components/camel-netty/pom.xml
index 1aa221c..be69e4e 100644
--- a/components/camel-netty/pom.xml
+++ b/components/camel-netty/pom.xml
@@ -17,7 +17,8 @@
limitations under the License.
-->
-<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+ xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
<modelVersion>4.0.0</modelVersion>
<parent>
@@ -111,6 +112,25 @@
<build>
<plugins>
<plugin>
+ <!-- we need to generate additional configurer classes -->
+ <groupId>org.apache.camel</groupId>
+ <artifactId>camel-package-maven-plugin</artifactId>
+ <executions>
+ <execution>
+ <id>generate-configurer</id>
+ <phase>process-classes</phase>
+ <goals>
+ <goal>generate-configurer</goal>
+ </goals>
+ <configuration>
+ <discoverClasses>true</discoverClasses>
+ <classes>org.apache.camel.component.netty.NettyConfiguration</classes>
+ </configuration>
+ </execution>
+ </executions>
+ </plugin>
+
+ <plugin>
<artifactId>maven-surefire-plugin</artifactId>
<configuration>
<forkCount>1</forkCount>
diff --git a/components/camel-netty/src/generated/java/org/apache/camel/component/netty/NettyConfigurationConfigurer.java b/components/camel-netty/src/generated/java/org/apache/camel/component/netty/NettyConfigurationConfigurer.java
new file mode 100644
index 0000000..b2aa719
--- /dev/null
+++ b/components/camel-netty/src/generated/java/org/apache/camel/component/netty/NettyConfigurationConfigurer.java
@@ -0,0 +1,476 @@
+/* Generated by camel build tools - do NOT edit this file! */
+package org.apache.camel.component.netty;
+
+import java.util.Map;
+
+import org.apache.camel.CamelContext;
+import org.apache.camel.spi.ExtendedPropertyConfigurerGetter;
+import org.apache.camel.spi.PropertyConfigurerGetter;
+import org.apache.camel.spi.ConfigurerStrategy;
+import org.apache.camel.spi.GeneratedPropertyConfigurer;
+import org.apache.camel.util.CaseInsensitiveMap;
+import org.apache.camel.component.netty.NettyConfiguration;
+
+/**
+ * Generated by camel build tools - do NOT edit this file!
+ */
+@SuppressWarnings("unchecked")
+public class NettyConfigurationConfigurer extends org.apache.camel.support.component.PropertyConfigurerSupport implements GeneratedPropertyConfigurer, PropertyConfigurerGetter {
+
+ @Override
+ public boolean configure(CamelContext camelContext, Object obj, String name, Object value, boolean ignoreCase) {
+ org.apache.camel.component.netty.NettyConfiguration target = (org.apache.camel.component.netty.NettyConfiguration) obj;
+ switch (ignoreCase ? name.toLowerCase() : name) {
+ case "allowdefaultcodec":
+ case "AllowDefaultCodec": target.setAllowDefaultCodec(property(camelContext, boolean.class, value)); return true;
+ case "allowserializedheaders":
+ case "AllowSerializedHeaders": target.setAllowSerializedHeaders(property(camelContext, boolean.class, value)); return true;
+ case "autoappenddelimiter":
+ case "AutoAppendDelimiter": target.setAutoAppendDelimiter(property(camelContext, boolean.class, value)); return true;
+ case "backlog":
+ case "Backlog": target.setBacklog(property(camelContext, int.class, value)); return true;
+ case "bosscount":
+ case "BossCount": target.setBossCount(property(camelContext, int.class, value)); return true;
+ case "bossgroup":
+ case "BossGroup": target.setBossGroup(property(camelContext, io.netty.channel.EventLoopGroup.class, value)); return true;
+ case "broadcast":
+ case "Broadcast": target.setBroadcast(property(camelContext, boolean.class, value)); return true;
+ case "channelgroup":
+ case "ChannelGroup": target.setChannelGroup(property(camelContext, io.netty.channel.group.ChannelGroup.class, value)); return true;
+ case "clientinitializerfactory":
+ case "ClientInitializerFactory": target.setClientInitializerFactory(property(camelContext, org.apache.camel.component.netty.ClientInitializerFactory.class, value)); return true;
+ case "clientmode":
+ case "ClientMode": target.setClientMode(property(camelContext, boolean.class, value)); return true;
+ case "clientpipelinefactory":
+ case "ClientPipelineFactory": target.setClientPipelineFactory(property(camelContext, org.apache.camel.component.netty.ClientInitializerFactory.class, value)); return true;
+ case "connecttimeout":
+ case "ConnectTimeout": target.setConnectTimeout(property(camelContext, int.class, value)); return true;
+ case "correlationmanager":
+ case "CorrelationManager": target.setCorrelationManager(property(camelContext, org.apache.camel.component.netty.NettyCamelStateCorrelationManager.class, value)); return true;
+ case "decodermaxlinelength":
+ case "DecoderMaxLineLength": target.setDecoderMaxLineLength(property(camelContext, int.class, value)); return true;
+ case "decoders":
+ case "Decoders": target.setDecoders(property(camelContext, java.util.List.class, value)); return true;
+ case "delimiter":
+ case "Delimiter": target.setDelimiter(property(camelContext, org.apache.camel.component.netty.TextLineDelimiter.class, value)); return true;
+ case "disconnect":
+ case "Disconnect": target.setDisconnect(property(camelContext, boolean.class, value)); return true;
+ case "disconnectonnoreply":
+ case "DisconnectOnNoReply": target.setDisconnectOnNoReply(property(camelContext, boolean.class, value)); return true;
+ case "enabledprotocols":
+ case "EnabledProtocols": target.setEnabledProtocols(property(camelContext, java.lang.String.class, value)); return true;
+ case "encoders":
+ case "Encoders": target.setEncoders(property(camelContext, java.util.List.class, value)); return true;
+ case "encoding":
+ case "Encoding": target.setEncoding(property(camelContext, java.lang.String.class, value)); return true;
+ case "host":
+ case "Host": target.setHost(property(camelContext, java.lang.String.class, value)); return true;
+ case "keepalive":
+ case "KeepAlive": target.setKeepAlive(property(camelContext, boolean.class, value)); return true;
+ case "keystorefile":
+ case "KeyStoreFile": target.setKeyStoreFile(property(camelContext, java.io.File.class, value)); return true;
+ case "keystoreformat":
+ case "KeyStoreFormat": target.setKeyStoreFormat(property(camelContext, java.lang.String.class, value)); return true;
+ case "keystoreresource":
+ case "KeyStoreResource": target.setKeyStoreResource(property(camelContext, java.lang.String.class, value)); return true;
+ case "lazychannelcreation":
+ case "LazyChannelCreation": target.setLazyChannelCreation(property(camelContext, boolean.class, value)); return true;
+ case "nativetransport":
+ case "NativeTransport": target.setNativeTransport(property(camelContext, boolean.class, value)); return true;
+ case "needclientauth":
+ case "NeedClientAuth": target.setNeedClientAuth(property(camelContext, boolean.class, value)); return true;
+ case "nettyserverbootstrapfactory":
+ case "NettyServerBootstrapFactory": target.setNettyServerBootstrapFactory(property(camelContext, org.apache.camel.component.netty.NettyServerBootstrapFactory.class, value)); return true;
+ case "networkinterface":
+ case "NetworkInterface": target.setNetworkInterface(property(camelContext, java.lang.String.class, value)); return true;
+ case "noreplyloglevel":
+ case "NoReplyLogLevel": target.setNoReplyLogLevel(property(camelContext, org.apache.camel.LoggingLevel.class, value)); return true;
+ case "options":
+ case "Options": target.setOptions(property(camelContext, java.util.Map.class, value)); return true;
+ case "passphrase":
+ case "Passphrase": target.setPassphrase(property(camelContext, java.lang.String.class, value)); return true;
+ case "port":
+ case "Port": target.setPort(property(camelContext, int.class, value)); return true;
+ case "producerpoolenabled":
+ case "ProducerPoolEnabled": target.setProducerPoolEnabled(property(camelContext, boolean.class, value)); return true;
+ case "producerpoolmaxactive":
+ case "ProducerPoolMaxActive": target.setProducerPoolMaxActive(property(camelContext, int.class, value)); return true;
+ case "producerpoolmaxidle":
+ case "ProducerPoolMaxIdle": target.setProducerPoolMaxIdle(property(camelContext, int.class, value)); return true;
+ case "producerpoolminevictableidle":
+ case "ProducerPoolMinEvictableIdle": target.setProducerPoolMinEvictableIdle(property(camelContext, long.class, value)); return true;
+ case "producerpoolminidle":
+ case "ProducerPoolMinIdle": target.setProducerPoolMinIdle(property(camelContext, int.class, value)); return true;
+ case "protocol":
+ case "Protocol": target.setProtocol(property(camelContext, java.lang.String.class, value)); return true;
+ case "receivebuffersize":
+ case "ReceiveBufferSize": target.setReceiveBufferSize(property(camelContext, int.class, value)); return true;
+ case "receivebuffersizepredictor":
+ case "ReceiveBufferSizePredictor": target.setReceiveBufferSizePredictor(property(camelContext, int.class, value)); return true;
+ case "reconnect":
+ case "Reconnect": target.setReconnect(property(camelContext, boolean.class, value)); return true;
+ case "reconnectinterval":
+ case "ReconnectInterval": target.setReconnectInterval(property(camelContext, int.class, value)); return true;
+ case "requesttimeout":
+ case "RequestTimeout": target.setRequestTimeout(property(camelContext, long.class, value)); return true;
+ case "reuseaddress":
+ case "ReuseAddress": target.setReuseAddress(property(camelContext, boolean.class, value)); return true;
+ case "reusechannel":
+ case "ReuseChannel": target.setReuseChannel(property(camelContext, boolean.class, value)); return true;
+ case "securityprovider":
+ case "SecurityProvider": target.setSecurityProvider(property(camelContext, java.lang.String.class, value)); return true;
+ case "sendbuffersize":
+ case "SendBufferSize": target.setSendBufferSize(property(camelContext, int.class, value)); return true;
+ case "serverclosedchannelexceptioncaughtloglevel":
+ case "ServerClosedChannelExceptionCaughtLogLevel": target.setServerClosedChannelExceptionCaughtLogLevel(property(camelContext, org.apache.camel.LoggingLevel.class, value)); return true;
+ case "serverexceptioncaughtloglevel":
+ case "ServerExceptionCaughtLogLevel": target.setServerExceptionCaughtLogLevel(property(camelContext, org.apache.camel.LoggingLevel.class, value)); return true;
+ case "serverinitializerfactory":
+ case "ServerInitializerFactory": target.setServerInitializerFactory(property(camelContext, org.apache.camel.component.netty.ServerInitializerFactory.class, value)); return true;
+ case "serverpipelinefactory":
+ case "ServerPipelineFactory": target.setServerPipelineFactory(property(camelContext, org.apache.camel.component.netty.ServerInitializerFactory.class, value)); return true;
+ case "ssl":
+ case "Ssl": target.setSsl(property(camelContext, boolean.class, value)); return true;
+ case "sslclientcertheaders":
+ case "SslClientCertHeaders": target.setSslClientCertHeaders(property(camelContext, boolean.class, value)); return true;
+ case "sslcontextparameters":
+ case "SslContextParameters": target.setSslContextParameters(property(camelContext, org.apache.camel.support.jsse.SSLContextParameters.class, value)); return true;
+ case "sslhandler":
+ case "SslHandler": target.setSslHandler(property(camelContext, io.netty.handler.ssl.SslHandler.class, value)); return true;
+ case "sync":
+ case "Sync": target.setSync(property(camelContext, boolean.class, value)); return true;
+ case "tcpnodelay":
+ case "TcpNoDelay": target.setTcpNoDelay(property(camelContext, boolean.class, value)); return true;
+ case "textline":
+ case "Textline": target.setTextline(property(camelContext, boolean.class, value)); return true;
+ case "transferexchange":
+ case "TransferExchange": target.setTransferExchange(property(camelContext, boolean.class, value)); return true;
+ case "truststorefile":
+ case "TrustStoreFile": target.setTrustStoreFile(property(camelContext, java.io.File.class, value)); return true;
+ case "truststoreresource":
+ case "TrustStoreResource": target.setTrustStoreResource(property(camelContext, java.lang.String.class, value)); return true;
+ case "udpbytearraycodec":
+ case "UdpByteArrayCodec": target.setUdpByteArrayCodec(property(camelContext, boolean.class, value)); return true;
+ case "udpconnectionlesssending":
+ case "UdpConnectionlessSending": target.setUdpConnectionlessSending(property(camelContext, boolean.class, value)); return true;
+ case "usebytebuf":
+ case "UseByteBuf": target.setUseByteBuf(property(camelContext, boolean.class, value)); return true;
+ case "usingexecutorservice":
+ case "UsingExecutorService": target.setUsingExecutorService(property(camelContext, boolean.class, value)); return true;
+ case "workercount":
+ case "WorkerCount": target.setWorkerCount(property(camelContext, int.class, value)); return true;
+ case "workergroup":
+ case "WorkerGroup": target.setWorkerGroup(property(camelContext, io.netty.channel.EventLoopGroup.class, value)); return true;
+ default: return false;
+ }
+ }
+
+ @Override
+ public Class<?> getOptionType(String name, boolean ignoreCase) {
+ switch (ignoreCase ? name.toLowerCase() : name) {
+ case "allowdefaultcodec":
+ case "AllowDefaultCodec": return boolean.class;
+ case "allowserializedheaders":
+ case "AllowSerializedHeaders": return boolean.class;
+ case "autoappenddelimiter":
+ case "AutoAppendDelimiter": return boolean.class;
+ case "backlog":
+ case "Backlog": return int.class;
+ case "bosscount":
+ case "BossCount": return int.class;
+ case "bossgroup":
+ case "BossGroup": return io.netty.channel.EventLoopGroup.class;
+ case "broadcast":
+ case "Broadcast": return boolean.class;
+ case "channelgroup":
+ case "ChannelGroup": return io.netty.channel.group.ChannelGroup.class;
+ case "clientinitializerfactory":
+ case "ClientInitializerFactory": return org.apache.camel.component.netty.ClientInitializerFactory.class;
+ case "clientmode":
+ case "ClientMode": return boolean.class;
+ case "clientpipelinefactory":
+ case "ClientPipelineFactory": return org.apache.camel.component.netty.ClientInitializerFactory.class;
+ case "connecttimeout":
+ case "ConnectTimeout": return int.class;
+ case "correlationmanager":
+ case "CorrelationManager": return org.apache.camel.component.netty.NettyCamelStateCorrelationManager.class;
+ case "decodermaxlinelength":
+ case "DecoderMaxLineLength": return int.class;
+ case "decoders":
+ case "Decoders": return java.util.List.class;
+ case "delimiter":
+ case "Delimiter": return org.apache.camel.component.netty.TextLineDelimiter.class;
+ case "disconnect":
+ case "Disconnect": return boolean.class;
+ case "disconnectonnoreply":
+ case "DisconnectOnNoReply": return boolean.class;
+ case "enabledprotocols":
+ case "EnabledProtocols": return java.lang.String.class;
+ case "encoders":
+ case "Encoders": return java.util.List.class;
+ case "encoding":
+ case "Encoding": return java.lang.String.class;
+ case "host":
+ case "Host": return java.lang.String.class;
+ case "keepalive":
+ case "KeepAlive": return boolean.class;
+ case "keystorefile":
+ case "KeyStoreFile": return java.io.File.class;
+ case "keystoreformat":
+ case "KeyStoreFormat": return java.lang.String.class;
+ case "keystoreresource":
+ case "KeyStoreResource": return java.lang.String.class;
+ case "lazychannelcreation":
+ case "LazyChannelCreation": return boolean.class;
+ case "nativetransport":
+ case "NativeTransport": return boolean.class;
+ case "needclientauth":
+ case "NeedClientAuth": return boolean.class;
+ case "nettyserverbootstrapfactory":
+ case "NettyServerBootstrapFactory": return org.apache.camel.component.netty.NettyServerBootstrapFactory.class;
+ case "networkinterface":
+ case "NetworkInterface": return java.lang.String.class;
+ case "noreplyloglevel":
+ case "NoReplyLogLevel": return org.apache.camel.LoggingLevel.class;
+ case "options":
+ case "Options": return java.util.Map.class;
+ case "passphrase":
+ case "Passphrase": return java.lang.String.class;
+ case "port":
+ case "Port": return int.class;
+ case "producerpoolenabled":
+ case "ProducerPoolEnabled": return boolean.class;
+ case "producerpoolmaxactive":
+ case "ProducerPoolMaxActive": return int.class;
+ case "producerpoolmaxidle":
+ case "ProducerPoolMaxIdle": return int.class;
+ case "producerpoolminevictableidle":
+ case "ProducerPoolMinEvictableIdle": return long.class;
+ case "producerpoolminidle":
+ case "ProducerPoolMinIdle": return int.class;
+ case "protocol":
+ case "Protocol": return java.lang.String.class;
+ case "receivebuffersize":
+ case "ReceiveBufferSize": return int.class;
+ case "receivebuffersizepredictor":
+ case "ReceiveBufferSizePredictor": return int.class;
+ case "reconnect":
+ case "Reconnect": return boolean.class;
+ case "reconnectinterval":
+ case "ReconnectInterval": return int.class;
+ case "requesttimeout":
+ case "RequestTimeout": return long.class;
+ case "reuseaddress":
+ case "ReuseAddress": return boolean.class;
+ case "reusechannel":
+ case "ReuseChannel": return boolean.class;
+ case "securityprovider":
+ case "SecurityProvider": return java.lang.String.class;
+ case "sendbuffersize":
+ case "SendBufferSize": return int.class;
+ case "serverclosedchannelexceptioncaughtloglevel":
+ case "ServerClosedChannelExceptionCaughtLogLevel": return org.apache.camel.LoggingLevel.class;
+ case "serverexceptioncaughtloglevel":
+ case "ServerExceptionCaughtLogLevel": return org.apache.camel.LoggingLevel.class;
+ case "serverinitializerfactory":
+ case "ServerInitializerFactory": return org.apache.camel.component.netty.ServerInitializerFactory.class;
+ case "serverpipelinefactory":
+ case "ServerPipelineFactory": return org.apache.camel.component.netty.ServerInitializerFactory.class;
+ case "ssl":
+ case "Ssl": return boolean.class;
+ case "sslclientcertheaders":
+ case "SslClientCertHeaders": return boolean.class;
+ case "sslcontextparameters":
+ case "SslContextParameters": return org.apache.camel.support.jsse.SSLContextParameters.class;
+ case "sslhandler":
+ case "SslHandler": return io.netty.handler.ssl.SslHandler.class;
+ case "sync":
+ case "Sync": return boolean.class;
+ case "tcpnodelay":
+ case "TcpNoDelay": return boolean.class;
+ case "textline":
+ case "Textline": return boolean.class;
+ case "transferexchange":
+ case "TransferExchange": return boolean.class;
+ case "truststorefile":
+ case "TrustStoreFile": return java.io.File.class;
+ case "truststoreresource":
+ case "TrustStoreResource": return java.lang.String.class;
+ case "udpbytearraycodec":
+ case "UdpByteArrayCodec": return boolean.class;
+ case "udpconnectionlesssending":
+ case "UdpConnectionlessSending": return boolean.class;
+ case "usebytebuf":
+ case "UseByteBuf": return boolean.class;
+ case "usingexecutorservice":
+ case "UsingExecutorService": return boolean.class;
+ case "workercount":
+ case "WorkerCount": return int.class;
+ case "workergroup":
+ case "WorkerGroup": return io.netty.channel.EventLoopGroup.class;
+ default: return null;
+ }
+ }
+
+ @Override
+ public Object getOptionValue(Object obj, String name, boolean ignoreCase) {
+ org.apache.camel.component.netty.NettyConfiguration target = (org.apache.camel.component.netty.NettyConfiguration) obj;
+ switch (ignoreCase ? name.toLowerCase() : name) {
+ case "allowdefaultcodec":
+ case "AllowDefaultCodec": return target.isAllowDefaultCodec();
+ case "allowserializedheaders":
+ case "AllowSerializedHeaders": return target.isAllowSerializedHeaders();
+ case "autoappenddelimiter":
+ case "AutoAppendDelimiter": return target.isAutoAppendDelimiter();
+ case "backlog":
+ case "Backlog": return target.getBacklog();
+ case "bosscount":
+ case "BossCount": return target.getBossCount();
+ case "bossgroup":
+ case "BossGroup": return target.getBossGroup();
+ case "broadcast":
+ case "Broadcast": return target.isBroadcast();
+ case "channelgroup":
+ case "ChannelGroup": return target.getChannelGroup();
+ case "clientinitializerfactory":
+ case "ClientInitializerFactory": return target.getClientInitializerFactory();
+ case "clientmode":
+ case "ClientMode": return target.isClientMode();
+ case "clientpipelinefactory":
+ case "ClientPipelineFactory": return target.getClientPipelineFactory();
+ case "connecttimeout":
+ case "ConnectTimeout": return target.getConnectTimeout();
+ case "correlationmanager":
+ case "CorrelationManager": return target.getCorrelationManager();
+ case "decodermaxlinelength":
+ case "DecoderMaxLineLength": return target.getDecoderMaxLineLength();
+ case "decoders":
+ case "Decoders": return target.getDecoders();
+ case "delimiter":
+ case "Delimiter": return target.getDelimiter();
+ case "disconnect":
+ case "Disconnect": return target.isDisconnect();
+ case "disconnectonnoreply":
+ case "DisconnectOnNoReply": return target.isDisconnectOnNoReply();
+ case "enabledprotocols":
+ case "EnabledProtocols": return target.getEnabledProtocols();
+ case "encoders":
+ case "Encoders": return target.getEncoders();
+ case "encoding":
+ case "Encoding": return target.getEncoding();
+ case "host":
+ case "Host": return target.getHost();
+ case "keepalive":
+ case "KeepAlive": return target.isKeepAlive();
+ case "keystorefile":
+ case "KeyStoreFile": return target.getKeyStoreFile();
+ case "keystoreformat":
+ case "KeyStoreFormat": return target.getKeyStoreFormat();
+ case "keystoreresource":
+ case "KeyStoreResource": return target.getKeyStoreResource();
+ case "lazychannelcreation":
+ case "LazyChannelCreation": return target.isLazyChannelCreation();
+ case "nativetransport":
+ case "NativeTransport": return target.isNativeTransport();
+ case "needclientauth":
+ case "NeedClientAuth": return target.isNeedClientAuth();
+ case "nettyserverbootstrapfactory":
+ case "NettyServerBootstrapFactory": return target.getNettyServerBootstrapFactory();
+ case "networkinterface":
+ case "NetworkInterface": return target.getNetworkInterface();
+ case "noreplyloglevel":
+ case "NoReplyLogLevel": return target.getNoReplyLogLevel();
+ case "options":
+ case "Options": return target.getOptions();
+ case "passphrase":
+ case "Passphrase": return target.getPassphrase();
+ case "port":
+ case "Port": return target.getPort();
+ case "producerpoolenabled":
+ case "ProducerPoolEnabled": return target.isProducerPoolEnabled();
+ case "producerpoolmaxactive":
+ case "ProducerPoolMaxActive": return target.getProducerPoolMaxActive();
+ case "producerpoolmaxidle":
+ case "ProducerPoolMaxIdle": return target.getProducerPoolMaxIdle();
+ case "producerpoolminevictableidle":
+ case "ProducerPoolMinEvictableIdle": return target.getProducerPoolMinEvictableIdle();
+ case "producerpoolminidle":
+ case "ProducerPoolMinIdle": return target.getProducerPoolMinIdle();
+ case "protocol":
+ case "Protocol": return target.getProtocol();
+ case "receivebuffersize":
+ case "ReceiveBufferSize": return target.getReceiveBufferSize();
+ case "receivebuffersizepredictor":
+ case "ReceiveBufferSizePredictor": return target.getReceiveBufferSizePredictor();
+ case "reconnect":
+ case "Reconnect": return target.isReconnect();
+ case "reconnectinterval":
+ case "ReconnectInterval": return target.getReconnectInterval();
+ case "requesttimeout":
+ case "RequestTimeout": return target.getRequestTimeout();
+ case "reuseaddress":
+ case "ReuseAddress": return target.isReuseAddress();
+ case "reusechannel":
+ case "ReuseChannel": return target.isReuseChannel();
+ case "securityprovider":
+ case "SecurityProvider": return target.getSecurityProvider();
+ case "sendbuffersize":
+ case "SendBufferSize": return target.getSendBufferSize();
+ case "serverclosedchannelexceptioncaughtloglevel":
+ case "ServerClosedChannelExceptionCaughtLogLevel": return target.getServerClosedChannelExceptionCaughtLogLevel();
+ case "serverexceptioncaughtloglevel":
+ case "ServerExceptionCaughtLogLevel": return target.getServerExceptionCaughtLogLevel();
+ case "serverinitializerfactory":
+ case "ServerInitializerFactory": return target.getServerInitializerFactory();
+ case "serverpipelinefactory":
+ case "ServerPipelineFactory": return target.getServerPipelineFactory();
+ case "ssl":
+ case "Ssl": return target.isSsl();
+ case "sslclientcertheaders":
+ case "SslClientCertHeaders": return target.isSslClientCertHeaders();
+ case "sslcontextparameters":
+ case "SslContextParameters": return target.getSslContextParameters();
+ case "sslhandler":
+ case "SslHandler": return target.getSslHandler();
+ case "sync":
+ case "Sync": return target.isSync();
+ case "tcpnodelay":
+ case "TcpNoDelay": return target.isTcpNoDelay();
+ case "textline":
+ case "Textline": return target.isTextline();
+ case "transferexchange":
+ case "TransferExchange": return target.isTransferExchange();
+ case "truststorefile":
+ case "TrustStoreFile": return target.getTrustStoreFile();
+ case "truststoreresource":
+ case "TrustStoreResource": return target.getTrustStoreResource();
+ case "udpbytearraycodec":
+ case "UdpByteArrayCodec": return target.isUdpByteArrayCodec();
+ case "udpconnectionlesssending":
+ case "UdpConnectionlessSending": return target.isUdpConnectionlessSending();
+ case "usebytebuf":
+ case "UseByteBuf": return target.isUseByteBuf();
+ case "usingexecutorservice":
+ case "UsingExecutorService": return target.isUsingExecutorService();
+ case "workercount":
+ case "WorkerCount": return target.getWorkerCount();
+ case "workergroup":
+ case "WorkerGroup": return target.getWorkerGroup();
+ default: return null;
+ }
+ }
+
+ @Override
+ public Object getCollectionValueType(Object target, String name, boolean ignoreCase) {
+ switch (ignoreCase ? name.toLowerCase() : name) {
+ case "decoders":
+ case "Decoders": return io.netty.channel.ChannelHandler.class;
+ case "encoders":
+ case "Encoders": return io.netty.channel.ChannelHandler.class;
+ case "options":
+ case "Options": return java.lang.Object.class;
+ default: return null;
+ }
+ }
+}
+
diff --git a/components/camel-netty/src/generated/resources/META-INF/services/org/apache/camel/configurer/org.apache.camel.component.netty.NettyConfiguration b/components/camel-netty/src/generated/resources/META-INF/services/org/apache/camel/configurer/org.apache.camel.component.netty.NettyConfiguration
new file mode 100644
index 0000000..6cca5cf
--- /dev/null
+++ b/components/camel-netty/src/generated/resources/META-INF/services/org/apache/camel/configurer/org.apache.camel.component.netty.NettyConfiguration
@@ -0,0 +1,2 @@
+# Generated by camel build tools - do NOT edit this file!
+class=org.apache.camel.component.netty.NettyConfigurationConfigurer
diff --git a/components/camel-netty/src/main/java/org/apache/camel/component/netty/NettyConfiguration.java b/components/camel-netty/src/main/java/org/apache/camel/component/netty/NettyConfiguration.java
index 95db9db..172660d 100644
--- a/components/camel-netty/src/main/java/org/apache/camel/component/netty/NettyConfiguration.java
+++ b/components/camel-netty/src/main/java/org/apache/camel/component/netty/NettyConfiguration.java
@@ -30,8 +30,10 @@ import io.netty.handler.codec.Delimiters;
import io.netty.handler.ssl.SslHandler;
import io.netty.util.CharsetUtil;
import org.apache.camel.Exchange;
+import org.apache.camel.ExtendedCamelContext;
import org.apache.camel.LoggingLevel;
import org.apache.camel.RuntimeCamelException;
+import org.apache.camel.spi.PropertyConfigurer;
import org.apache.camel.spi.UriParam;
import org.apache.camel.spi.UriParams;
import org.apache.camel.support.CamelContextHelper;
@@ -208,7 +210,17 @@ public class NettyConfiguration extends NettyServerBootstrapConfiguration implem
addToHandlersList(decoders, referencedDecoders, ChannelHandler.class);
// then set parameters with the help of the camel context type converters
- PropertyBindingSupport.bindProperties(component.getCamelContext(), this, parameters);
+ // and use configurer to avoid any reflection calls
+ PropertyConfigurer configurer = component.getCamelContext().adapt(ExtendedCamelContext.class).getConfigurerResolver()
+ .resolvePropertyConfigurer(NettyConfiguration.class.getName(), component.getCamelContext());
+ PropertyBindingSupport.build()
+ .withCamelContext(component.getCamelContext())
+ .withTarget(this)
+ .withReflection(false)
+ .withIgnoreCase(true)
+ .withConfigurer(configurer)
+ .withProperties(parameters)
+ .bind();
// additional netty options, we don't want to store an empty map, so set it as null if empty
options = PropertiesHelper.extractProperties(parameters, "option.");
@@ -612,7 +624,7 @@ public class NettyConfiguration extends NettyServerBootstrapConfiguration implem
/**
* Whether producer pool is enabled or not.
- *
+ * <p>
* Important: If you turn this off then a single shared connection is used for the producer, also if you are doing
* request/reply. That means there is a potential issue with interleaved responses if replies comes back
* out-of-order. Therefore you need to have a correlation id in both the request and reply messages so you can
[camel] 03/06: Regen
Posted by da...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git
commit bc9a0ac4508198529acdf3a547e8db9a5729a8a6
Author: Claus Ibsen <cl...@gmail.com>
AuthorDate: Wed Feb 3 06:17:42 2021 +0100
Regen
---
.../resources/org/apache/camel/catalog/components/aws2-sns.json | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/aws2-sns.json b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/aws2-sns.json
index f7c7b8e..9d44671 100644
--- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/aws2-sns.json
+++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/aws2-sns.json
@@ -30,7 +30,7 @@
"messageDeduplicationIdStrategy": { "kind": "property", "displayName": "Message Deduplication Id Strategy", "group": "producer", "label": "producer", "required": false, "type": "string", "javaType": "java.lang.String", "enum": [ "useExchangeId", "useContentBasedDeduplication" ], "deprecated": false, "autowired": false, "secret": false, "defaultValue": "useExchangeId", "configurationClass": "org.apache.camel.component.aws2.sns.Sns2Configuration", "configurationField": "configuration", [...]
"messageGroupIdStrategy": { "kind": "property", "displayName": "Message Group Id Strategy", "group": "producer", "label": "producer", "required": false, "type": "string", "javaType": "java.lang.String", "enum": [ "useConstant", "useExchangeId", "usePropertyValue" ], "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.aws2.sns.Sns2Configuration", "configurationField": "configuration", "description": "Only for FIFO Topic. Strategy [...]
"messageStructure": { "kind": "property", "displayName": "Message Structure", "group": "producer", "label": "", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.aws2.sns.Sns2Configuration", "configurationField": "configuration", "description": "The message structure to use such as json" },
- "policy": { "kind": "property", "displayName": "Policy", "group": "producer", "label": "", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.aws2.sns.Sns2Configuration", "configurationField": "configuration", "description": "The policy for this queue. Is loaded by default from classpath, but you can prefix with classpath:, file:, or http: to load the resource [...]
+ "policy": { "kind": "property", "displayName": "Policy", "group": "producer", "label": "", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.aws2.sns.Sns2Configuration", "configurationField": "configuration", "description": "The policy for this topic. Is loaded by default from classpath, but you can prefix with classpath:, file:, or http: to load the resource [...]
"proxyHost": { "kind": "property", "displayName": "Proxy Host", "group": "producer", "label": "", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.aws2.sns.Sns2Configuration", "configurationField": "configuration", "description": "To define a proxy host when instantiating the SNS client" },
"proxyPort": { "kind": "property", "displayName": "Proxy Port", "group": "producer", "label": "", "required": false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.aws2.sns.Sns2Configuration", "configurationField": "configuration", "description": "To define a proxy port when instantiating the SNS client" },
"proxyProtocol": { "kind": "property", "displayName": "Proxy Protocol", "group": "producer", "label": "", "required": false, "type": "object", "javaType": "software.amazon.awssdk.core.Protocol", "enum": [ "HTTP", "HTTPS" ], "deprecated": false, "autowired": false, "secret": false, "defaultValue": "HTTPS", "configurationClass": "org.apache.camel.component.aws2.sns.Sns2Configuration", "configurationField": "configuration", "description": "To define a proxy protocol when instantiating t [...]
@@ -55,7 +55,7 @@
"messageDeduplicationIdStrategy": { "kind": "parameter", "displayName": "Message Deduplication Id Strategy", "group": "producer", "label": "producer", "required": false, "type": "string", "javaType": "java.lang.String", "enum": [ "useExchangeId", "useContentBasedDeduplication" ], "deprecated": false, "autowired": false, "secret": false, "defaultValue": "useExchangeId", "configurationClass": "org.apache.camel.component.aws2.sns.Sns2Configuration", "configurationField": "configuration" [...]
"messageGroupIdStrategy": { "kind": "parameter", "displayName": "Message Group Id Strategy", "group": "producer", "label": "producer", "required": false, "type": "string", "javaType": "java.lang.String", "enum": [ "useConstant", "useExchangeId", "usePropertyValue" ], "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.aws2.sns.Sns2Configuration", "configurationField": "configuration", "description": "Only for FIFO Topic. Strateg [...]
"messageStructure": { "kind": "parameter", "displayName": "Message Structure", "group": "producer", "label": "", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.aws2.sns.Sns2Configuration", "configurationField": "configuration", "description": "The message structure to use such as json" },
- "policy": { "kind": "parameter", "displayName": "Policy", "group": "producer", "label": "", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.aws2.sns.Sns2Configuration", "configurationField": "configuration", "description": "The policy for this queue. Is loaded by default from classpath, but you can prefix with classpath:, file:, or http: to load the resourc [...]
+ "policy": { "kind": "parameter", "displayName": "Policy", "group": "producer", "label": "", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.aws2.sns.Sns2Configuration", "configurationField": "configuration", "description": "The policy for this topic. Is loaded by default from classpath, but you can prefix with classpath:, file:, or http: to load the resourc [...]
"proxyHost": { "kind": "parameter", "displayName": "Proxy Host", "group": "producer", "label": "", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.aws2.sns.Sns2Configuration", "configurationField": "configuration", "description": "To define a proxy host when instantiating the SNS client" },
"proxyPort": { "kind": "parameter", "displayName": "Proxy Port", "group": "producer", "label": "", "required": false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.aws2.sns.Sns2Configuration", "configurationField": "configuration", "description": "To define a proxy port when instantiating the SNS client" },
"proxyProtocol": { "kind": "parameter", "displayName": "Proxy Protocol", "group": "producer", "label": "", "required": false, "type": "object", "javaType": "software.amazon.awssdk.core.Protocol", "enum": [ "HTTP", "HTTPS" ], "deprecated": false, "autowired": false, "secret": false, "defaultValue": "HTTPS", "configurationClass": "org.apache.camel.component.aws2.sns.Sns2Configuration", "configurationField": "configuration", "description": "To define a proxy protocol when instantiating [...]
[camel] 02/06: Polished
Posted by da...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git
commit ce48dea0a753f19da9f691b38f93b008e632b1ae
Author: Claus Ibsen <cl...@gmail.com>
AuthorDate: Wed Feb 3 06:17:37 2021 +0100
Polished
---
.../org/apache/camel/component/vertx/http/VertxHttpProducer.java | 6 ++----
1 file changed, 2 insertions(+), 4 deletions(-)
diff --git a/components/camel-vertx-http/src/main/java/org/apache/camel/component/vertx/http/VertxHttpProducer.java b/components/camel-vertx-http/src/main/java/org/apache/camel/component/vertx/http/VertxHttpProducer.java
index b7360cd..51e7412 100644
--- a/components/camel-vertx-http/src/main/java/org/apache/camel/component/vertx/http/VertxHttpProducer.java
+++ b/components/camel-vertx-http/src/main/java/org/apache/camel/component/vertx/http/VertxHttpProducer.java
@@ -32,7 +32,6 @@ import org.apache.camel.AsyncCallback;
import org.apache.camel.CamelExchangeException;
import org.apache.camel.Exchange;
import org.apache.camel.Message;
-import org.apache.camel.RuntimeCamelException;
import org.apache.camel.support.DefaultAsyncProducer;
import org.apache.camel.util.ObjectHelper;
import org.apache.camel.util.URISupport;
@@ -57,11 +56,10 @@ public class VertxHttpProducer extends DefaultAsyncProducer {
@Override
public boolean process(Exchange exchange, AsyncCallback callback) {
- VertxHttpConfiguration configuration = getEndpoint().getConfiguration();
Message message = exchange.getMessage();
try {
- VertxHttpBinding vertxHttpBinding = configuration.getVertxHttpBinding();
+ VertxHttpBinding vertxHttpBinding = getEndpoint().getConfiguration().getVertxHttpBinding();
HttpRequest<Buffer> request = vertxHttpBinding.prepareHttpRequest(getEndpoint(), exchange);
Handler<AsyncResult<HttpResponse<Buffer>>> resultHandler = createResultHandler(exchange, callback);
@@ -132,7 +130,7 @@ public class VertxHttpProducer extends DefaultAsyncProducer {
VertxHttpBinding vertxHttpBinding = endpoint.getConfiguration().getVertxHttpBinding();
vertxHttpBinding.handleResponse(endpoint, exchange, response);
} catch (Exception e) {
- throw new RuntimeCamelException(e);
+ exchange.setException(e);
} finally {
callback.done(false);
}
[camel] 04/06: Revert "CAMEL-16129: camel-netty - Avoid reflection
when configuring endpoints."
Posted by da...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 883a1b8712c66c480cc8f2b6e6fbbd4baef77a51
Author: Claus Ibsen <cl...@gmail.com>
AuthorDate: Wed Feb 3 06:20:25 2021 +0100
Revert "CAMEL-16129: camel-netty - Avoid reflection when configuring endpoints."
This reverts commit 0b72e8c567ad29313d7a45cc4f10a6329f6ff256.
---
.../java/org/apache/camel/component/netty/NettyComponent.java | 8 +++-----
.../java/org/apache/camel/component/netty/NettyConfiguration.java | 7 ++++---
2 files changed, 7 insertions(+), 8 deletions(-)
diff --git a/components/camel-netty/src/main/java/org/apache/camel/component/netty/NettyComponent.java b/components/camel-netty/src/main/java/org/apache/camel/component/netty/NettyComponent.java
index 5519338..4e62bdb 100644
--- a/components/camel-netty/src/main/java/org/apache/camel/component/netty/NettyComponent.java
+++ b/components/camel-netty/src/main/java/org/apache/camel/component/netty/NettyComponent.java
@@ -96,13 +96,11 @@ public class NettyComponent extends DefaultComponent implements SSLContextParame
config.setSslContextParameters(retrieveGlobalSslContextParameters());
}
- NettyEndpoint nettyEndpoint = new NettyEndpoint(uri, this, config);
- setProperties(nettyEndpoint, parameters);
-
- // set defaults on config and validate
- config.setDefaultEncodersAndDecoders();
+ // validate config
config.validateConfiguration();
+ NettyEndpoint nettyEndpoint = new NettyEndpoint(uri, this, config);
+ setProperties(nettyEndpoint, parameters);
return nettyEndpoint;
}
diff --git a/components/camel-netty/src/main/java/org/apache/camel/component/netty/NettyConfiguration.java b/components/camel-netty/src/main/java/org/apache/camel/component/netty/NettyConfiguration.java
index d6f5baa..95db9db 100644
--- a/components/camel-netty/src/main/java/org/apache/camel/component/netty/NettyConfiguration.java
+++ b/components/camel-netty/src/main/java/org/apache/camel/component/netty/NettyConfiguration.java
@@ -36,6 +36,7 @@ import org.apache.camel.spi.UriParam;
import org.apache.camel.spi.UriParams;
import org.apache.camel.support.CamelContextHelper;
import org.apache.camel.support.EndpointHelper;
+import org.apache.camel.support.PropertyBindingSupport;
import org.apache.camel.util.ObjectHelper;
import org.apache.camel.util.PropertiesHelper;
import org.apache.camel.util.StringHelper;
@@ -163,7 +164,6 @@ public class NettyConfiguration extends NettyServerBootstrapConfiguration implem
}
}
- @Deprecated
public void parseURI(URI uri, Map<String, Object> parameters, NettyComponent component, String... supportedProtocols)
throws Exception {
protocol = uri.getScheme();
@@ -207,14 +207,15 @@ public class NettyConfiguration extends NettyServerBootstrapConfiguration implem
= component.resolveAndRemoveReferenceListParameter(parameters, "decoders", ChannelHandler.class, null);
addToHandlersList(decoders, referencedDecoders, ChannelHandler.class);
+ // then set parameters with the help of the camel context type converters
+ PropertyBindingSupport.bindProperties(component.getCamelContext(), this, parameters);
+
// additional netty options, we don't want to store an empty map, so set it as null if empty
options = PropertiesHelper.extractProperties(parameters, "option.");
if (options.isEmpty()) {
options = null;
}
- }
- public void setDefaultEncodersAndDecoders() {
// add default encoders and decoders
if (encoders.isEmpty() && decoders.isEmpty()) {
if (isAllowDefaultCodec()) {
[camel] 01/06: CAMEL-16129: camel-netty - Avoid reflection when
configuring endpoints.
Posted by da...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 6e8a24901f69de1e949936b1ea9631d2c88aa910
Author: Claus Ibsen <cl...@gmail.com>
AuthorDate: Tue Feb 2 21:17:36 2021 +0100
CAMEL-16129: camel-netty - Avoid reflection when configuring endpoints.
---
.../java/org/apache/camel/component/netty/NettyComponent.java | 8 +++++---
.../java/org/apache/camel/component/netty/NettyConfiguration.java | 7 +++----
2 files changed, 8 insertions(+), 7 deletions(-)
diff --git a/components/camel-netty/src/main/java/org/apache/camel/component/netty/NettyComponent.java b/components/camel-netty/src/main/java/org/apache/camel/component/netty/NettyComponent.java
index 4e62bdb..5519338 100644
--- a/components/camel-netty/src/main/java/org/apache/camel/component/netty/NettyComponent.java
+++ b/components/camel-netty/src/main/java/org/apache/camel/component/netty/NettyComponent.java
@@ -96,11 +96,13 @@ public class NettyComponent extends DefaultComponent implements SSLContextParame
config.setSslContextParameters(retrieveGlobalSslContextParameters());
}
- // validate config
- config.validateConfiguration();
-
NettyEndpoint nettyEndpoint = new NettyEndpoint(uri, this, config);
setProperties(nettyEndpoint, parameters);
+
+ // set defaults on config and validate
+ config.setDefaultEncodersAndDecoders();
+ config.validateConfiguration();
+
return nettyEndpoint;
}
diff --git a/components/camel-netty/src/main/java/org/apache/camel/component/netty/NettyConfiguration.java b/components/camel-netty/src/main/java/org/apache/camel/component/netty/NettyConfiguration.java
index 95db9db..d6f5baa 100644
--- a/components/camel-netty/src/main/java/org/apache/camel/component/netty/NettyConfiguration.java
+++ b/components/camel-netty/src/main/java/org/apache/camel/component/netty/NettyConfiguration.java
@@ -36,7 +36,6 @@ import org.apache.camel.spi.UriParam;
import org.apache.camel.spi.UriParams;
import org.apache.camel.support.CamelContextHelper;
import org.apache.camel.support.EndpointHelper;
-import org.apache.camel.support.PropertyBindingSupport;
import org.apache.camel.util.ObjectHelper;
import org.apache.camel.util.PropertiesHelper;
import org.apache.camel.util.StringHelper;
@@ -164,6 +163,7 @@ public class NettyConfiguration extends NettyServerBootstrapConfiguration implem
}
}
+ @Deprecated
public void parseURI(URI uri, Map<String, Object> parameters, NettyComponent component, String... supportedProtocols)
throws Exception {
protocol = uri.getScheme();
@@ -207,15 +207,14 @@ public class NettyConfiguration extends NettyServerBootstrapConfiguration implem
= component.resolveAndRemoveReferenceListParameter(parameters, "decoders", ChannelHandler.class, null);
addToHandlersList(decoders, referencedDecoders, ChannelHandler.class);
- // then set parameters with the help of the camel context type converters
- PropertyBindingSupport.bindProperties(component.getCamelContext(), this, parameters);
-
// additional netty options, we don't want to store an empty map, so set it as null if empty
options = PropertiesHelper.extractProperties(parameters, "option.");
if (options.isEmpty()) {
options = null;
}
+ }
+ public void setDefaultEncodersAndDecoders() {
// add default encoders and decoders
if (encoders.isEmpty() && decoders.isEmpty()) {
if (isAllowDefaultCodec()) {
[camel] 06/06: CAMEL-16129: camel-netty - Avoid reflection when
configuring endpoints.
Posted by da...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 440a14797be5017d889d98501498fdb26a5ba900
Author: Claus Ibsen <cl...@gmail.com>
AuthorDate: Wed Feb 3 07:50:50 2021 +0100
CAMEL-16129: camel-netty - Avoid reflection when configuring endpoints.
---
components/camel-netty-http/pom.xml | 18 +
.../http/NettyHttpConfigurationConfigurer.java | 578 +++++++++++++++++++++
...mel.component.netty.http.NettyHttpConfiguration | 2 +
.../camel/component/netty/NettyConfiguration.java | 2 +-
4 files changed, 599 insertions(+), 1 deletion(-)
diff --git a/components/camel-netty-http/pom.xml b/components/camel-netty-http/pom.xml
index 5d43f62..e9433cc 100644
--- a/components/camel-netty-http/pom.xml
+++ b/components/camel-netty-http/pom.xml
@@ -132,6 +132,24 @@
<build>
<plugins>
<plugin>
+ <!-- we need to generate additional configurer classes -->
+ <groupId>org.apache.camel</groupId>
+ <artifactId>camel-package-maven-plugin</artifactId>
+ <executions>
+ <execution>
+ <id>generate-configurer</id>
+ <phase>process-classes</phase>
+ <goals>
+ <goal>generate-configurer</goal>
+ </goals>
+ <configuration>
+ <discoverClasses>true</discoverClasses>
+ <classes>org.apache.camel.component.netty.http.NettyHttpConfiguration</classes>
+ </configuration>
+ </execution>
+ </executions>
+ </plugin>
+ <plugin>
<artifactId>maven-surefire-plugin</artifactId>
<configuration>
<forkCount>1</forkCount>
diff --git a/components/camel-netty-http/src/generated/java/org/apache/camel/component/netty/http/NettyHttpConfigurationConfigurer.java b/components/camel-netty-http/src/generated/java/org/apache/camel/component/netty/http/NettyHttpConfigurationConfigurer.java
new file mode 100644
index 0000000..9ab13aa
--- /dev/null
+++ b/components/camel-netty-http/src/generated/java/org/apache/camel/component/netty/http/NettyHttpConfigurationConfigurer.java
@@ -0,0 +1,578 @@
+/* Generated by camel build tools - do NOT edit this file! */
+package org.apache.camel.component.netty.http;
+
+import java.util.Map;
+
+import org.apache.camel.CamelContext;
+import org.apache.camel.spi.ExtendedPropertyConfigurerGetter;
+import org.apache.camel.spi.PropertyConfigurerGetter;
+import org.apache.camel.spi.ConfigurerStrategy;
+import org.apache.camel.spi.GeneratedPropertyConfigurer;
+import org.apache.camel.util.CaseInsensitiveMap;
+import org.apache.camel.component.netty.http.NettyHttpConfiguration;
+
+/**
+ * Generated by camel build tools - do NOT edit this file!
+ */
+@SuppressWarnings("unchecked")
+public class NettyHttpConfigurationConfigurer extends org.apache.camel.support.component.PropertyConfigurerSupport implements GeneratedPropertyConfigurer, PropertyConfigurerGetter {
+
+ @Override
+ public boolean configure(CamelContext camelContext, Object obj, String name, Object value, boolean ignoreCase) {
+ org.apache.camel.component.netty.http.NettyHttpConfiguration target = (org.apache.camel.component.netty.http.NettyHttpConfiguration) obj;
+ switch (ignoreCase ? name.toLowerCase() : name) {
+ case "allowdefaultcodec":
+ case "AllowDefaultCodec": target.setAllowDefaultCodec(property(camelContext, boolean.class, value)); return true;
+ case "allowserializedheaders":
+ case "AllowSerializedHeaders": target.setAllowSerializedHeaders(property(camelContext, boolean.class, value)); return true;
+ case "autoappenddelimiter":
+ case "AutoAppendDelimiter": target.setAutoAppendDelimiter(property(camelContext, boolean.class, value)); return true;
+ case "backlog":
+ case "Backlog": target.setBacklog(property(camelContext, int.class, value)); return true;
+ case "bosscount":
+ case "BossCount": target.setBossCount(property(camelContext, int.class, value)); return true;
+ case "bossgroup":
+ case "BossGroup": target.setBossGroup(property(camelContext, io.netty.channel.EventLoopGroup.class, value)); return true;
+ case "bridgeendpoint":
+ case "BridgeEndpoint": target.setBridgeEndpoint(property(camelContext, boolean.class, value)); return true;
+ case "broadcast":
+ case "Broadcast": target.setBroadcast(property(camelContext, boolean.class, value)); return true;
+ case "channelgroup":
+ case "ChannelGroup": target.setChannelGroup(property(camelContext, io.netty.channel.group.ChannelGroup.class, value)); return true;
+ case "chunkedmaxcontentlength":
+ case "ChunkedMaxContentLength": target.setChunkedMaxContentLength(property(camelContext, int.class, value)); return true;
+ case "clientinitializerfactory":
+ case "ClientInitializerFactory": target.setClientInitializerFactory(property(camelContext, org.apache.camel.component.netty.ClientInitializerFactory.class, value)); return true;
+ case "clientmode":
+ case "ClientMode": target.setClientMode(property(camelContext, boolean.class, value)); return true;
+ case "clientpipelinefactory":
+ case "ClientPipelineFactory": target.setClientPipelineFactory(property(camelContext, org.apache.camel.component.netty.ClientInitializerFactory.class, value)); return true;
+ case "compression":
+ case "Compression": target.setCompression(property(camelContext, boolean.class, value)); return true;
+ case "connecttimeout":
+ case "ConnectTimeout": target.setConnectTimeout(property(camelContext, int.class, value)); return true;
+ case "correlationmanager":
+ case "CorrelationManager": target.setCorrelationManager(property(camelContext, org.apache.camel.component.netty.NettyCamelStateCorrelationManager.class, value)); return true;
+ case "decodermaxlinelength":
+ case "DecoderMaxLineLength": target.setDecoderMaxLineLength(property(camelContext, int.class, value)); return true;
+ case "decoders":
+ case "Decoders": target.setDecoders(property(camelContext, java.util.List.class, value)); return true;
+ case "delimiter":
+ case "Delimiter": target.setDelimiter(property(camelContext, org.apache.camel.component.netty.TextLineDelimiter.class, value)); return true;
+ case "disablestreamcache":
+ case "DisableStreamCache": target.setDisableStreamCache(property(camelContext, boolean.class, value)); return true;
+ case "disconnect":
+ case "Disconnect": target.setDisconnect(property(camelContext, boolean.class, value)); return true;
+ case "disconnectonnoreply":
+ case "DisconnectOnNoReply": target.setDisconnectOnNoReply(property(camelContext, boolean.class, value)); return true;
+ case "enabledprotocols":
+ case "EnabledProtocols": target.setEnabledProtocols(property(camelContext, java.lang.String.class, value)); return true;
+ case "encoders":
+ case "Encoders": target.setEncoders(property(camelContext, java.util.List.class, value)); return true;
+ case "encoding":
+ case "Encoding": target.setEncoding(property(camelContext, java.lang.String.class, value)); return true;
+ case "host":
+ case "Host": target.setHost(property(camelContext, java.lang.String.class, value)); return true;
+ case "keepalive":
+ case "KeepAlive": target.setKeepAlive(property(camelContext, boolean.class, value)); return true;
+ case "keystorefile":
+ case "KeyStoreFile": target.setKeyStoreFile(property(camelContext, java.io.File.class, value)); return true;
+ case "keystoreformat":
+ case "KeyStoreFormat": target.setKeyStoreFormat(property(camelContext, java.lang.String.class, value)); return true;
+ case "keystoreresource":
+ case "KeyStoreResource": target.setKeyStoreResource(property(camelContext, java.lang.String.class, value)); return true;
+ case "lazychannelcreation":
+ case "LazyChannelCreation": target.setLazyChannelCreation(property(camelContext, boolean.class, value)); return true;
+ case "logwarnonbadrequest":
+ case "LogWarnOnBadRequest": target.setLogWarnOnBadRequest(property(camelContext, boolean.class, value)); return true;
+ case "mapheaders":
+ case "MapHeaders": target.setMapHeaders(property(camelContext, boolean.class, value)); return true;
+ case "matchonuriprefix":
+ case "MatchOnUriPrefix": target.setMatchOnUriPrefix(property(camelContext, boolean.class, value)); return true;
+ case "maxheadersize":
+ case "MaxHeaderSize": target.setMaxHeaderSize(property(camelContext, int.class, value)); return true;
+ case "muteexception":
+ case "MuteException": target.setMuteException(property(camelContext, boolean.class, value)); return true;
+ case "nativetransport":
+ case "NativeTransport": target.setNativeTransport(property(camelContext, boolean.class, value)); return true;
+ case "needclientauth":
+ case "NeedClientAuth": target.setNeedClientAuth(property(camelContext, boolean.class, value)); return true;
+ case "nettyserverbootstrapfactory":
+ case "NettyServerBootstrapFactory": target.setNettyServerBootstrapFactory(property(camelContext, org.apache.camel.component.netty.NettyServerBootstrapFactory.class, value)); return true;
+ case "networkinterface":
+ case "NetworkInterface": target.setNetworkInterface(property(camelContext, java.lang.String.class, value)); return true;
+ case "noreplyloglevel":
+ case "NoReplyLogLevel": target.setNoReplyLogLevel(property(camelContext, org.apache.camel.LoggingLevel.class, value)); return true;
+ case "okstatuscoderange":
+ case "OkStatusCodeRange": target.setOkStatusCodeRange(property(camelContext, java.lang.String.class, value)); return true;
+ case "options":
+ case "Options": target.setOptions(property(camelContext, java.util.Map.class, value)); return true;
+ case "passphrase":
+ case "Passphrase": target.setPassphrase(property(camelContext, java.lang.String.class, value)); return true;
+ case "path":
+ case "Path": target.setPath(property(camelContext, java.lang.String.class, value)); return true;
+ case "port":
+ case "Port": target.setPort(property(camelContext, int.class, value)); return true;
+ case "producerpoolenabled":
+ case "ProducerPoolEnabled": target.setProducerPoolEnabled(property(camelContext, boolean.class, value)); return true;
+ case "producerpoolmaxactive":
+ case "ProducerPoolMaxActive": target.setProducerPoolMaxActive(property(camelContext, int.class, value)); return true;
+ case "producerpoolmaxidle":
+ case "ProducerPoolMaxIdle": target.setProducerPoolMaxIdle(property(camelContext, int.class, value)); return true;
+ case "producerpoolminevictableidle":
+ case "ProducerPoolMinEvictableIdle": target.setProducerPoolMinEvictableIdle(property(camelContext, long.class, value)); return true;
+ case "producerpoolminidle":
+ case "ProducerPoolMinIdle": target.setProducerPoolMinIdle(property(camelContext, int.class, value)); return true;
+ case "protocol":
+ case "Protocol": target.setProtocol(property(camelContext, java.lang.String.class, value)); return true;
+ case "receivebuffersize":
+ case "ReceiveBufferSize": target.setReceiveBufferSize(property(camelContext, int.class, value)); return true;
+ case "receivebuffersizepredictor":
+ case "ReceiveBufferSizePredictor": target.setReceiveBufferSizePredictor(property(camelContext, int.class, value)); return true;
+ case "reconnect":
+ case "Reconnect": target.setReconnect(property(camelContext, boolean.class, value)); return true;
+ case "reconnectinterval":
+ case "ReconnectInterval": target.setReconnectInterval(property(camelContext, int.class, value)); return true;
+ case "requesttimeout":
+ case "RequestTimeout": target.setRequestTimeout(property(camelContext, long.class, value)); return true;
+ case "reuseaddress":
+ case "ReuseAddress": target.setReuseAddress(property(camelContext, boolean.class, value)); return true;
+ case "reusechannel":
+ case "ReuseChannel": target.setReuseChannel(property(camelContext, boolean.class, value)); return true;
+ case "securityprovider":
+ case "SecurityProvider": target.setSecurityProvider(property(camelContext, java.lang.String.class, value)); return true;
+ case "send503whensuspended":
+ case "Send503whenSuspended": target.setSend503whenSuspended(property(camelContext, boolean.class, value)); return true;
+ case "sendbuffersize":
+ case "SendBufferSize": target.setSendBufferSize(property(camelContext, int.class, value)); return true;
+ case "serverclosedchannelexceptioncaughtloglevel":
+ case "ServerClosedChannelExceptionCaughtLogLevel": target.setServerClosedChannelExceptionCaughtLogLevel(property(camelContext, org.apache.camel.LoggingLevel.class, value)); return true;
+ case "serverexceptioncaughtloglevel":
+ case "ServerExceptionCaughtLogLevel": target.setServerExceptionCaughtLogLevel(property(camelContext, org.apache.camel.LoggingLevel.class, value)); return true;
+ case "serverinitializerfactory":
+ case "ServerInitializerFactory": target.setServerInitializerFactory(property(camelContext, org.apache.camel.component.netty.ServerInitializerFactory.class, value)); return true;
+ case "serverpipelinefactory":
+ case "ServerPipelineFactory": target.setServerPipelineFactory(property(camelContext, org.apache.camel.component.netty.ServerInitializerFactory.class, value)); return true;
+ case "ssl":
+ case "Ssl": target.setSsl(property(camelContext, boolean.class, value)); return true;
+ case "sslclientcertheaders":
+ case "SslClientCertHeaders": target.setSslClientCertHeaders(property(camelContext, boolean.class, value)); return true;
+ case "sslcontextparameters":
+ case "SslContextParameters": target.setSslContextParameters(property(camelContext, org.apache.camel.support.jsse.SSLContextParameters.class, value)); return true;
+ case "sslhandler":
+ case "SslHandler": target.setSslHandler(property(camelContext, io.netty.handler.ssl.SslHandler.class, value)); return true;
+ case "sync":
+ case "Sync": target.setSync(property(camelContext, boolean.class, value)); return true;
+ case "synchronous":
+ case "Synchronous": target.setSynchronous(property(camelContext, boolean.class, value)); return true;
+ case "tcpnodelay":
+ case "TcpNoDelay": target.setTcpNoDelay(property(camelContext, boolean.class, value)); return true;
+ case "textline":
+ case "Textline": target.setTextline(property(camelContext, boolean.class, value)); return true;
+ case "throwexceptiononfailure":
+ case "ThrowExceptionOnFailure": target.setThrowExceptionOnFailure(property(camelContext, boolean.class, value)); return true;
+ case "transferexception":
+ case "TransferException": target.setTransferException(property(camelContext, boolean.class, value)); return true;
+ case "transferexchange":
+ case "TransferExchange": target.setTransferExchange(property(camelContext, boolean.class, value)); return true;
+ case "truststorefile":
+ case "TrustStoreFile": target.setTrustStoreFile(property(camelContext, java.io.File.class, value)); return true;
+ case "truststoreresource":
+ case "TrustStoreResource": target.setTrustStoreResource(property(camelContext, java.lang.String.class, value)); return true;
+ case "udpbytearraycodec":
+ case "UdpByteArrayCodec": target.setUdpByteArrayCodec(property(camelContext, boolean.class, value)); return true;
+ case "udpconnectionlesssending":
+ case "UdpConnectionlessSending": target.setUdpConnectionlessSending(property(camelContext, boolean.class, value)); return true;
+ case "urldecodeheaders":
+ case "UrlDecodeHeaders": target.setUrlDecodeHeaders(property(camelContext, boolean.class, value)); return true;
+ case "usebytebuf":
+ case "UseByteBuf": target.setUseByteBuf(property(camelContext, boolean.class, value)); return true;
+ case "userelativepath":
+ case "UseRelativePath": target.setUseRelativePath(property(camelContext, boolean.class, value)); return true;
+ case "usingexecutorservice":
+ case "UsingExecutorService": target.setUsingExecutorService(property(camelContext, boolean.class, value)); return true;
+ case "workercount":
+ case "WorkerCount": target.setWorkerCount(property(camelContext, int.class, value)); return true;
+ case "workergroup":
+ case "WorkerGroup": target.setWorkerGroup(property(camelContext, io.netty.channel.EventLoopGroup.class, value)); return true;
+ default: return false;
+ }
+ }
+
+ @Override
+ public Class<?> getOptionType(String name, boolean ignoreCase) {
+ switch (ignoreCase ? name.toLowerCase() : name) {
+ case "allowdefaultcodec":
+ case "AllowDefaultCodec": return boolean.class;
+ case "allowserializedheaders":
+ case "AllowSerializedHeaders": return boolean.class;
+ case "autoappenddelimiter":
+ case "AutoAppendDelimiter": return boolean.class;
+ case "backlog":
+ case "Backlog": return int.class;
+ case "bosscount":
+ case "BossCount": return int.class;
+ case "bossgroup":
+ case "BossGroup": return io.netty.channel.EventLoopGroup.class;
+ case "bridgeendpoint":
+ case "BridgeEndpoint": return boolean.class;
+ case "broadcast":
+ case "Broadcast": return boolean.class;
+ case "channelgroup":
+ case "ChannelGroup": return io.netty.channel.group.ChannelGroup.class;
+ case "chunkedmaxcontentlength":
+ case "ChunkedMaxContentLength": return int.class;
+ case "clientinitializerfactory":
+ case "ClientInitializerFactory": return org.apache.camel.component.netty.ClientInitializerFactory.class;
+ case "clientmode":
+ case "ClientMode": return boolean.class;
+ case "clientpipelinefactory":
+ case "ClientPipelineFactory": return org.apache.camel.component.netty.ClientInitializerFactory.class;
+ case "compression":
+ case "Compression": return boolean.class;
+ case "connecttimeout":
+ case "ConnectTimeout": return int.class;
+ case "correlationmanager":
+ case "CorrelationManager": return org.apache.camel.component.netty.NettyCamelStateCorrelationManager.class;
+ case "decodermaxlinelength":
+ case "DecoderMaxLineLength": return int.class;
+ case "decoders":
+ case "Decoders": return java.util.List.class;
+ case "delimiter":
+ case "Delimiter": return org.apache.camel.component.netty.TextLineDelimiter.class;
+ case "disablestreamcache":
+ case "DisableStreamCache": return boolean.class;
+ case "disconnect":
+ case "Disconnect": return boolean.class;
+ case "disconnectonnoreply":
+ case "DisconnectOnNoReply": return boolean.class;
+ case "enabledprotocols":
+ case "EnabledProtocols": return java.lang.String.class;
+ case "encoders":
+ case "Encoders": return java.util.List.class;
+ case "encoding":
+ case "Encoding": return java.lang.String.class;
+ case "host":
+ case "Host": return java.lang.String.class;
+ case "keepalive":
+ case "KeepAlive": return boolean.class;
+ case "keystorefile":
+ case "KeyStoreFile": return java.io.File.class;
+ case "keystoreformat":
+ case "KeyStoreFormat": return java.lang.String.class;
+ case "keystoreresource":
+ case "KeyStoreResource": return java.lang.String.class;
+ case "lazychannelcreation":
+ case "LazyChannelCreation": return boolean.class;
+ case "logwarnonbadrequest":
+ case "LogWarnOnBadRequest": return boolean.class;
+ case "mapheaders":
+ case "MapHeaders": return boolean.class;
+ case "matchonuriprefix":
+ case "MatchOnUriPrefix": return boolean.class;
+ case "maxheadersize":
+ case "MaxHeaderSize": return int.class;
+ case "muteexception":
+ case "MuteException": return boolean.class;
+ case "nativetransport":
+ case "NativeTransport": return boolean.class;
+ case "needclientauth":
+ case "NeedClientAuth": return boolean.class;
+ case "nettyserverbootstrapfactory":
+ case "NettyServerBootstrapFactory": return org.apache.camel.component.netty.NettyServerBootstrapFactory.class;
+ case "networkinterface":
+ case "NetworkInterface": return java.lang.String.class;
+ case "noreplyloglevel":
+ case "NoReplyLogLevel": return org.apache.camel.LoggingLevel.class;
+ case "okstatuscoderange":
+ case "OkStatusCodeRange": return java.lang.String.class;
+ case "options":
+ case "Options": return java.util.Map.class;
+ case "passphrase":
+ case "Passphrase": return java.lang.String.class;
+ case "path":
+ case "Path": return java.lang.String.class;
+ case "port":
+ case "Port": return int.class;
+ case "producerpoolenabled":
+ case "ProducerPoolEnabled": return boolean.class;
+ case "producerpoolmaxactive":
+ case "ProducerPoolMaxActive": return int.class;
+ case "producerpoolmaxidle":
+ case "ProducerPoolMaxIdle": return int.class;
+ case "producerpoolminevictableidle":
+ case "ProducerPoolMinEvictableIdle": return long.class;
+ case "producerpoolminidle":
+ case "ProducerPoolMinIdle": return int.class;
+ case "protocol":
+ case "Protocol": return java.lang.String.class;
+ case "receivebuffersize":
+ case "ReceiveBufferSize": return int.class;
+ case "receivebuffersizepredictor":
+ case "ReceiveBufferSizePredictor": return int.class;
+ case "reconnect":
+ case "Reconnect": return boolean.class;
+ case "reconnectinterval":
+ case "ReconnectInterval": return int.class;
+ case "requesttimeout":
+ case "RequestTimeout": return long.class;
+ case "reuseaddress":
+ case "ReuseAddress": return boolean.class;
+ case "reusechannel":
+ case "ReuseChannel": return boolean.class;
+ case "securityprovider":
+ case "SecurityProvider": return java.lang.String.class;
+ case "send503whensuspended":
+ case "Send503whenSuspended": return boolean.class;
+ case "sendbuffersize":
+ case "SendBufferSize": return int.class;
+ case "serverclosedchannelexceptioncaughtloglevel":
+ case "ServerClosedChannelExceptionCaughtLogLevel": return org.apache.camel.LoggingLevel.class;
+ case "serverexceptioncaughtloglevel":
+ case "ServerExceptionCaughtLogLevel": return org.apache.camel.LoggingLevel.class;
+ case "serverinitializerfactory":
+ case "ServerInitializerFactory": return org.apache.camel.component.netty.ServerInitializerFactory.class;
+ case "serverpipelinefactory":
+ case "ServerPipelineFactory": return org.apache.camel.component.netty.ServerInitializerFactory.class;
+ case "ssl":
+ case "Ssl": return boolean.class;
+ case "sslclientcertheaders":
+ case "SslClientCertHeaders": return boolean.class;
+ case "sslcontextparameters":
+ case "SslContextParameters": return org.apache.camel.support.jsse.SSLContextParameters.class;
+ case "sslhandler":
+ case "SslHandler": return io.netty.handler.ssl.SslHandler.class;
+ case "sync":
+ case "Sync": return boolean.class;
+ case "synchronous":
+ case "Synchronous": return boolean.class;
+ case "tcpnodelay":
+ case "TcpNoDelay": return boolean.class;
+ case "textline":
+ case "Textline": return boolean.class;
+ case "throwexceptiononfailure":
+ case "ThrowExceptionOnFailure": return boolean.class;
+ case "transferexception":
+ case "TransferException": return boolean.class;
+ case "transferexchange":
+ case "TransferExchange": return boolean.class;
+ case "truststorefile":
+ case "TrustStoreFile": return java.io.File.class;
+ case "truststoreresource":
+ case "TrustStoreResource": return java.lang.String.class;
+ case "udpbytearraycodec":
+ case "UdpByteArrayCodec": return boolean.class;
+ case "udpconnectionlesssending":
+ case "UdpConnectionlessSending": return boolean.class;
+ case "urldecodeheaders":
+ case "UrlDecodeHeaders": return boolean.class;
+ case "usebytebuf":
+ case "UseByteBuf": return boolean.class;
+ case "userelativepath":
+ case "UseRelativePath": return boolean.class;
+ case "usingexecutorservice":
+ case "UsingExecutorService": return boolean.class;
+ case "workercount":
+ case "WorkerCount": return int.class;
+ case "workergroup":
+ case "WorkerGroup": return io.netty.channel.EventLoopGroup.class;
+ default: return null;
+ }
+ }
+
+ @Override
+ public Object getOptionValue(Object obj, String name, boolean ignoreCase) {
+ org.apache.camel.component.netty.http.NettyHttpConfiguration target = (org.apache.camel.component.netty.http.NettyHttpConfiguration) obj;
+ switch (ignoreCase ? name.toLowerCase() : name) {
+ case "allowdefaultcodec":
+ case "AllowDefaultCodec": return target.isAllowDefaultCodec();
+ case "allowserializedheaders":
+ case "AllowSerializedHeaders": return target.isAllowSerializedHeaders();
+ case "autoappenddelimiter":
+ case "AutoAppendDelimiter": return target.isAutoAppendDelimiter();
+ case "backlog":
+ case "Backlog": return target.getBacklog();
+ case "bosscount":
+ case "BossCount": return target.getBossCount();
+ case "bossgroup":
+ case "BossGroup": return target.getBossGroup();
+ case "bridgeendpoint":
+ case "BridgeEndpoint": return target.isBridgeEndpoint();
+ case "broadcast":
+ case "Broadcast": return target.isBroadcast();
+ case "channelgroup":
+ case "ChannelGroup": return target.getChannelGroup();
+ case "chunkedmaxcontentlength":
+ case "ChunkedMaxContentLength": return target.getChunkedMaxContentLength();
+ case "clientinitializerfactory":
+ case "ClientInitializerFactory": return target.getClientInitializerFactory();
+ case "clientmode":
+ case "ClientMode": return target.isClientMode();
+ case "clientpipelinefactory":
+ case "ClientPipelineFactory": return target.getClientPipelineFactory();
+ case "compression":
+ case "Compression": return target.isCompression();
+ case "connecttimeout":
+ case "ConnectTimeout": return target.getConnectTimeout();
+ case "correlationmanager":
+ case "CorrelationManager": return target.getCorrelationManager();
+ case "decodermaxlinelength":
+ case "DecoderMaxLineLength": return target.getDecoderMaxLineLength();
+ case "decoders":
+ case "Decoders": return target.getDecoders();
+ case "delimiter":
+ case "Delimiter": return target.getDelimiter();
+ case "disablestreamcache":
+ case "DisableStreamCache": return target.isDisableStreamCache();
+ case "disconnect":
+ case "Disconnect": return target.isDisconnect();
+ case "disconnectonnoreply":
+ case "DisconnectOnNoReply": return target.isDisconnectOnNoReply();
+ case "enabledprotocols":
+ case "EnabledProtocols": return target.getEnabledProtocols();
+ case "encoders":
+ case "Encoders": return target.getEncoders();
+ case "encoding":
+ case "Encoding": return target.getEncoding();
+ case "host":
+ case "Host": return target.getHost();
+ case "keepalive":
+ case "KeepAlive": return target.isKeepAlive();
+ case "keystorefile":
+ case "KeyStoreFile": return target.getKeyStoreFile();
+ case "keystoreformat":
+ case "KeyStoreFormat": return target.getKeyStoreFormat();
+ case "keystoreresource":
+ case "KeyStoreResource": return target.getKeyStoreResource();
+ case "lazychannelcreation":
+ case "LazyChannelCreation": return target.isLazyChannelCreation();
+ case "logwarnonbadrequest":
+ case "LogWarnOnBadRequest": return target.isLogWarnOnBadRequest();
+ case "mapheaders":
+ case "MapHeaders": return target.isMapHeaders();
+ case "matchonuriprefix":
+ case "MatchOnUriPrefix": return target.isMatchOnUriPrefix();
+ case "maxheadersize":
+ case "MaxHeaderSize": return target.getMaxHeaderSize();
+ case "muteexception":
+ case "MuteException": return target.isMuteException();
+ case "nativetransport":
+ case "NativeTransport": return target.isNativeTransport();
+ case "needclientauth":
+ case "NeedClientAuth": return target.isNeedClientAuth();
+ case "nettyserverbootstrapfactory":
+ case "NettyServerBootstrapFactory": return target.getNettyServerBootstrapFactory();
+ case "networkinterface":
+ case "NetworkInterface": return target.getNetworkInterface();
+ case "noreplyloglevel":
+ case "NoReplyLogLevel": return target.getNoReplyLogLevel();
+ case "okstatuscoderange":
+ case "OkStatusCodeRange": return target.getOkStatusCodeRange();
+ case "options":
+ case "Options": return target.getOptions();
+ case "passphrase":
+ case "Passphrase": return target.getPassphrase();
+ case "path":
+ case "Path": return target.getPath();
+ case "port":
+ case "Port": return target.getPort();
+ case "producerpoolenabled":
+ case "ProducerPoolEnabled": return target.isProducerPoolEnabled();
+ case "producerpoolmaxactive":
+ case "ProducerPoolMaxActive": return target.getProducerPoolMaxActive();
+ case "producerpoolmaxidle":
+ case "ProducerPoolMaxIdle": return target.getProducerPoolMaxIdle();
+ case "producerpoolminevictableidle":
+ case "ProducerPoolMinEvictableIdle": return target.getProducerPoolMinEvictableIdle();
+ case "producerpoolminidle":
+ case "ProducerPoolMinIdle": return target.getProducerPoolMinIdle();
+ case "protocol":
+ case "Protocol": return target.getProtocol();
+ case "receivebuffersize":
+ case "ReceiveBufferSize": return target.getReceiveBufferSize();
+ case "receivebuffersizepredictor":
+ case "ReceiveBufferSizePredictor": return target.getReceiveBufferSizePredictor();
+ case "reconnect":
+ case "Reconnect": return target.isReconnect();
+ case "reconnectinterval":
+ case "ReconnectInterval": return target.getReconnectInterval();
+ case "requesttimeout":
+ case "RequestTimeout": return target.getRequestTimeout();
+ case "reuseaddress":
+ case "ReuseAddress": return target.isReuseAddress();
+ case "reusechannel":
+ case "ReuseChannel": return target.isReuseChannel();
+ case "securityprovider":
+ case "SecurityProvider": return target.getSecurityProvider();
+ case "send503whensuspended":
+ case "Send503whenSuspended": return target.isSend503whenSuspended();
+ case "sendbuffersize":
+ case "SendBufferSize": return target.getSendBufferSize();
+ case "serverclosedchannelexceptioncaughtloglevel":
+ case "ServerClosedChannelExceptionCaughtLogLevel": return target.getServerClosedChannelExceptionCaughtLogLevel();
+ case "serverexceptioncaughtloglevel":
+ case "ServerExceptionCaughtLogLevel": return target.getServerExceptionCaughtLogLevel();
+ case "serverinitializerfactory":
+ case "ServerInitializerFactory": return target.getServerInitializerFactory();
+ case "serverpipelinefactory":
+ case "ServerPipelineFactory": return target.getServerPipelineFactory();
+ case "ssl":
+ case "Ssl": return target.isSsl();
+ case "sslclientcertheaders":
+ case "SslClientCertHeaders": return target.isSslClientCertHeaders();
+ case "sslcontextparameters":
+ case "SslContextParameters": return target.getSslContextParameters();
+ case "sslhandler":
+ case "SslHandler": return target.getSslHandler();
+ case "sync":
+ case "Sync": return target.isSync();
+ case "synchronous":
+ case "Synchronous": return target.isSynchronous();
+ case "tcpnodelay":
+ case "TcpNoDelay": return target.isTcpNoDelay();
+ case "textline":
+ case "Textline": return target.isTextline();
+ case "throwexceptiononfailure":
+ case "ThrowExceptionOnFailure": return target.isThrowExceptionOnFailure();
+ case "transferexception":
+ case "TransferException": return target.isTransferException();
+ case "transferexchange":
+ case "TransferExchange": return target.isTransferExchange();
+ case "truststorefile":
+ case "TrustStoreFile": return target.getTrustStoreFile();
+ case "truststoreresource":
+ case "TrustStoreResource": return target.getTrustStoreResource();
+ case "udpbytearraycodec":
+ case "UdpByteArrayCodec": return target.isUdpByteArrayCodec();
+ case "udpconnectionlesssending":
+ case "UdpConnectionlessSending": return target.isUdpConnectionlessSending();
+ case "urldecodeheaders":
+ case "UrlDecodeHeaders": return target.isUrlDecodeHeaders();
+ case "usebytebuf":
+ case "UseByteBuf": return target.isUseByteBuf();
+ case "userelativepath":
+ case "UseRelativePath": return target.isUseRelativePath();
+ case "usingexecutorservice":
+ case "UsingExecutorService": return target.isUsingExecutorService();
+ case "workercount":
+ case "WorkerCount": return target.getWorkerCount();
+ case "workergroup":
+ case "WorkerGroup": return target.getWorkerGroup();
+ default: return null;
+ }
+ }
+
+ @Override
+ public Object getCollectionValueType(Object target, String name, boolean ignoreCase) {
+ switch (ignoreCase ? name.toLowerCase() : name) {
+ case "decoders":
+ case "Decoders": return io.netty.channel.ChannelHandler.class;
+ case "encoders":
+ case "Encoders": return io.netty.channel.ChannelHandler.class;
+ case "options":
+ case "Options": return java.lang.Object.class;
+ default: return null;
+ }
+ }
+}
+
diff --git a/components/camel-netty-http/src/generated/resources/META-INF/services/org/apache/camel/configurer/org.apache.camel.component.netty.http.NettyHttpConfiguration b/components/camel-netty-http/src/generated/resources/META-INF/services/org/apache/camel/configurer/org.apache.camel.component.netty.http.NettyHttpConfiguration
new file mode 100644
index 0000000..3c8633f
--- /dev/null
+++ b/components/camel-netty-http/src/generated/resources/META-INF/services/org/apache/camel/configurer/org.apache.camel.component.netty.http.NettyHttpConfiguration
@@ -0,0 +1,2 @@
+# Generated by camel build tools - do NOT edit this file!
+class=org.apache.camel.component.netty.http.NettyHttpConfigurationConfigurer
diff --git a/components/camel-netty/src/main/java/org/apache/camel/component/netty/NettyConfiguration.java b/components/camel-netty/src/main/java/org/apache/camel/component/netty/NettyConfiguration.java
index 172660d..4315ccd 100644
--- a/components/camel-netty/src/main/java/org/apache/camel/component/netty/NettyConfiguration.java
+++ b/components/camel-netty/src/main/java/org/apache/camel/component/netty/NettyConfiguration.java
@@ -212,7 +212,7 @@ public class NettyConfiguration extends NettyServerBootstrapConfiguration implem
// then set parameters with the help of the camel context type converters
// and use configurer to avoid any reflection calls
PropertyConfigurer configurer = component.getCamelContext().adapt(ExtendedCamelContext.class).getConfigurerResolver()
- .resolvePropertyConfigurer(NettyConfiguration.class.getName(), component.getCamelContext());
+ .resolvePropertyConfigurer(this.getClass().getName(), component.getCamelContext());
PropertyBindingSupport.build()
.withCamelContext(component.getCamelContext())
.withTarget(this)