Repository: camel Updated Branches: refs/heads/master 63df40219 -> 1e9700b05
Component docs Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/1e9700b0 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/1e9700b0 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/1e9700b0 Branch: refs/heads/master Commit: 1e9700b05bcfd5f1bc7cc5ad9e8c76ea03d18ff2 Parents: 63df402 Author: Claus Ibsen <davscl...@apache.org> Authored: Sun Jun 14 16:40:24 2015 +0200 Committer: Claus Ibsen <davscl...@apache.org> Committed: Sun Jun 14 16:55:41 2015 +0200 ---------------------------------------------------------------------- .../component/jetty/JettyHttpComponent.java | 8 +- .../component/jetty/JettyHttpEndpoint.java | 103 +++++++++++++++---- .../netty/http/NettyHttpComponent.java | 9 ++ .../netty/http/NettyHttpConfiguration.java | 68 +++++++++--- .../component/netty/http/NettyHttpEndpoint.java | 22 ++++ 5 files changed, 172 insertions(+), 38 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/1e9700b0/components/camel-jetty-common/src/main/java/org/apache/camel/component/jetty/JettyHttpComponent.java ---------------------------------------------------------------------- diff --git a/components/camel-jetty-common/src/main/java/org/apache/camel/component/jetty/JettyHttpComponent.java b/components/camel-jetty-common/src/main/java/org/apache/camel/component/jetty/JettyHttpComponent.java index c3bc309..d079be2 100644 --- a/components/camel-jetty-common/src/main/java/org/apache/camel/component/jetty/JettyHttpComponent.java +++ b/components/camel-jetty-common/src/main/java/org/apache/camel/component/jetty/JettyHttpComponent.java @@ -29,7 +29,6 @@ import java.util.HashMap; import java.util.List; import java.util.Locale; import java.util.Map; - import javax.management.MBeanServer; import javax.servlet.Filter; import javax.servlet.RequestDispatcher; @@ -362,7 +361,6 @@ public abstract class JettyHttpComponent extends HttpComponent implements RestCo connectorRef.servlet.connect(consumer); } } - private void enableJmx(Server server) { MBeanContainer containerToRegister = getMbContainer(); @@ -500,7 +498,6 @@ public abstract class JettyHttpComponent extends HttpComponent implements RestCo return sslKeystore; } - public ErrorHandler getErrorHandler() { return errorHandler; } @@ -542,7 +539,6 @@ public abstract class JettyHttpComponent extends HttpComponent implements RestCo protected Connector createConnector(Server server, JettyHttpEndpoint endpoint) { - // now we just use the SelectChannelConnector as the default connector SslContextFactory sslcf = null; @@ -627,7 +623,7 @@ public abstract class JettyHttpComponent extends HttpComponent implements RestCo * Creates a new {@link HttpClient} and configures its proxy/thread pool and SSL based on this * component settings. * - * @Param endpoint the instance of JettyHttpEndpoint + * @param endpoint the instance of JettyHttpEndpoint * @param minThreads optional minimum number of threads in client thread pool * @param maxThreads optional maximum number of threads in client thread pool * @param ssl option SSL parameters @@ -873,7 +869,6 @@ public abstract class JettyHttpComponent extends HttpComponent implements RestCo // Implementation methods // ------------------------------------------------------------------------- - @Override public Consumer createConsumer(CamelContext camelContext, Processor processor, String verb, String basePath, String uriTemplate, String consumes, String produces, Map<String, Object> parameters) throws Exception { @@ -1014,7 +1009,6 @@ public abstract class JettyHttpComponent extends HttpComponent implements RestCo } } } - } protected Server createServer() { http://git-wip-us.apache.org/repos/asf/camel/blob/1e9700b0/components/camel-jetty-common/src/main/java/org/apache/camel/component/jetty/JettyHttpEndpoint.java ---------------------------------------------------------------------- diff --git a/components/camel-jetty-common/src/main/java/org/apache/camel/component/jetty/JettyHttpEndpoint.java b/components/camel-jetty-common/src/main/java/org/apache/camel/component/jetty/JettyHttpEndpoint.java index 4b17416..12d944c 100644 --- a/components/camel-jetty-common/src/main/java/org/apache/camel/component/jetty/JettyHttpEndpoint.java +++ b/components/camel-jetty-common/src/main/java/org/apache/camel/component/jetty/JettyHttpEndpoint.java @@ -42,31 +42,49 @@ import org.eclipse.jetty.server.Handler; */ public abstract class JettyHttpEndpoint extends HttpEndpoint { - @UriParam - private boolean sessionSupport; private List<Handler> handlers; private HttpClient client; - @UriParam + private Filter multipartFilter; + private List<Filter> filters; + private SSLContextParameters sslContextParameters; + private Map<String, Object> httpClientParameters; + private JettyHttpBinding jettyBinding; + + @UriParam(label = "consumer", + description = "Specifies whether to enable the session manager on the server side of Jetty.") + private boolean sessionSupport; + @UriParam(label = "producer", defaultValue = "8", + description = "To set a value for minimum number of threads in HttpClient thread pool." + + " This setting override any setting configured on component level." + + " Notice that both a min and max size must be configured. If not set it default to min 8 threads used in Jettys thread pool.") private Integer httpClientMinThreads; - @UriParam + @UriParam(label = "producer", defaultValue = "254", + description = "To set a value for maximum number of threads in HttpClient thread pool." + + " This setting override any setting configured on component level." + + " Notice that both a min and max size must be configured. If not set it default to max 254 threads used in Jettys thread pool.") private Integer httpClientMaxThreads; - private JettyHttpBinding jettyBinding; - @UriParam + @UriParam(label = "consumer", + description = "If this option is true, Jetty JMX support will be enabled for this endpoint. See Jetty JMX support for more details.") private boolean enableJmx; - @UriParam + @UriParam(description = "Whether Jetty org.eclipse.jetty.servlets.MultiPartFilter is enabled or not." + + " You should set this value to false when bridging endpoints, to ensure multipart requests is proxied/bridged as well.") private boolean enableMultipartFilter; - @UriParam(defaultValue = "true") + @UriParam(label = "consumer", defaultValue = "true", + description = "If the option is true, jetty will send the server header with the jetty version information to the client which sends the request." + + " NOTE please make sure there is no any other camel-jetty endpoint is share the same port, otherwise this option may not work as expected.") private boolean sendServerVersion = true; - @UriParam + @UriParam(label = "consumer", description = "If the option is true, jetty server will send the date header to the client which sends the request." + + " NOTE please make sure there is no any other camel-jetty endpoint is share the same port, otherwise this option may not work as expected.") private boolean sendDateHeader; - private Filter multipartFilter; - private List<Filter> filters; - @UriParam + @UriParam(label = "consumer", defaultValue = "30000", + description = "Allows to set a timeout in millis when using Jetty as consumer (server)." + + " By default Jetty uses 30000. You can use a value of <= 0 to never expire." + + " If a timeout occurs then the request will be expired and Jetty will return back a http error 503 to the client." + + " This option is only in use when using Jetty with the Asynchronous Routing Engine.") private Long continuationTimeout; - @UriParam + @UriParam(label = "consumer", + description = "Whether or not to use Jetty continuations for the Jetty Server.") private Boolean useContinuation; - private SSLContextParameters sslContextParameters; - private Map<String, Object> httpClientParameters; public JettyHttpEndpoint(JettyHttpComponent component, String uri, URI httpURL) throws URISyntaxException { super(uri, component, httpURL); @@ -128,8 +146,11 @@ public abstract class JettyHttpEndpoint extends HttpEndpoint { HttpConsumer answer = new HttpConsumer(this, processor); configureConsumer(answer); return answer; - } + } + /** + * Specifies whether to enable the session manager on the server side of Jetty. + */ public void setSessionSupport(boolean support) { sessionSupport = support; } @@ -184,6 +205,9 @@ public abstract class JettyHttpEndpoint extends HttpEndpoint { return this.enableJmx; } + /** + * If this option is true, Jetty JMX support will be enabled for this endpoint. See Jetty JMX support for more details. + */ public void setEnableJmx(boolean enableJmx) { this.enableJmx = enableJmx; } @@ -191,7 +215,11 @@ public abstract class JettyHttpEndpoint extends HttpEndpoint { public boolean isSendServerVersion() { return sendServerVersion; } - + + /** + * If the option is true, jetty will send the server header with the jetty version information to the client which sends the request. + * NOTE please make sure there is no any other camel-jetty endpoint is share the same port, otherwise this option may not work as expected. + */ public void setSendServerVersion(boolean sendServerVersion) { this.sendServerVersion = sendServerVersion; } @@ -199,7 +227,11 @@ public abstract class JettyHttpEndpoint extends HttpEndpoint { public boolean isSendDateHeader() { return sendDateHeader; } - + + /** + * If the option is true, jetty server will send the date header to the client which sends the request. + * NOTE please make sure there is no any other camel-jetty endpoint is share the same port, otherwise this option may not work as expected. + */ public void setSendDateHeader(boolean sendDateHeader) { this.sendDateHeader = sendDateHeader; } @@ -208,10 +240,17 @@ public abstract class JettyHttpEndpoint extends HttpEndpoint { return enableMultipartFilter; } + /** + * Whether Jetty org.eclipse.jetty.servlets.MultiPartFilter is enabled or not. + * You should set this value to false when bridging endpoints, to ensure multipart requests is proxied/bridged as well. + */ public void setEnableMultipartFilter(boolean enableMultipartFilter) { this.enableMultipartFilter = enableMultipartFilter; } - + + /** + * Allows using a custom multipart filter. Note: setting multipartFilter forces the value of enableMultipartFilter to true. + */ public void setMultipartFilter(Filter filter) { this.multipartFilter = filter; } @@ -232,6 +271,12 @@ public abstract class JettyHttpEndpoint extends HttpEndpoint { return continuationTimeout; } + /** + * Allows to set a timeout in millis when using Jetty as consumer (server). + * By default Jetty uses 30000. You can use a value of <= 0 to never expire. + * If a timeout occurs then the request will be expired and Jetty will return back a http error 503 to the client. + * This option is only in use when using Jetty with the Asynchronous Routing Engine. + */ public void setContinuationTimeout(Long continuationTimeout) { this.continuationTimeout = continuationTimeout; } @@ -240,6 +285,9 @@ public abstract class JettyHttpEndpoint extends HttpEndpoint { return useContinuation; } + /** + * Whether or not to use Jetty continuations for the Jetty Server. + */ public void setUseContinuation(Boolean useContinuation) { this.useContinuation = useContinuation; } @@ -248,6 +296,9 @@ public abstract class JettyHttpEndpoint extends HttpEndpoint { return sslContextParameters; } + /** + * To configure security using SSLContextParameters + */ public void setSslContextParameters(SSLContextParameters sslContextParameters) { this.sslContextParameters = sslContextParameters; } @@ -256,6 +307,11 @@ public abstract class JettyHttpEndpoint extends HttpEndpoint { return httpClientMinThreads; } + /** + * To set a value for minimum number of threads in HttpClient thread pool. + * This setting override any setting configured on component level. + * Notice that both a min and max size must be configured. If not set it default to min 8 threads used in Jettys thread pool. + */ public void setHttpClientMinThreads(Integer httpClientMinThreads) { this.httpClientMinThreads = httpClientMinThreads; } @@ -264,6 +320,11 @@ public abstract class JettyHttpEndpoint extends HttpEndpoint { return httpClientMaxThreads; } + /** + * To set a value for maximum number of threads in HttpClient thread pool. + * This setting override any setting configured on component level. + * Notice that both a min and max size must be configured. If not set it default to max 254 threads used in Jettys thread pool. + */ public void setHttpClientMaxThreads(Integer httpClientMaxThreads) { this.httpClientMaxThreads = httpClientMaxThreads; } @@ -272,6 +333,10 @@ public abstract class JettyHttpEndpoint extends HttpEndpoint { return httpClientParameters; } + /** + * Configuration of Jetty's HttpClient. For example, setting httpClient.idleTimeout=30000 sets the idle timeout to 30 seconds. + * And httpClient.timeout=30000 sets the request timeout to 30 seconds, in case you want to timeout sooner if you have long running request/response calls. + */ public void setHttpClientParameters(Map<String, Object> httpClientParameters) { this.httpClientParameters = httpClientParameters; } http://git-wip-us.apache.org/repos/asf/camel/blob/1e9700b0/components/camel-netty-http/src/main/java/org/apache/camel/component/netty/http/NettyHttpComponent.java ---------------------------------------------------------------------- diff --git a/components/camel-netty-http/src/main/java/org/apache/camel/component/netty/http/NettyHttpComponent.java b/components/camel-netty-http/src/main/java/org/apache/camel/component/netty/http/NettyHttpComponent.java index 3751ad2..5d9a6c9 100644 --- a/components/camel-netty-http/src/main/java/org/apache/camel/component/netty/http/NettyHttpComponent.java +++ b/components/camel-netty-http/src/main/java/org/apache/camel/component/netty/http/NettyHttpComponent.java @@ -172,6 +172,9 @@ public class NettyHttpComponent extends NettyComponent implements HeaderFilterSt return nettyHttpBinding; } + /** + * To use a custom org.apache.camel.component.netty.http.NettyHttpBinding for binding to/from Netty and Camel Message API. + */ public void setNettyHttpBinding(NettyHttpBinding nettyHttpBinding) { this.nettyHttpBinding = nettyHttpBinding; } @@ -180,6 +183,9 @@ public class NettyHttpComponent extends NettyComponent implements HeaderFilterSt return headerFilterStrategy; } + /** + * To use a custom org.apache.camel.spi.HeaderFilterStrategy to filter headers. + */ public void setHeaderFilterStrategy(HeaderFilterStrategy headerFilterStrategy) { this.headerFilterStrategy = headerFilterStrategy; } @@ -188,6 +194,9 @@ public class NettyHttpComponent extends NettyComponent implements HeaderFilterSt return securityConfiguration; } + /** + * Refers to a org.apache.camel.component.netty.http.NettyHttpSecurityConfiguration for configuring secure web resources. + */ public void setSecurityConfiguration(NettyHttpSecurityConfiguration securityConfiguration) { this.securityConfiguration = securityConfiguration; } http://git-wip-us.apache.org/repos/asf/camel/blob/1e9700b0/components/camel-netty-http/src/main/java/org/apache/camel/component/netty/http/NettyHttpConfiguration.java ---------------------------------------------------------------------- diff --git a/components/camel-netty-http/src/main/java/org/apache/camel/component/netty/http/NettyHttpConfiguration.java b/components/camel-netty-http/src/main/java/org/apache/camel/component/netty/http/NettyHttpConfiguration.java index 28c314d..51c907c 100644 --- a/components/camel-netty-http/src/main/java/org/apache/camel/component/netty/http/NettyHttpConfiguration.java +++ b/components/camel-netty-http/src/main/java/org/apache/camel/component/netty/http/NettyHttpConfiguration.java @@ -21,6 +21,7 @@ import java.util.List; import org.apache.camel.RuntimeCamelException; import org.apache.camel.component.netty.NettyConfiguration; +import org.apache.camel.spi.Metadata; import org.apache.camel.spi.UriParam; import org.apache.camel.spi.UriParams; import org.apache.camel.spi.UriPath; @@ -32,7 +33,7 @@ import org.jboss.netty.channel.ChannelHandler; @UriParams public class NettyHttpConfiguration extends NettyConfiguration { - @UriPath + @UriPath @Metadata(required = "true") private String path; @UriParam private boolean urlDecodeHeaders; @@ -50,12 +51,10 @@ public class NettyHttpConfiguration extends NettyConfiguration { private boolean bridgeEndpoint; @UriParam private boolean disableStreamCache; - @UriParam(defaultValue = "true") + @UriParam(label = "consumer", defaultValue = "true") private boolean send503whenSuspended = true; @UriParam(defaultValue = "" + 1024 * 1024) private int chunkedMaxContentLength = 1024 * 1024; - @UriParam(defaultValue = "true") - private boolean chunked = true; public NettyHttpConfiguration() { // we need sync=true as http is request/reply by nature @@ -85,6 +84,9 @@ public class NettyHttpConfiguration extends NettyConfiguration { return compression; } + /** + * Allow using gzip/deflate for compression on the Netty HTTP server if the client supports it from the HTTP headers. + */ public void setCompression(boolean compression) { this.compression = compression; } @@ -93,6 +95,10 @@ public class NettyHttpConfiguration extends NettyConfiguration { return throwExceptionOnFailure; } + /** + * Option to disable throwing the HttpOperationFailedException in case of failed responses from the remote server. + * This allows you to get all responses regardless of the HTTP status code. + */ public void setThrowExceptionOnFailure(boolean throwExceptionOnFailure) { this.throwExceptionOnFailure = throwExceptionOnFailure; } @@ -101,6 +107,12 @@ public class NettyHttpConfiguration extends NettyConfiguration { return transferException; } + /** + * If enabled and an Exchange failed processing on the consumer side, and if the caused Exception was send back serialized + * in the response as a application/x-java-serialized-object content type. + * On the producer side the exception will be deserialized and thrown as is, instead of the HttpOperationFailedException. + * The caused exception is required to be serialized. + */ public void setTransferException(boolean transferException) { this.transferException = transferException; } @@ -109,6 +121,12 @@ public class NettyHttpConfiguration extends NettyConfiguration { return urlDecodeHeaders; } + /** + * If this option is enabled, then during binding from Netty to Camel Message then the header values will be URL decoded + * (eg %20 will be a space character. Notice this option is used by the default org.apache.camel.component.netty.http.NettyHttpBinding + * and therefore if you implement a custom org.apache.camel.component.netty.http.NettyHttpBinding then you would + * need to decode the headers accordingly to this option. + */ public void setUrlDecodeHeaders(boolean urlDecodeHeaders) { this.urlDecodeHeaders = urlDecodeHeaders; } @@ -117,6 +135,12 @@ public class NettyHttpConfiguration extends NettyConfiguration { return mapHeaders; } + /** + * If this option is enabled, then during binding from Netty to Camel Message then the headers will be mapped as well + * (eg added as header to the Camel Message as well). You can turn off this option to disable this. + * The headers can still be accessed from the org.apache.camel.component.netty.http.NettyHttpMessage message with + * the method getHttpRequest() that returns the Netty HTTP request org.jboss.netty.handler.codec.http.HttpRequest instance. + */ public void setMapHeaders(boolean mapHeaders) { this.mapHeaders = mapHeaders; } @@ -125,6 +149,9 @@ public class NettyHttpConfiguration extends NettyConfiguration { return matchOnUriPrefix; } + /** + * Whether or not Camel should try to find a target consumer by matching the URI prefix if no exact match is found. + */ public void setMatchOnUriPrefix(boolean matchOnUriPrefix) { this.matchOnUriPrefix = matchOnUriPrefix; } @@ -133,6 +160,12 @@ public class NettyHttpConfiguration extends NettyConfiguration { return bridgeEndpoint; } + /** + * If the option is true, the producer will ignore the Exchange.HTTP_URI header, and use the endpoint's URI for request. + * You may also set the throwExceptionOnFailure to be false to let the producer send all the fault response back. + * The consumer working in the bridge mode will skip the gzip compression and WWW URL form encoding (by adding the Exchange.SKIP_GZIP_ENCODING + * and Exchange.SKIP_WWW_FORM_URLENCODED headers to the consumed exchange). + */ public void setBridgeEndpoint(boolean bridgeEndpoint) { this.bridgeEndpoint = bridgeEndpoint; } @@ -141,6 +174,9 @@ public class NettyHttpConfiguration extends NettyConfiguration { return path; } + /** + * Resource path + */ public void setPath(String path) { this.path = path; } @@ -149,6 +185,15 @@ public class NettyHttpConfiguration extends NettyConfiguration { return disableStreamCache; } + /** + * Determines whether or not the raw input stream from Netty HttpRequest#getContent() is cached or not + * (Camel will read the stream into a in light-weight memory based Stream caching) cache. + * By default Camel will cache the Netty input stream to support reading it multiple times to ensure it Camel + * can retrieve all data from the stream. However you can set this option to true when you for example need to + * access the raw stream, such as streaming it directly to a file or other persistent store. Mind that + * if you enable this option, then you cannot read the Netty stream multiple times out of the box, and you would + * need manually to reset the reader index on the Netty raw stream. + */ public void setDisableStreamCache(boolean disableStreamCache) { this.disableStreamCache = disableStreamCache; } @@ -157,22 +202,21 @@ public class NettyHttpConfiguration extends NettyConfiguration { return send503whenSuspended; } + /** + * Whether to send back HTTP status code 503 when the consumer has been suspended. + * If the option is false then the Netty Acceptor is unbound when the consumer is suspended, so clients cannot connect anymore. + */ public void setSend503whenSuspended(boolean send503whenSuspended) { this.send503whenSuspended = send503whenSuspended; } - public boolean isChunked() { - return chunked; - } - - public void setChunked(boolean chunked) { - this.chunked = chunked; - } - public int getChunkedMaxContentLength() { return chunkedMaxContentLength; } + /** + * Value in bytes the max content length per chunked frame received on the Netty HTTP server. + */ public void setChunkedMaxContentLength(int chunkedMaxContentLength) { this.chunkedMaxContentLength = chunkedMaxContentLength; } http://git-wip-us.apache.org/repos/asf/camel/blob/1e9700b0/components/camel-netty-http/src/main/java/org/apache/camel/component/netty/http/NettyHttpEndpoint.java ---------------------------------------------------------------------- diff --git a/components/camel-netty-http/src/main/java/org/apache/camel/component/netty/http/NettyHttpEndpoint.java b/components/camel-netty-http/src/main/java/org/apache/camel/component/netty/http/NettyHttpEndpoint.java index c3c253a..9cc5ac6 100644 --- a/components/camel-netty-http/src/main/java/org/apache/camel/component/netty/http/NettyHttpEndpoint.java +++ b/components/camel-netty-http/src/main/java/org/apache/camel/component/netty/http/NettyHttpEndpoint.java @@ -44,7 +44,9 @@ import org.slf4j.LoggerFactory; public class NettyHttpEndpoint extends NettyEndpoint implements HeaderFilterStrategyAware { private static final Logger LOG = LoggerFactory.getLogger(NettyHttpEndpoint.class); + @UriParam private NettyHttpBinding nettyHttpBinding; + @UriParam private HeaderFilterStrategy headerFilterStrategy; @UriParam private NettyHttpConfiguration configuration; @@ -52,7 +54,9 @@ public class NettyHttpEndpoint extends NettyEndpoint implements HeaderFilterStra private boolean traceEnabled; @UriParam private String httpMethodRestrict; + @UriParam private NettySharedHttpServer nettySharedHttpServer; + @UriParam(label = "consumer") private NettyHttpSecurityConfiguration securityConfiguration; public NettyHttpEndpoint(String endpointUri, NettyHttpComponent component, NettyConfiguration configuration) { @@ -141,6 +145,9 @@ public class NettyHttpEndpoint extends NettyEndpoint implements HeaderFilterStra return nettyHttpBinding; } + /** + * To use a custom org.apache.camel.component.netty.http.NettyHttpBinding for binding to/from Netty and Camel Message API. + */ public void setNettyHttpBinding(NettyHttpBinding nettyHttpBinding) { this.nettyHttpBinding = nettyHttpBinding; } @@ -149,6 +156,9 @@ public class NettyHttpEndpoint extends NettyEndpoint implements HeaderFilterStra return headerFilterStrategy; } + /** + * To use a custom org.apache.camel.spi.HeaderFilterStrategy to filter headers. + */ public void setHeaderFilterStrategy(HeaderFilterStrategy headerFilterStrategy) { this.headerFilterStrategy = headerFilterStrategy; getNettyHttpBinding().setHeaderFilterStrategy(headerFilterStrategy); @@ -158,6 +168,9 @@ public class NettyHttpEndpoint extends NettyEndpoint implements HeaderFilterStra return traceEnabled; } + /** + * Specifies whether to enable HTTP TRACE for this Netty HTTP consumer. By default TRACE is turned off. + */ public void setTraceEnabled(boolean traceEnabled) { this.traceEnabled = traceEnabled; } @@ -166,6 +179,9 @@ public class NettyHttpEndpoint extends NettyEndpoint implements HeaderFilterStra return httpMethodRestrict; } + /** + * To disable HTTP methods on the Netty HTTP consumer. You can specify multiple separated by comma. + */ public void setHttpMethodRestrict(String httpMethodRestrict) { this.httpMethodRestrict = httpMethodRestrict; } @@ -174,6 +190,9 @@ public class NettyHttpEndpoint extends NettyEndpoint implements HeaderFilterStra return nettySharedHttpServer; } + /** + * To use a shared Netty HTTP server. See Netty HTTP Server Example for more details. + */ public void setNettySharedHttpServer(NettySharedHttpServer nettySharedHttpServer) { this.nettySharedHttpServer = nettySharedHttpServer; } @@ -182,6 +201,9 @@ public class NettyHttpEndpoint extends NettyEndpoint implements HeaderFilterStra return securityConfiguration; } + /** + * Refers to a org.apache.camel.component.netty.http.NettyHttpSecurityConfiguration for configuring secure web resources. + */ public void setSecurityConfiguration(NettyHttpSecurityConfiguration securityConfiguration) { this.securityConfiguration = securityConfiguration; }
