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:59:20 UTC
[camel] branch camel-3.7.x updated (036cc7d -> 5f805f8)
This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a change to branch camel-3.7.x
in repository https://gitbox.apache.org/repos/asf/camel.git.
from 036cc7d Sync deps
new d8dadf8 Polished
new be7ec1f CAMEL-16129: camel-netty - Avoid reflection when configuring endpoints.
new 5f805f8 CAMEL-16129: camel-netty - Avoid reflection when configuring endpoints.
The 3 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:
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 +-
8 files changed, 1112 insertions(+), 8 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] 02/03: 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 camel-3.7.x
in repository https://gitbox.apache.org/repos/asf/camel.git
commit be7ec1f69676f05119ade6c0bbb4ca8033898cc7
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 72b84db..bd8518d 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/03: 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 camel-3.7.x
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 5f805f800c1aeaca72d8a7437f639cb1b7824f5c
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 a6959e6..ecfa9a3 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)
[camel] 01/03: Polished
Posted by da...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch camel-3.7.x
in repository https://gitbox.apache.org/repos/asf/camel.git
commit d8dadf89260d98ad8738032bed27402f28f5507d
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);
}