http://git-wip-us.apache.org/repos/asf/camel/blob/0d96e56d/components/camel-jetty/src/main/java/org/apache/camel/component/jetty/JettyHttpComponent.java ---------------------------------------------------------------------- diff --git a/components/camel-jetty/src/main/java/org/apache/camel/component/jetty/JettyHttpComponent.java b/components/camel-jetty/src/main/java/org/apache/camel/component/jetty/JettyHttpComponent.java deleted file mode 100644 index c3bc309..0000000 --- a/components/camel-jetty/src/main/java/org/apache/camel/component/jetty/JettyHttpComponent.java +++ /dev/null @@ -1,1203 +0,0 @@ -/** - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.apache.camel.component.jetty; - -import java.io.File; -import java.io.IOException; -import java.io.Writer; -import java.lang.reflect.InvocationTargetException; -import java.lang.reflect.Method; -import java.net.URI; -import java.net.URISyntaxException; -import java.security.GeneralSecurityException; -import java.util.ArrayList; -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; -import javax.servlet.http.HttpServletRequest; -import javax.servlet.http.HttpServletResponse; - -import org.apache.camel.CamelContext; -import org.apache.camel.Consumer; -import org.apache.camel.Endpoint; -import org.apache.camel.Processor; -import org.apache.camel.RuntimeCamelException; -import org.apache.camel.component.http.CamelServlet; -import org.apache.camel.component.http.HttpBinding; -import org.apache.camel.component.http.HttpComponent; -import org.apache.camel.component.http.HttpConsumer; -import org.apache.camel.component.http.HttpEndpoint; -import org.apache.camel.component.http.UrlRewrite; -import org.apache.camel.spi.HeaderFilterStrategy; -import org.apache.camel.spi.ManagementAgent; -import org.apache.camel.spi.ManagementStrategy; -import org.apache.camel.spi.RestConfiguration; -import org.apache.camel.spi.RestConsumerFactory; -import org.apache.camel.util.FileUtil; -import org.apache.camel.util.HostUtils; -import org.apache.camel.util.IntrospectionSupport; -import org.apache.camel.util.ObjectHelper; -import org.apache.camel.util.URISupport; -import org.apache.camel.util.UnsafeUriCharactersEncoder; -import org.apache.camel.util.jsse.SSLContextParameters; -import org.eclipse.jetty.client.HttpClient; -import org.eclipse.jetty.http.HttpStatus; -import org.eclipse.jetty.jmx.MBeanContainer; -import org.eclipse.jetty.server.AbstractConnector; -import org.eclipse.jetty.server.Connector; -import org.eclipse.jetty.server.Handler; -import org.eclipse.jetty.server.Request; -import org.eclipse.jetty.server.Response; -import org.eclipse.jetty.server.Server; -import org.eclipse.jetty.server.handler.ContextHandlerCollection; -import org.eclipse.jetty.server.handler.ErrorHandler; -import org.eclipse.jetty.server.handler.HandlerCollection; -import org.eclipse.jetty.server.handler.HandlerWrapper; -import org.eclipse.jetty.server.session.SessionHandler; -import org.eclipse.jetty.servlet.FilterHolder; -import org.eclipse.jetty.servlet.ServletContextHandler; -import org.eclipse.jetty.servlet.ServletHolder; -import org.eclipse.jetty.servlets.CrossOriginFilter; -import org.eclipse.jetty.servlets.MultiPartFilter; -import org.eclipse.jetty.util.component.Container; -import org.eclipse.jetty.util.ssl.SslContextFactory; -import org.eclipse.jetty.util.thread.QueuedThreadPool; -import org.eclipse.jetty.util.thread.ThreadPool; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; - -/** - * An HttpComponent which starts an embedded Jetty for to handle consuming from - * the http endpoints. - * - * @version - */ -public abstract class JettyHttpComponent extends HttpComponent implements RestConsumerFactory { - public static final String TMP_DIR = "CamelJettyTempDir"; - - protected static final HashMap<String, ConnectorRef> CONNECTORS = new HashMap<String, ConnectorRef>(); - - private static final Logger LOG = LoggerFactory.getLogger(JettyHttpComponent.class); - private static final String JETTY_SSL_KEYSTORE = "org.eclipse.jetty.ssl.keystore"; - private static final String JETTY_SSL_KEYPASSWORD = "org.eclipse.jetty.ssl.keypassword"; - private static final String JETTY_SSL_PASSWORD = "org.eclipse.jetty.ssl.password"; - - protected String sslKeyPassword; - protected String sslPassword; - protected String sslKeystore; - protected Map<Integer, Connector> sslSocketConnectors; - protected Map<Integer, Connector> socketConnectors; - protected Map<String, Object> sslSocketConnectorProperties; - protected Map<String, Object> socketConnectorProperties; - protected Integer httpClientMinThreads; - protected Integer httpClientMaxThreads; - protected Integer minThreads; - protected Integer maxThreads; - protected ThreadPool threadPool; - protected MBeanContainer mbContainer; - protected boolean enableJmx; - protected JettyHttpBinding jettyHttpBinding; - protected Long continuationTimeout; - protected boolean useContinuation = true; - protected SSLContextParameters sslContextParameters; - protected Integer requestBufferSize; - protected Integer requestHeaderSize; - protected Integer responseBufferSize; - protected Integer responseHeaderSize; - protected String proxyHost; - protected ErrorHandler errorHandler; - private Integer proxyPort; - - public JettyHttpComponent() { - super(JettyHttpEndpoint.class); - } - - class ConnectorRef { - Server server; - Connector connector; - CamelServlet servlet; - int refCount; - - public ConnectorRef(Server server, Connector connector, CamelServlet servlet) { - this.server = server; - this.connector = connector; - this.servlet = servlet; - increment(); - } - - public int increment() { - return ++refCount; - } - - public int decrement() { - return --refCount; - } - - public int getRefCount() { - return refCount; - } - } - - @Override - protected Endpoint createEndpoint(String uri, String remaining, Map<String, Object> parameters) throws Exception { - - // must extract well known parameters before we create the endpoint - List<Handler> handlerList = resolveAndRemoveReferenceListParameter(parameters, "handlers", Handler.class); - HttpBinding binding = resolveAndRemoveReferenceParameter(parameters, "httpBindingRef", HttpBinding.class); - JettyHttpBinding jettyBinding = resolveAndRemoveReferenceParameter(parameters, "jettyHttpBindingRef", JettyHttpBinding.class); - Boolean throwExceptionOnFailure = getAndRemoveParameter(parameters, "throwExceptionOnFailure", Boolean.class); - Boolean transferException = getAndRemoveParameter(parameters, "transferException", Boolean.class); - Boolean bridgeEndpoint = getAndRemoveParameter(parameters, "bridgeEndpoint", Boolean.class); - Boolean matchOnUriPrefix = getAndRemoveParameter(parameters, "matchOnUriPrefix", Boolean.class); - Boolean enableJmx = getAndRemoveParameter(parameters, "enableJmx", Boolean.class); - Boolean enableMultipartFilter = getAndRemoveParameter(parameters, "enableMultipartFilter", - Boolean.class, true); - Filter multipartFilter = resolveAndRemoveReferenceParameter(parameters, "multipartFilterRef", Filter.class); - List<Filter> filters = resolveAndRemoveReferenceListParameter(parameters, "filtersRef", Filter.class); - Boolean enableCors = getAndRemoveParameter(parameters, "enableCORS", Boolean.class, false); - Long continuationTimeout = getAndRemoveParameter(parameters, "continuationTimeout", Long.class); - Boolean useContinuation = getAndRemoveParameter(parameters, "useContinuation", Boolean.class); - HeaderFilterStrategy headerFilterStrategy = resolveAndRemoveReferenceParameter(parameters, "headerFilterStrategy", HeaderFilterStrategy.class); - UrlRewrite urlRewrite = resolveAndRemoveReferenceParameter(parameters, "urlRewrite", UrlRewrite.class); - SSLContextParameters sslContextParameters = resolveAndRemoveReferenceParameter(parameters, "sslContextParametersRef", SSLContextParameters.class); - SSLContextParameters ssl = sslContextParameters != null ? sslContextParameters : this.sslContextParameters; - String proxyHost = getAndRemoveParameter(parameters, "proxyHost", String.class, getProxyHost()); - Integer proxyPort = getAndRemoveParameter(parameters, "proxyPort", Integer.class, getProxyPort()); - Integer responseBufferSize = getAndRemoveParameter(parameters, "responseBufferSize", Integer.class, getResponseBufferSize()); - Integer httpClientMinThreads = getAndRemoveParameter(parameters, "httpClientMinThreads", Integer.class, this.httpClientMinThreads); - Integer httpClientMaxThreads = getAndRemoveParameter(parameters, "httpClientMaxThreads", Integer.class, this.httpClientMaxThreads); - - // extract httpClient. parameters - Map<String, Object> httpClientParameters = IntrospectionSupport.extractProperties(parameters, "httpClient."); - - String address = remaining; - URI addressUri = new URI(UnsafeUriCharactersEncoder.encodeHttpURI(address)); - URI endpointUri = URISupport.createRemainingURI(addressUri, parameters); - // need to keep the httpMethodRestrict parameter for the endpointUri - String httpMethodRestrict = getAndRemoveParameter(parameters, "httpMethodRestrict", String.class); - // restructure uri to be based on the parameters left as we dont want to include the Camel internal options - URI httpUri = URISupport.createRemainingURI(addressUri, parameters); - // create endpoint after all known parameters have been extracted from parameters - JettyHttpEndpoint endpoint = createEndpoint(endpointUri, httpUri); - - - if (headerFilterStrategy != null) { - endpoint.setHeaderFilterStrategy(headerFilterStrategy); - } else { - setEndpointHeaderFilterStrategy(endpoint); - } - if (proxyHost != null) { - endpoint.setProxyHost(proxyHost); - endpoint.setProxyPort(proxyPort); - } - if (urlRewrite != null) { - // let CamelContext deal with the lifecycle of the url rewrite - // this ensures its being shutdown when Camel shutdown etc. - getCamelContext().addService(urlRewrite); - endpoint.setUrlRewrite(urlRewrite); - } - // setup the proxy host and proxy port - - - if (httpClientParameters != null && !httpClientParameters.isEmpty()) { - endpoint.setHttpClientParameters(httpClientParameters); - } - if (handlerList.size() > 0) { - endpoint.setHandlers(handlerList); - } - // prefer to use endpoint configured over component configured - if (binding == null) { - // fallback to component configured - binding = getHttpBinding(); - } - if (binding != null) { - endpoint.setBinding(binding); - } - // prefer to use endpoint configured over component configured - if (jettyBinding == null) { - // fallback to component configured - jettyBinding = getJettyHttpBinding(); - } - if (jettyBinding != null) { - endpoint.setJettyBinding(jettyBinding); - } - // should we use an exception for failed error codes? - if (throwExceptionOnFailure != null) { - endpoint.setThrowExceptionOnFailure(throwExceptionOnFailure); - } - // should we transfer exception as serialized object - if (transferException != null) { - endpoint.setTransferException(transferException); - } - if (bridgeEndpoint != null) { - endpoint.setBridgeEndpoint(bridgeEndpoint); - } - if (matchOnUriPrefix != null) { - endpoint.setMatchOnUriPrefix(matchOnUriPrefix); - } - if (enableJmx != null) { - endpoint.setEnableJmx(enableJmx); - } else { - // set this option based on setting of JettyHttpComponent - endpoint.setEnableJmx(isEnableJmx()); - } - - endpoint.setEnableMultipartFilter(enableMultipartFilter); - if (multipartFilter != null) { - endpoint.setMultipartFilter(multipartFilter); - endpoint.setEnableMultipartFilter(true); - } - if (enableCors) { - if (filters == null) { - filters = new ArrayList<Filter>(1); - } - filters.add(new CrossOriginFilter()); - } - if (filters != null) { - endpoint.setFilters(filters); - } - - if (continuationTimeout != null) { - endpoint.setContinuationTimeout(continuationTimeout); - } - if (useContinuation != null) { - endpoint.setUseContinuation(useContinuation); - } - if (httpMethodRestrict != null) { - endpoint.setHttpMethodRestrict(httpMethodRestrict); - } - if (ssl != null) { - endpoint.setSslContextParameters(ssl); - } - if (responseBufferSize != null) { - endpoint.setResponseBufferSize(responseBufferSize); - } - if (httpClientMinThreads != null) { - endpoint.setHttpClientMinThreads(httpClientMinThreads); - } - if (httpClientMaxThreads != null) { - endpoint.setHttpClientMaxThreads(httpClientMaxThreads); - } - - setProperties(endpoint, parameters); - return endpoint; - } - - protected abstract JettyHttpEndpoint createEndpoint(URI endpointUri, URI httpUri) throws URISyntaxException; - - /** - * Connects the URL specified on the endpoint to the specified processor. - */ - @Override - public void connect(HttpConsumer consumer) throws Exception { - // Make sure that there is a connector for the requested endpoint. - JettyHttpEndpoint endpoint = (JettyHttpEndpoint)consumer.getEndpoint(); - String connectorKey = getConnectorKey(endpoint); - - synchronized (CONNECTORS) { - ConnectorRef connectorRef = CONNECTORS.get(connectorKey); - if (connectorRef == null) { - Server server = createServer(); - Connector connector = getConnector(server, endpoint); - if ("localhost".equalsIgnoreCase(endpoint.getHttpUri().getHost())) { - LOG.warn("You use localhost interface! It means that no external connections will be available." - + " Don't you want to use 0.0.0.0 instead (all network interfaces)? " + endpoint); - } - if (endpoint.isEnableJmx()) { - enableJmx(server); - } - server.addConnector(connector); - - connectorRef = new ConnectorRef(server, connector, createServletForConnector(server, connector, endpoint.getHandlers(), endpoint)); - // must enable session before we start - if (endpoint.isSessionSupport()) { - enableSessionSupport(connectorRef.server, connectorKey); - } - connectorRef.server.start(); - - CONNECTORS.put(connectorKey, connectorRef); - - } else { - - if (endpoint.getHandlers() != null && !endpoint.getHandlers().isEmpty()) { - // As the server is started, we need to stop the server for a while to add the new handler - connectorRef.server.stop(); - addJettyHandlers(connectorRef.server, endpoint.getHandlers()); - connectorRef.server.start(); - } - // ref track the connector - connectorRef.increment(); - } - // check the session support - if (endpoint.isSessionSupport()) { - enableSessionSupport(connectorRef.server, connectorKey); - } - - if (endpoint.isEnableMultipartFilter()) { - enableMultipartFilter(endpoint, connectorRef.server, connectorKey); - } - - if (endpoint.getFilters() != null && endpoint.getFilters().size() > 0) { - setFilters(endpoint, connectorRef.server, connectorKey); - } - connectorRef.servlet.connect(consumer); - } - } - - - private void enableJmx(Server server) { - MBeanContainer containerToRegister = getMbContainer(); - if (containerToRegister != null) { - LOG.info("Jetty JMX Extensions is enabled"); - addServerMBean(server); - // Since we may have many Servers running, don't tie the MBeanContainer - // to a Server lifecycle or we end up closing it while it is still in use. - //server.addBean(mbContainer); - } - } - - private void enableSessionSupport(Server server, String connectorKey) throws Exception { - ServletContextHandler context = server.getChildHandlerByClass(ServletContextHandler.class); - if (context.getSessionHandler() == null) { - SessionHandler sessionHandler = new SessionHandler(); - if (context.isStarted()) { - throw new IllegalStateException("Server has already been started. Cannot enabled sessionSupport on " + connectorKey); - } else { - context.setSessionHandler(sessionHandler); - } - } - } - - private void setFilters(JettyHttpEndpoint endpoint, Server server, String connectorKey) { - ServletContextHandler context = server.getChildHandlerByClass(ServletContextHandler.class); - List<Filter> filters = endpoint.getFilters(); - for (Filter filter : filters) { - FilterHolder filterHolder = new FilterHolder(); - filterHolder.setFilter(new CamelFilterWrapper(filter)); - String pathSpec = endpoint.getPath(); - if (pathSpec == null || "".equals(pathSpec)) { - pathSpec = "/"; - } - if (endpoint.isMatchOnUriPrefix()) { - pathSpec = pathSpec.endsWith("/") ? pathSpec + "*" : pathSpec + "/*"; - } - addFilter(context, filterHolder, pathSpec); - } - } - - private void addFilter(ServletContextHandler context, FilterHolder filterHolder, String pathSpec) { - context.getServletHandler().addFilterWithMapping(filterHolder, pathSpec, 0); - } - - private void enableMultipartFilter(HttpEndpoint endpoint, Server server, String connectorKey) throws Exception { - ServletContextHandler context = server.getChildHandlerByClass(ServletContextHandler.class); - CamelContext camelContext = this.getCamelContext(); - FilterHolder filterHolder = new FilterHolder(); - filterHolder.setInitParameter("deleteFiles", "true"); - if (ObjectHelper.isNotEmpty(camelContext.getProperty(TMP_DIR))) { - File file = new File(camelContext.getProperty(TMP_DIR)); - if (!file.isDirectory()) { - throw new RuntimeCamelException( - "The temp file directory of camel-jetty is not exists, please recheck it with directory name :" - + camelContext.getProperties().get(TMP_DIR)); - } - context.setAttribute("javax.servlet.context.tempdir", file); - } - // if a filter ref was provided, use it. - Filter filter = ((JettyHttpEndpoint) endpoint).getMultipartFilter(); - if (filter == null) { - // if no filter ref was provided, use the default filter - filter = new MultiPartFilter(); - } - filterHolder.setFilter(new CamelFilterWrapper(filter)); - String pathSpec = endpoint.getPath(); - if (pathSpec == null || "".equals(pathSpec)) { - pathSpec = "/"; - } - if (endpoint.isMatchOnUriPrefix()) { - pathSpec = pathSpec.endsWith("/") ? pathSpec + "*" : pathSpec + "/*"; - } - addFilter(context, filterHolder, pathSpec); - LOG.debug("using multipart filter implementation " + filter.getClass().getName() + " for path " + pathSpec); - } - - /** - * Disconnects the URL specified on the endpoint from the specified processor. - */ - @Override - public void disconnect(HttpConsumer consumer) throws Exception { - // If the connector is not needed anymore then stop it - HttpEndpoint endpoint = consumer.getEndpoint(); - String connectorKey = getConnectorKey(endpoint); - - synchronized (CONNECTORS) { - ConnectorRef connectorRef = CONNECTORS.get(connectorKey); - if (connectorRef != null) { - connectorRef.servlet.disconnect(consumer); - if (connectorRef.decrement() == 0) { - connectorRef.server.removeConnector(connectorRef.connector); - connectorRef.connector.stop(); - connectorRef.server.stop(); - CONNECTORS.remove(connectorKey); - // Camel controls the lifecycle of these entities so remove the - // registered MBeans when Camel is done with the managed objects. - if (mbContainer != null) { - this.removeServerMBean(connectorRef.server); - //mbContainer.removeBean(connectorRef.connector); - } - } - } - } - } - - private String getConnectorKey(HttpEndpoint endpoint) { - return endpoint.getProtocol() + ":" + endpoint.getHttpUri().getHost() + ":" + endpoint.getPort(); - } - - // Properties - // ------------------------------------------------------------------------- - - public String getSslKeyPassword() { - return sslKeyPassword; - } - - public void setSslKeyPassword(String sslKeyPassword) { - this.sslKeyPassword = sslKeyPassword; - } - - public String getSslPassword() { - return sslPassword; - } - - public void setSslPassword(String sslPassword) { - this.sslPassword = sslPassword; - } - - public void setKeystore(String sslKeystore) { - this.sslKeystore = sslKeystore; - } - - public String getKeystore() { - return sslKeystore; - } - - - public ErrorHandler getErrorHandler() { - return errorHandler; - } - - public void setErrorHandler(ErrorHandler errorHandler) { - this.errorHandler = errorHandler; - } - - protected Connector getConnector(Server server, JettyHttpEndpoint endpoint) { - Connector connector; - if ("https".equals(endpoint.getProtocol())) { - connector = getSslSocketConnector(server, endpoint); - } else { - connector = getSocketConnector(server, endpoint); - } - return connector; - } - protected Connector getSocketConnector(Server server, JettyHttpEndpoint endpoint) { - Connector answer = null; - if (socketConnectors != null) { - answer = socketConnectors.get(endpoint.getPort()); - } - if (answer == null) { - answer = createConnector(server, endpoint); - } - return answer; - } - - protected Connector getSslSocketConnector(Server server, JettyHttpEndpoint endpoint) { - Connector answer = null; - if (sslSocketConnectors != null) { - answer = sslSocketConnectors.get(endpoint.getPort()); - } - if (answer == null) { - answer = createConnector(server, endpoint); - } - return answer; - } - - protected Connector createConnector(Server server, JettyHttpEndpoint endpoint) { - - - // now we just use the SelectChannelConnector as the default connector - SslContextFactory sslcf = null; - - // Note that this was set on the endpoint when it was constructed. It was - // either explicitly set at the component or on the endpoint, but either way, - // the value is already set. We therefore do not need to look at the component - // level SSLContextParameters again in this method. - SSLContextParameters endpointSslContextParameters = endpoint.getSslContextParameters(); - - if (endpointSslContextParameters != null) { - try { - sslcf = createSslContextFactory(endpointSslContextParameters); - } catch (Exception e) { - throw new RuntimeCamelException(e); - } - } else if ("https".equals(endpoint.getProtocol())) { - sslcf = new SslContextFactory(); - String keystoreProperty = System.getProperty(JETTY_SSL_KEYSTORE); - if (keystoreProperty != null) { - sslcf.setKeyStorePath(keystoreProperty); - } else if (sslKeystore != null) { - sslcf.setKeyStorePath(sslKeystore); - } - - String keystorePassword = System.getProperty(JETTY_SSL_KEYPASSWORD); - if (keystorePassword != null) { - sslcf.setKeyManagerPassword(keystorePassword); - } else if (sslKeyPassword != null) { - sslcf.setKeyManagerPassword(sslKeyPassword); - } - - String password = System.getProperty(JETTY_SSL_PASSWORD); - if (password != null) { - sslcf.setKeyStorePassword(password); - } else if (sslPassword != null) { - sslcf.setKeyStorePassword(sslPassword); - } - } - - return createConnectorJettyInternal(server, endpoint, sslcf); - } - - protected abstract AbstractConnector createConnectorJettyInternal(Server server, JettyHttpEndpoint endpoint, SslContextFactory sslcf); - - private SslContextFactory createSslContextFactory(SSLContextParameters ssl) throws GeneralSecurityException, IOException { - SslContextFactory answer = new SslContextFactory(); - if (ssl != null) { - answer.setSslContext(ssl.createSSLContext()); - } - return answer; - } - - protected boolean checkSSLContextFactoryConfig(Object instance) { - try { - Method method = instance.getClass().getMethod("checkConfig"); - return (Boolean)method.invoke(instance); - } catch (NoSuchMethodException ex) { - // ignore - } catch (IllegalArgumentException e) { - // ignore - } catch (IllegalAccessException e) { - // ignore - } catch (InvocationTargetException e) { - // ignore - } - return false; - } - - public Map<Integer, Connector> getSslSocketConnectors() { - return sslSocketConnectors; - } - - public void setSslSocketConnectors(Map <Integer, Connector> connectors) { - sslSocketConnectors = connectors; - } - - public void setSocketConnectors(Map<Integer, Connector> socketConnectors) { - this.socketConnectors = socketConnectors; - } - - /** - * 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 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 - */ - public CamelHttpClient createHttpClient(JettyHttpEndpoint endpoint, Integer minThreads, Integer maxThreads, SSLContextParameters ssl) throws Exception { - SslContextFactory sslContextFactory = createSslContextFactory(ssl); - CamelHttpClient httpClient = createCamelHttpClient(sslContextFactory); - - CamelContext context = endpoint.getCamelContext(); - - if (context != null - && ObjectHelper.isNotEmpty(context.getProperty("http.proxyHost")) - && ObjectHelper.isNotEmpty(context.getProperty("http.proxyPort"))) { - String host = context.getProperty("http.proxyHost"); - int port = Integer.parseInt(context.getProperty("http.proxyPort")); - LOG.debug("CamelContext properties http.proxyHost and http.proxyPort detected. Using http proxy host: {} port: {}", host, port); - httpClient.setProxy(host, port); - } - - if (ObjectHelper.isNotEmpty(endpoint.getProxyHost()) && endpoint.getProxyPort() > 0) { - String host = endpoint.getProxyHost(); - int port = endpoint.getProxyPort(); - LOG.debug("proxyHost and proxyPort options detected. Using http proxy host: {} port: {}", host, port); - httpClient.setProxy(host, port); - } - - // must have both min and max - if (minThreads != null || maxThreads != null) { - - // must have both options - if (minThreads == null || maxThreads == null) { - throw new IllegalArgumentException("Both min and max thread pool sizes must be provided."); - } - - // use QueueThreadPool as the default bounded is deprecated (see SMXCOMP-157) - QueuedThreadPool qtp = new QueuedThreadPool(); - qtp.setMinThreads(minThreads.intValue()); - qtp.setMaxThreads(maxThreads.intValue()); - // and we want to use daemon threads - qtp.setDaemon(true); - // let the thread names indicate they are from the client - qtp.setName("CamelJettyClient(" + ObjectHelper.getIdentityHashCode(httpClient) + ")"); - httpClient.setThreadPoolOrExecutor(qtp); - } - - if (LOG.isDebugEnabled()) { - if (minThreads != null) { - LOG.debug("Created HttpClient with thread pool {}-{} -> {}", new Object[]{minThreads, maxThreads, httpClient}); - } else { - LOG.debug("Created HttpClient with default thread pool size -> {}", httpClient); - } - } - - return httpClient; - } - - protected abstract CamelHttpClient createCamelHttpClient(SslContextFactory sslContextFactory); - - public Integer getHttpClientMinThreads() { - return httpClientMinThreads; - } - - public void setHttpClientMinThreads(Integer httpClientMinThreads) { - this.httpClientMinThreads = httpClientMinThreads; - } - - public Integer getHttpClientMaxThreads() { - return httpClientMaxThreads; - } - - public void setHttpClientMaxThreads(Integer httpClientMaxThreads) { - this.httpClientMaxThreads = httpClientMaxThreads; - } - - public Integer getMinThreads() { - return minThreads; - } - - public void setMinThreads(Integer minThreads) { - this.minThreads = minThreads; - } - - public Integer getMaxThreads() { - return maxThreads; - } - - public void setMaxThreads(Integer maxThreads) { - this.maxThreads = maxThreads; - } - - public ThreadPool getThreadPool() { - return threadPool; - } - - public void setThreadPool(ThreadPool threadPool) { - this.threadPool = threadPool; - } - - public void setEnableJmx(boolean enableJmx) { - this.enableJmx = enableJmx; - } - - public boolean isEnableJmx() { - return enableJmx; - } - - public JettyHttpBinding getJettyHttpBinding() { - return jettyHttpBinding; - } - - public void setJettyHttpBinding(JettyHttpBinding jettyHttpBinding) { - this.jettyHttpBinding = jettyHttpBinding; - } - - public synchronized MBeanContainer getMbContainer() { - // If null, provide the default implementation. - if (mbContainer == null) { - MBeanServer mbs = null; - - final ManagementStrategy mStrategy = this.getCamelContext().getManagementStrategy(); - final ManagementAgent mAgent = mStrategy.getManagementAgent(); - if (mAgent != null) { - mbs = mAgent.getMBeanServer(); - } - - if (mbs != null) { - mbContainer = new MBeanContainer(mbs); - startMbContainer(); - } else { - LOG.warn("JMX disabled in CamelContext. Jetty JMX extensions will remain disabled."); - } - } - - return this.mbContainer; - } - - public void setMbContainer(MBeanContainer mbContainer) { - this.mbContainer = mbContainer; - } - - public Map<String, Object> getSslSocketConnectorProperties() { - return sslSocketConnectorProperties; - } - - public void setSslSocketConnectorProperties(Map<String, Object> sslSocketConnectorProperties) { - this.sslSocketConnectorProperties = sslSocketConnectorProperties; - } - - public Map<String, Object> getSocketConnectorProperties() { - return socketConnectorProperties; - } - - public void setSocketConnectorProperties(Map<String, Object> socketConnectorProperties) { - this.socketConnectorProperties = socketConnectorProperties; - } - - public void addSocketConnectorProperty(String key, Object value) { - if (socketConnectorProperties == null) { - socketConnectorProperties = new HashMap<String, Object>(); - } - socketConnectorProperties.put(key, value); - } - - public void addSslSocketConnectorProperty(String key, Object value) { - if (sslSocketConnectorProperties == null) { - sslSocketConnectorProperties = new HashMap<String, Object>(); - } - sslSocketConnectorProperties.put(key, value); - } - - public Long getContinuationTimeout() { - return continuationTimeout; - } - - public void setContinuationTimeout(Long continuationTimeout) { - this.continuationTimeout = continuationTimeout; - } - - public boolean isUseContinuation() { - return useContinuation; - } - - public void setUseContinuation(boolean useContinuation) { - this.useContinuation = useContinuation; - } - - public SSLContextParameters getSslContextParameters() { - return sslContextParameters; - } - - public void setSslContextParameters(SSLContextParameters sslContextParameters) { - this.sslContextParameters = sslContextParameters; - } - - public Integer getResponseBufferSize() { - return responseBufferSize; - } - - public void setResponseBufferSize(Integer responseBufferSize) { - this.responseBufferSize = responseBufferSize; - } - - public Integer getRequestBufferSize() { - return requestBufferSize; - } - - public void setRequestBufferSize(Integer requestBufferSize) { - this.requestBufferSize = requestBufferSize; - } - - public Integer getRequestHeaderSize() { - return requestHeaderSize; - } - - public void setRequestHeaderSize(Integer requestHeaderSize) { - this.requestHeaderSize = requestHeaderSize; - } - - public Integer getResponseHeaderSize() { - return responseHeaderSize; - } - - public void setResponseHeaderSize(Integer responseHeaderSize) { - this.responseHeaderSize = responseHeaderSize; - } - - public String getProxyHost() { - return proxyHost; - } - - public void setProxyHost(String proxyHost) { - this.proxyHost = proxyHost; - } - - public Integer getProxyPort() { - return proxyPort; - } - - public void setProxyPort(Integer proxyPort) { - this.proxyPort = proxyPort; - } - - // 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 { - - String path = basePath; - if (uriTemplate != null) { - // make sure to avoid double slashes - if (uriTemplate.startsWith("/")) { - path = path + uriTemplate; - } else { - path = path + "/" + uriTemplate; - } - } - path = FileUtil.stripLeadingSeparator(path); - - String scheme = "http"; - String host = ""; - int port = 0; - - // if no explicit port/host configured, then use port from rest configuration - RestConfiguration config = getCamelContext().getRestConfiguration(); - if (config.getComponent() == null || config.getComponent().equals("jetty")) { - if (config.getScheme() != null) { - scheme = config.getScheme(); - } - if (config.getHost() != null) { - host = config.getHost(); - } - int num = config.getPort(); - if (num > 0) { - port = num; - } - } - - // if no explicit hostname set then resolve the hostname - if (ObjectHelper.isEmpty(host)) { - if (config.getRestHostNameResolver() == RestConfiguration.RestHostNameResolver.localHostName) { - host = HostUtils.getLocalHostName(); - } else if (config.getRestHostNameResolver() == RestConfiguration.RestHostNameResolver.localIp) { - host = HostUtils.getLocalIp(); - } - } - - Map<String, Object> map = new HashMap<String, Object>(); - // build query string, and append any endpoint configuration properties - if (config != null && (config.getComponent() == null || config.getComponent().equals("jetty"))) { - // setup endpoint options - if (config.getEndpointProperties() != null && !config.getEndpointProperties().isEmpty()) { - map.putAll(config.getEndpointProperties()); - } - } - - String query = URISupport.createQueryString(map); - - String url = "jetty:%s://%s:%s/%s?httpMethodRestrict=%s"; - // must use upper case for restrict - String restrict = verb.toUpperCase(Locale.US); - // get the endpoint - url = String.format(url, scheme, host, port, path, restrict); - - if (!query.isEmpty()) { - url = url + "&" + query; - } - - JettyHttpEndpoint endpoint = camelContext.getEndpoint(url, JettyHttpEndpoint.class); - setProperties(endpoint, parameters); - - // disable this filter as we want to use ours - endpoint.setEnableMultipartFilter(false); - // use the rest binding - endpoint.setBinding(new JettyRestHttpBinding(endpoint)); - - // configure consumer properties - Consumer consumer = endpoint.createConsumer(processor); - if (config != null && config.getConsumerProperties() != null && !config.getConsumerProperties().isEmpty()) { - setProperties(consumer, config.getConsumerProperties()); - } - - return consumer; - } - - protected CamelServlet createServletForConnector(Server server, Connector connector, - List<Handler> handlers, JettyHttpEndpoint endpoint) throws Exception { - ServletContextHandler context = new ServletContextHandler(server, "/", ServletContextHandler.NO_SECURITY | ServletContextHandler.NO_SESSIONS); - if (Server.getVersion().startsWith("8")) { - context.getClass().getMethod("setConnectorNames", new Class[] {String[].class}) - .invoke(context, new Object[] {new String[] {connector.getName()}}); - } - - addJettyHandlers(server, handlers); - - CamelServlet camelServlet; - boolean jetty = endpoint.getUseContinuation() != null ? endpoint.getUseContinuation() : isUseContinuation(); - if (jetty) { - // use Jetty continuations - CamelContinuationServlet jettyServlet = new CamelContinuationServlet(); - // configure timeout and log it so end user know what we are using - Long timeout = endpoint.getContinuationTimeout() != null ? endpoint.getContinuationTimeout() : getContinuationTimeout(); - if (timeout != null) { - LOG.info("Using Jetty continuation timeout: " + timeout + " millis for: " + endpoint); - jettyServlet.setContinuationTimeout(timeout); - } else { - LOG.info("Using default Jetty continuation timeout for: " + endpoint); - } - - // use the jetty servlet - camelServlet = jettyServlet; - } else { - // do not use jetty so use a plain servlet - camelServlet = new CamelServlet(); - LOG.info("Jetty continuation is disabled for: " + endpoint); - } - - ServletHolder holder = new ServletHolder(); - holder.setServlet(camelServlet); - context.addServlet(holder, "/*"); - - // use rest enabled resolver in case we use rest - camelServlet.setServletResolveConsumerStrategy(new JettyRestServletResolveConsumerStrategy()); - - return camelServlet; - } - - protected void addJettyHandlers(Server server, List<Handler> handlers) { - if (handlers != null && !handlers.isEmpty()) { - for (Handler handler : handlers) { - if (handler instanceof HandlerWrapper) { - // avoid setting the security handler more than once - if (!handler.equals(server.getHandler())) { - ((HandlerWrapper) handler).setHandler(server.getHandler()); - server.setHandler(handler); - } - } else { - HandlerCollection handlerCollection = new HandlerCollection(); - handlerCollection.addHandler(server.getHandler()); - handlerCollection.addHandler(handler); - server.setHandler(handlerCollection); - } - } - } - - } - - protected Server createServer() { - Server s = null; - ThreadPool tp = threadPool; - QueuedThreadPool qtp = null; - // configure thread pool if min/max given - if (minThreads != null || maxThreads != null) { - if (getThreadPool() != null) { - throw new IllegalArgumentException("You cannot configure both minThreads/maxThreads and a custom threadPool on JettyHttpComponent: " + this); - } - qtp = new QueuedThreadPool(); - if (minThreads != null) { - qtp.setMinThreads(minThreads.intValue()); - } - if (maxThreads != null) { - qtp.setMaxThreads(maxThreads.intValue()); - } - tp = qtp; - } - if (tp != null) { - try { - if (!Server.getVersion().startsWith("8")) { - s = Server.class.getConstructor(ThreadPool.class).newInstance(tp); - - } else { - s = new Server(); - Server.class.getMethod("setThreadPool", ThreadPool.class).invoke(s, tp); - } - } catch (Exception e) { - //ignore - } - } - if (s == null) { - s = new Server(); - } - if (qtp != null) { - // let the thread names indicate they are from the server - qtp.setName("CamelJettyServer(" + ObjectHelper.getIdentityHashCode(s) + ")"); - try { - qtp.start(); - } catch (Exception e) { - throw new RuntimeCamelException("Error starting JettyServer thread pool: " + qtp, e); - } - } - ContextHandlerCollection collection = new ContextHandlerCollection(); - s.setHandler(collection); - // setup the error handler if it set to Jetty component - if (getErrorHandler() != null) { - s.addBean(getErrorHandler()); - } else if (!Server.getVersion().startsWith("8")) { - //need an error handler that won't leak information about the exception - //back to the client. - ErrorHandler eh = new ErrorHandler() { - public void handle(String target, Request baseRequest, - HttpServletRequest request, HttpServletResponse response) - throws IOException { - String msg = HttpStatus.getMessage(response.getStatus()); - request.setAttribute(RequestDispatcher.ERROR_MESSAGE, msg); - if (response instanceof Response) { - //need to use the deprecated method to support compiling with Jetty 8 - ((Response)response).setStatus(response.getStatus(), msg); - } - super.handle(target, baseRequest, request, response); - } - protected void writeErrorPage(HttpServletRequest request, Writer writer, int code, - String message, boolean showStacks) - throws IOException { - super.writeErrorPage(request, writer, code, message, false); - } - }; - s.addBean(eh); - } - return s; - } - - - /** - * Starts {@link #mbContainer} and registers the container with itself as a managed bean - * logging an error if there is a problem starting the container. - * Does nothing if {@link #mbContainer} is {@code null}. - */ - protected void startMbContainer() { - if (mbContainer != null - && Server.getVersion().startsWith("8")) { - //JETTY8 only - try { - boolean b = (boolean)mbContainer.getClass().getMethod("isStarted").invoke(mbContainer); - if (b) { - mbContainer.getClass().getMethod("start").invoke(mbContainer); - // Publish the container itself for consistency with - // traditional embedded Jetty configurations. - mbContainer.getClass().getMethod("addBean", Object.class).invoke(mbContainer, mbContainer); - } - } catch (Throwable e) { - LOG.warn("Could not start Jetty MBeanContainer. Jetty JMX extensions will remain disabled.", e); - } - } - } - - @Override - protected void doStart() throws Exception { - super.doStart(); - startMbContainer(); - } - - @Override - protected void doStop() throws Exception { - super.doStop(); - if (CONNECTORS.size() > 0) { - for (String connectorKey : CONNECTORS.keySet()) { - ConnectorRef connectorRef = CONNECTORS.get(connectorKey); - if (connectorRef != null && connectorRef.getRefCount() == 0) { - connectorRef.server.removeConnector(connectorRef.connector); - connectorRef.connector.stop(); - // Camel controls the lifecycle of these entities so remove the - // registered MBeans when Camel is done with the managed objects. - removeServerMBean(connectorRef.server); - connectorRef.server.stop(); - //removeServerMBean(connectorRef.connector); - CONNECTORS.remove(connectorKey); - } - } - } - if (mbContainer != null) { - try { - //JETTY8 - mbContainer.getClass().getMethod("stop").invoke(mbContainer); - } catch (Throwable t) { - //JETTY9 - mbContainer.getClass().getMethod("destroy").invoke(mbContainer); - } - mbContainer = null; - } - } - - private void addServerMBean(Server server) { - if (mbContainer == null) { - return; - } - - try { - Object o = getContainer(server); - o.getClass().getMethod("addEventListener", Container.Listener.class).invoke(o, mbContainer); - if (Server.getVersion().startsWith("8")) { - return; - } - mbContainer.getClass().getMethod("beanAdded", Container.class, Object.class) - .invoke(mbContainer, null, server); - } catch (RuntimeException rex) { - throw rex; - } catch (Exception r) { - throw new RuntimeException(r); - } - } - private void removeServerMBean(Server server) { - try { - mbContainer.getClass().getMethod("beanRemoved", Container.class, Object.class) - .invoke(mbContainer, null, server); - } catch (RuntimeException rex) { - throw rex; - } catch (Exception r) { - try { - mbContainer.getClass().getMethod("removeBean", Object.class) - .invoke(mbContainer, server); - } catch (RuntimeException rex) { - throw rex; - } catch (Exception r2) { - throw new RuntimeException(r); - } - } - } - private static Container getContainer(Object server) { - if (server instanceof Container) { - return (Container)server; - } - try { - return (Container)server.getClass().getMethod("getContainer").invoke(server); - } catch (RuntimeException t) { - throw t; - } catch (Throwable t) { - throw new RuntimeException(t); - } - } - -}
http://git-wip-us.apache.org/repos/asf/camel/blob/0d96e56d/components/camel-jetty/src/main/java/org/apache/camel/component/jetty/JettyHttpEndpoint.java ---------------------------------------------------------------------- diff --git a/components/camel-jetty/src/main/java/org/apache/camel/component/jetty/JettyHttpEndpoint.java b/components/camel-jetty/src/main/java/org/apache/camel/component/jetty/JettyHttpEndpoint.java deleted file mode 100644 index 15bf62c..0000000 --- a/components/camel-jetty/src/main/java/org/apache/camel/component/jetty/JettyHttpEndpoint.java +++ /dev/null @@ -1,283 +0,0 @@ -/** - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.apache.camel.component.jetty; - -import java.net.URI; -import java.net.URISyntaxException; -import java.util.HashMap; -import java.util.List; -import java.util.Map; - -import javax.servlet.Filter; - -import org.apache.camel.Consumer; -import org.apache.camel.Processor; -import org.apache.camel.Producer; -import org.apache.camel.ResolveEndpointFailedException; -import org.apache.camel.component.http.HttpConsumer; -import org.apache.camel.component.http.HttpEndpoint; -import org.apache.camel.impl.SynchronousDelegateProducer; -import org.apache.camel.spi.UriEndpoint; -import org.apache.camel.spi.UriParam; -import org.apache.camel.util.IntrospectionSupport; -import org.apache.camel.util.jsse.SSLContextParameters; -import org.eclipse.jetty.client.HttpClient; -import org.eclipse.jetty.server.Handler; - -/** - * @version - */ -@UriEndpoint(scheme = "jetty", consumerClass = HttpConsumer.class, label = "http") -public abstract class JettyHttpEndpoint extends HttpEndpoint { - - @UriParam - private boolean sessionSupport; - private List<Handler> handlers; - private HttpClient client; - @UriParam - private Integer httpClientMinThreads; - @UriParam - private Integer httpClientMaxThreads; - private JettyHttpBinding jettyBinding; - @UriParam - private boolean enableJmx; - @UriParam - private boolean enableMultipartFilter; - @UriParam - private boolean sendServerVersion = true; - @UriParam - private boolean sendDateHeader; - private Filter multipartFilter; - private List<Filter> filters; - @UriParam - private Long continuationTimeout; - @UriParam - 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); - } - - @Override - public JettyHttpComponent getComponent() { - return (JettyHttpComponent) super.getComponent(); - } - - @Override - public Producer createProducer() throws Exception { - JettyHttpProducer answer = new JettyHttpProducer(this); - if (client != null) { - // use shared client, and ensure its started so we can use it - client.start(); - answer.setSharedClient(client); - answer.setBinding(getJettyBinding(client)); - } else { - HttpClient httpClient = createJettyHttpClient(); - answer.setClient(httpClient); - answer.setBinding(getJettyBinding(httpClient)); - } - - if (isSynchronous()) { - return new SynchronousDelegateProducer(answer); - } else { - return answer; - } - } - - protected HttpClient createJettyHttpClient() throws Exception { - // create a new client - // thread pool min/max from endpoint take precedence over from component - Integer min = httpClientMinThreads != null ? httpClientMinThreads : getComponent().getHttpClientMinThreads(); - Integer max = httpClientMaxThreads != null ? httpClientMaxThreads : getComponent().getHttpClientMaxThreads(); - HttpClient httpClient = getComponent().createHttpClient(this, min, max, sslContextParameters); - - // set optional http client parameters - if (httpClientParameters != null) { - // copy parameters as we need to re-use them again if creating a new producer later - Map<String, Object> params = new HashMap<String, Object>(httpClientParameters); - // Can not be set on httpClient for jetty 9 - params.remove("timeout"); - IntrospectionSupport.setProperties(httpClient, params); - // validate we could set all parameters - if (params.size() > 0) { - throw new ResolveEndpointFailedException(getEndpointUri(), "There are " + params.size() - + " parameters that couldn't be set on the endpoint." - + " Check the uri if the parameters are spelt correctly and that they are properties of the endpoint." - + " Unknown parameters=[" + params + "]"); - } - } - return httpClient; - } - - @Override - public Consumer createConsumer(Processor processor) throws Exception { - HttpConsumer answer = new HttpConsumer(this, processor); - configureConsumer(answer); - return answer; - } - - public void setSessionSupport(boolean support) { - sessionSupport = support; - } - - public boolean isSessionSupport() { - return sessionSupport; - } - - public List<Handler> getHandlers() { - return handlers; - } - - public void setHandlers(List<Handler> handlers) { - this.handlers = handlers; - } - - public HttpClient getClient() throws Exception { - return client; - } - - /** - * Sets a shared {@link HttpClient} to use for all producers - * created by this endpoint. By default each producer will - * use a new http client, and not share. - * <p/> - * <b>Important: </b> Make sure to handle the lifecycle of the shared - * client, such as stopping the client, when it is no longer in use. - * Camel will call the <tt>start</tt> method on the client to ensure - * its started when this endpoint creates a producer. - * <p/> - * This options should only be used in special circumstances. - */ - public void setClient(HttpClient client) { - this.client = client; - } - - public synchronized JettyHttpBinding getJettyBinding(HttpClient httpClient) { - if (jettyBinding == null) { - jettyBinding = new DefaultJettyHttpBinding(); - jettyBinding.setHeaderFilterStrategy(getHeaderFilterStrategy()); - jettyBinding.setThrowExceptionOnFailure(isThrowExceptionOnFailure()); - jettyBinding.setTransferException(isTransferException()); - } - return jettyBinding; - } - - public void setJettyBinding(JettyHttpBinding jettyBinding) { - this.jettyBinding = jettyBinding; - } - - public boolean isEnableJmx() { - return this.enableJmx; - } - - public void setEnableJmx(boolean enableJmx) { - this.enableJmx = enableJmx; - } - - public boolean isSendServerVersion() { - return sendServerVersion; - } - - public void setSendServerVersion(boolean sendServerVersion) { - this.sendServerVersion = sendServerVersion; - } - - public boolean isSendDateHeader() { - return sendDateHeader; - } - - public void setSendDateHeader(boolean sendDateHeader) { - this.sendDateHeader = sendDateHeader; - } - - public boolean isEnableMultipartFilter() { - return enableMultipartFilter; - } - - public void setEnableMultipartFilter(boolean enableMultipartFilter) { - this.enableMultipartFilter = enableMultipartFilter; - } - - public void setMultipartFilter(Filter filter) { - this.multipartFilter = filter; - } - - public Filter getMultipartFilter() { - return multipartFilter; - } - - public void setFilters(List<Filter> filterList) { - this.filters = filterList; - } - - public List<Filter> getFilters() { - return filters; - } - - public Long getContinuationTimeout() { - return continuationTimeout; - } - - public void setContinuationTimeout(Long continuationTimeout) { - this.continuationTimeout = continuationTimeout; - } - - public Boolean getUseContinuation() { - return useContinuation; - } - - public void setUseContinuation(Boolean useContinuation) { - this.useContinuation = useContinuation; - } - - public SSLContextParameters getSslContextParameters() { - return sslContextParameters; - } - - public void setSslContextParameters(SSLContextParameters sslContextParameters) { - this.sslContextParameters = sslContextParameters; - } - - public Integer getHttpClientMinThreads() { - return httpClientMinThreads; - } - - public void setHttpClientMinThreads(Integer httpClientMinThreads) { - this.httpClientMinThreads = httpClientMinThreads; - } - - public Integer getHttpClientMaxThreads() { - return httpClientMaxThreads; - } - - public void setHttpClientMaxThreads(Integer httpClientMaxThreads) { - this.httpClientMaxThreads = httpClientMaxThreads; - } - - public Map<String, Object> getHttpClientParameters() { - return httpClientParameters; - } - - public void setHttpClientParameters(Map<String, Object> httpClientParameters) { - this.httpClientParameters = httpClientParameters; - } - - public abstract JettyContentExchange createContentExchange(); - -} http://git-wip-us.apache.org/repos/asf/camel/blob/0d96e56d/components/camel-jetty/src/main/java/org/apache/camel/component/jetty/JettyHttpProducer.java ---------------------------------------------------------------------- diff --git a/components/camel-jetty/src/main/java/org/apache/camel/component/jetty/JettyHttpProducer.java b/components/camel-jetty/src/main/java/org/apache/camel/component/jetty/JettyHttpProducer.java deleted file mode 100644 index 46b0213..0000000 --- a/components/camel-jetty/src/main/java/org/apache/camel/component/jetty/JettyHttpProducer.java +++ /dev/null @@ -1,305 +0,0 @@ -/** - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.apache.camel.component.jetty; - -import java.io.ByteArrayOutputStream; -import java.io.InputStream; -import java.io.Serializable; -import java.net.URI; -import java.util.ArrayList; -import java.util.Iterator; -import java.util.List; -import java.util.Map; - -import org.apache.camel.AsyncCallback; -import org.apache.camel.AsyncProcessor; -import org.apache.camel.Endpoint; -import org.apache.camel.Exchange; -import org.apache.camel.Message; -import org.apache.camel.component.http.HttpConstants; -import org.apache.camel.component.http.HttpMethods; -import org.apache.camel.component.http.helper.HttpHelper; -import org.apache.camel.impl.DefaultAsyncProducer; -import org.apache.camel.spi.HeaderFilterStrategy; -import org.apache.camel.util.ExchangeHelper; -import org.apache.camel.util.IOHelper; -import org.apache.camel.util.ObjectHelper; -import org.apache.camel.util.URISupport; -import org.eclipse.jetty.client.HttpClient; -import org.eclipse.jetty.util.component.LifeCycle; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; - -/** - * @version - */ -public class JettyHttpProducer extends DefaultAsyncProducer implements AsyncProcessor { - private static final Logger LOG = LoggerFactory.getLogger(JettyHttpProducer.class); - private HttpClient client; - private boolean sharedClient; - private JettyHttpBinding binding; - - /** - * Creates this producer. - * <p/> - * A client must be set before use, eg either {@link #setClient(org.eclipse.jetty.client.HttpClient)} - * or {@link #setSharedClient(org.eclipse.jetty.client.HttpClient)}. - * - * @param endpoint the endpoint - */ - public JettyHttpProducer(Endpoint endpoint) { - super(endpoint); - } - - /** - * Creates this producer - * - * @param endpoint the endpoint - * @param client the non-shared client to use - */ - public JettyHttpProducer(Endpoint endpoint, HttpClient client) { - super(endpoint); - setClient(client); - } - - @Override - public JettyHttpEndpoint getEndpoint() { - return (JettyHttpEndpoint) super.getEndpoint(); - } - - public boolean process(Exchange exchange, final AsyncCallback callback) { - try { - processInternal(exchange, callback); - } catch (Exception e) { - // error occurred before we had a chance to go async - // so set exception and invoke callback true - exchange.setException(e); - callback.done(true); - return true; - } - - // we should continue processing this asynchronously - return false; - } - - private void processInternal(Exchange exchange, AsyncCallback callback) throws Exception { - // creating the url to use takes 2-steps - String url = HttpHelper.createURL(exchange, getEndpoint()); - URI uri = HttpHelper.createURI(exchange, url, getEndpoint()); - // get the url from the uri - url = uri.toASCIIString(); - - // execute any custom url rewrite - String rewriteUrl = HttpHelper.urlRewrite(exchange, url, getEndpoint(), this); - if (rewriteUrl != null) { - // update url and query string from the rewritten url - url = rewriteUrl; - } - - HttpMethods methodToUse = HttpHelper.createMethod(exchange, getEndpoint(), exchange.getIn().getBody() != null); - String method = methodToUse.createMethod(url).getName(); - - JettyContentExchange httpExchange = getEndpoint().createContentExchange(); - httpExchange.init(exchange, getBinding(), client, callback); - httpExchange.setURL(url); // Url has to be set first - httpExchange.setMethod(method); - - if (getEndpoint().getHttpClientParameters() != null) { - // For jetty 9 these parameters can not be set on the client - // so we need to set them on the httpExchange - String timeout = (String)getEndpoint().getHttpClientParameters().get("timeout"); - if (timeout != null) { - httpExchange.setTimeout(new Long(timeout)); - } - String supportRedirect = (String)getEndpoint().getHttpClientParameters().get("supportRedirect"); - if (supportRedirect != null) { - httpExchange.setSupportRedirect(new Boolean(supportRedirect)); - } - } - - LOG.trace("Using URL: {} with method: {}", url, method); - - // if we post or put then set data - if (HttpMethods.POST.equals(methodToUse) || HttpMethods.PUT.equals(methodToUse)) { - - String contentType = ExchangeHelper.getContentType(exchange); - if (contentType != null) { - httpExchange.setRequestContentType(contentType); - } - - if (contentType != null && HttpConstants.CONTENT_TYPE_JAVA_SERIALIZED_OBJECT.equals(contentType)) { - // serialized java object - Serializable obj = exchange.getIn().getMandatoryBody(Serializable.class); - // write object to output stream - ByteArrayOutputStream bos = new ByteArrayOutputStream(); - try { - HttpHelper.writeObjectToStream(bos, obj); - httpExchange.setRequestContent(bos.toByteArray()); - } finally { - IOHelper.close(bos, "body", LOG); - } - } else { - Object body = exchange.getIn().getBody(); - if (body instanceof String) { - String data = (String) body; - // be a bit careful with String as any type can most likely be converted to String - // so we only do an instanceof check and accept String if the body is really a String - // do not fallback to use the default charset as it can influence the request - // (for example application/x-www-form-urlencoded forms being sent) - String charset = IOHelper.getCharsetName(exchange, false); - httpExchange.setRequestContent(data, charset); - } else { - // then fallback to input stream - InputStream is = exchange.getContext().getTypeConverter().mandatoryConvertTo(InputStream.class, exchange, exchange.getIn().getBody()); - httpExchange.setRequestContent(is); - // setup the content length if it is possible - String length = exchange.getIn().getHeader(Exchange.CONTENT_LENGTH, String.class); - if (ObjectHelper.isNotEmpty(length)) { - httpExchange.addRequestHeader(Exchange.CONTENT_LENGTH, length); - } - } - } - } - - // if we bridge endpoint then we need to skip matching headers with the HTTP_QUERY to avoid sending - // duplicated headers to the receiver, so use this skipRequestHeaders as the list of headers to skip - Map<String, Object> skipRequestHeaders = null; - if (getEndpoint().isBridgeEndpoint()) { - exchange.setProperty(Exchange.SKIP_GZIP_ENCODING, Boolean.TRUE); - String queryString = exchange.getIn().getHeader(Exchange.HTTP_QUERY, String.class); - if (queryString != null) { - skipRequestHeaders = URISupport.parseQuery(queryString); - } - // Need to remove the Host key as it should be not used - exchange.getIn().getHeaders().remove("host"); - } - - // propagate headers as HTTP headers - Message in = exchange.getIn(); - HeaderFilterStrategy strategy = getEndpoint().getHeaderFilterStrategy(); - for (Map.Entry<String, Object> entry : in.getHeaders().entrySet()) { - String key = entry.getKey(); - Object headerValue = in.getHeader(key); - - if (headerValue != null) { - // use an iterator as there can be multiple values. (must not use a delimiter, and allow empty values) - final Iterator<?> it = ObjectHelper.createIterator(headerValue, null, true); - - // the values to add as a request header - final List<String> values = new ArrayList<String>(); - - // if its a multi value then check each value if we can add it and for multi values they - // should be combined into a single value - while (it.hasNext()) { - String value = exchange.getContext().getTypeConverter().convertTo(String.class, it.next()); - - // we should not add headers for the parameters in the uri if we bridge the endpoint - // as then we would duplicate headers on both the endpoint uri, and in HTTP headers as well - if (skipRequestHeaders != null && skipRequestHeaders.containsKey(key)) { - continue; - } - if (value != null && strategy != null && !strategy.applyFilterToCamelHeaders(key, value, exchange)) { - values.add(value); - } - } - - // add the value(s) as a http request header - if (values.size() > 0) { - // use the default toString of a ArrayList to create in the form [xxx, yyy] - // if multi valued, for a single value, then just output the value as is - String s = values.size() > 1 ? values.toString() : values.get(0); - httpExchange.addRequestHeader(key, s); - } - } - } - - // set the callback, which will handle all the response logic - if (LOG.isDebugEnabled()) { - LOG.debug("Sending HTTP request to: {}", httpExchange.getUrl()); - } - httpExchange.send(client); - } - - public JettyHttpBinding getBinding() { - return binding; - } - - public void setBinding(JettyHttpBinding binding) { - this.binding = binding; - } - - public HttpClient getClient() { - return client; - } - - public void setClient(HttpClient client) { - this.client = client; - this.sharedClient = false; - } - - public HttpClient getSharedClient() { - if (sharedClient) { - return client; - } else { - return null; - } - } - - public void setSharedClient(HttpClient sharedClient) { - this.client = sharedClient; - this.sharedClient = true; - } - - private Object getClientThreadPool() { - try { - return client.getClass().getMethod("getThreadPool").invoke(client); - } catch (Throwable t) { - // not found in Jetty 9 which is OK as the threadpool is auto started on Jetty 9 - } - return null; - } - - @Override - protected void doStart() throws Exception { - // only start non-shared client - if (!sharedClient && client != null) { - client.start(); - // start the thread pool - Object tp = getClientThreadPool(); - if (tp instanceof LifeCycle) { - LOG.debug("Starting client thread pool {}", tp); - ((LifeCycle) tp).start(); - } - } - super.doStart(); - } - - @Override - protected void doStop() throws Exception { - super.doStop(); - // only stop non-shared client - if (!sharedClient && client != null) { - client.stop(); - // stop thread pool - Object tp = getClientThreadPool(); - if (tp instanceof LifeCycle) { - LOG.debug("Stopping client thread pool {}", tp); - ((LifeCycle) tp).stop(); - } - } - } -} http://git-wip-us.apache.org/repos/asf/camel/blob/0d96e56d/components/camel-jetty/src/main/java/org/apache/camel/component/jetty/JettyRestHttpBinding.java ---------------------------------------------------------------------- diff --git a/components/camel-jetty/src/main/java/org/apache/camel/component/jetty/JettyRestHttpBinding.java b/components/camel-jetty/src/main/java/org/apache/camel/component/jetty/JettyRestHttpBinding.java deleted file mode 100644 index 6f211f3..0000000 --- a/components/camel-jetty/src/main/java/org/apache/camel/component/jetty/JettyRestHttpBinding.java +++ /dev/null @@ -1,75 +0,0 @@ -/** - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.apache.camel.component.jetty; - -import javax.servlet.http.HttpServletRequest; - -import org.apache.camel.component.http.DefaultHttpBinding; -import org.apache.camel.component.http.HttpEndpoint; -import org.apache.camel.component.http.HttpMessage; - -public class JettyRestHttpBinding extends DefaultHttpBinding { - @Deprecated - public JettyRestHttpBinding() { - } - public JettyRestHttpBinding(HttpEndpoint ep) { - super(ep); - } - - @Override - protected void populateRequestParameters(HttpServletRequest request, HttpMessage message) throws Exception { - super.populateRequestParameters(request, message); - - String path = request.getPathInfo(); - if (path == null) { - return; - } - - // in the endpoint the user may have defined rest {} placeholders - // so we need to map those placeholders with data from the incoming request context path - - JettyHttpEndpoint endpoint = (JettyHttpEndpoint) message.getExchange().getFromEndpoint(); - String consumerPath = endpoint.getPath(); - - if (useRestMatching(consumerPath)) { - - // split using single char / is optimized in the jdk - String[] paths = path.split("/"); - String[] consumerPaths = consumerPath.split("/"); - - for (int i = 0; i < consumerPaths.length; i++) { - if (paths.length < i) { - break; - } - String p1 = consumerPaths[i]; - if (p1.startsWith("{") && p1.endsWith("}")) { - String key = p1.substring(1, p1.length() - 1); - String value = paths[i]; - if (value != null) { - message.setHeader(key, value); - } - } - } - } - } - - private boolean useRestMatching(String path) { - // only need to do rest matching if using { } placeholders - return path.indexOf('{') > -1; - } - -} http://git-wip-us.apache.org/repos/asf/camel/blob/0d96e56d/components/camel-jetty/src/main/java/org/apache/camel/component/jetty/JettyRestServletResolveConsumerStrategy.java ---------------------------------------------------------------------- diff --git a/components/camel-jetty/src/main/java/org/apache/camel/component/jetty/JettyRestServletResolveConsumerStrategy.java b/components/camel-jetty/src/main/java/org/apache/camel/component/jetty/JettyRestServletResolveConsumerStrategy.java deleted file mode 100644 index a8c3a4f..0000000 --- a/components/camel-jetty/src/main/java/org/apache/camel/component/jetty/JettyRestServletResolveConsumerStrategy.java +++ /dev/null @@ -1,163 +0,0 @@ -/** - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.apache.camel.component.jetty; - -import java.util.ArrayList; -import java.util.Iterator; -import java.util.List; -import java.util.Locale; -import java.util.Map; -import javax.servlet.http.HttpServletRequest; - -import org.apache.camel.component.http.HttpConsumer; -import org.apache.camel.component.http.HttpServletResolveConsumerStrategy; - -/** - * A {@link org.apache.camel.component.http.HttpServletResolveConsumerStrategy} that supports the Rest DSL. - */ -public class JettyRestServletResolveConsumerStrategy extends HttpServletResolveConsumerStrategy { - - @Override - public HttpConsumer resolve(HttpServletRequest request, Map<String, HttpConsumer> consumers) { - HttpConsumer answer = null; - - String path = request.getPathInfo(); - if (path == null) { - return null; - } - String method = request.getMethod(); - if (method == null) { - return null; - } - - List<HttpConsumer> candidates = new ArrayList<HttpConsumer>(); - - // first match by http method - for (Map.Entry<String, HttpConsumer> entry : consumers.entrySet()) { - String restrict = entry.getValue().getEndpoint().getHttpMethodRestrict(); - if (matchRestMethod(method, restrict)) { - candidates.add(entry.getValue()); - } - } - - // then see if we got a direct match - Iterator<HttpConsumer> it = candidates.iterator(); - while (it.hasNext()) { - HttpConsumer consumer = it.next(); - String consumerPath = consumer.getPath(); - if (matchRestPath(path, consumerPath, false)) { - answer = consumer; - break; - } - } - - // then match by non wildcard path - if (answer == null) { - it = candidates.iterator(); - while (it.hasNext()) { - HttpConsumer consumer = it.next(); - String consumerPath = consumer.getPath(); - if (!matchRestPath(path, consumerPath, true)) { - it.remove(); - } - } - - // there should only be one - if (candidates.size() == 1) { - answer = candidates.get(0); - } - } - - if (answer == null) { - // fallback to default - answer = super.resolve(request, consumers); - } - - return answer; - } - - /** - * Matches the given request path with the configured consumer path - * - * @param requestPath the request path - * @param consumerPath the consumer path which may use { } tokens - * @return <tt>true</tt> if matched, <tt>false</tt> otherwise - */ - public boolean matchRestPath(String requestPath, String consumerPath, boolean wildcard) { - // remove starting/ending slashes - if (requestPath.startsWith("/")) { - requestPath = requestPath.substring(1); - } - if (requestPath.endsWith("/")) { - requestPath = requestPath.substring(0, requestPath.length() - 1); - } - // remove starting/ending slashes - if (consumerPath.startsWith("/")) { - consumerPath = consumerPath.substring(1); - } - if (consumerPath.endsWith("/")) { - consumerPath = consumerPath.substring(0, consumerPath.length() - 1); - } - - // split using single char / is optimized in the jdk - String[] requestPaths = requestPath.split("/"); - String[] consumerPaths = consumerPath.split("/"); - - // must be same number of path's - if (requestPaths.length != consumerPaths.length) { - return false; - } - - for (int i = 0; i < requestPaths.length; i++) { - String p1 = requestPaths[i]; - String p2 = consumerPaths[i]; - - if (wildcard && p2.startsWith("{") && p2.endsWith("}")) { - // always matches - continue; - } - - if (!p1.equals(p2)) { - return false; - } - } - - // assume matching - return true; - } - - /** - * Matches the given request HTTP method with the configured HTTP method of the consumer - * - * @param method the request HTTP method - * @param restrict the consumer configured HTTP restrict method - * @return <tt>true</tt> if matched, <tt>false</tt> otherwise - */ - public boolean matchRestMethod(String method, String restrict) { - if (restrict == null) { - return true; - } - - // always match OPTIONS as some REST clients uses that prior to calling the service - if ("OPTIONS".equals(method)) { - return true; - } - - return restrict.toLowerCase(Locale.US).contains(method.toLowerCase(Locale.US)); - } - -} http://git-wip-us.apache.org/repos/asf/camel/blob/0d96e56d/components/camel-jetty/src/main/java/org/apache/camel/component/jetty/package.html ---------------------------------------------------------------------- diff --git a/components/camel-jetty/src/main/java/org/apache/camel/component/jetty/package.html b/components/camel-jetty/src/main/java/org/apache/camel/component/jetty/package.html deleted file mode 100644 index a5371d9..0000000 --- a/components/camel-jetty/src/main/java/org/apache/camel/component/jetty/package.html +++ /dev/null @@ -1,25 +0,0 @@ -<!-- - Licensed to the Apache Software Foundation (ASF) under one or more - contributor license agreements. See the NOTICE file distributed with - this work for additional information regarding copyright ownership. - The ASF licenses this file to You under the Apache License, Version 2.0 - (the "License"); you may not use this file except in compliance with - the License. You may obtain a copy of the License at - - http://www.apache.org/licenses/LICENSE-2.0 - - Unless required by applicable law or agreed to in writing, software - distributed under the License is distributed on an "AS IS" BASIS, - WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - See the License for the specific language governing permissions and - limitations under the License. ---> -<html> -<head> -</head> -<body> - -Defines the <a href="http://activemq.apache.org/camel/jetty-http.html";>Jetty HTTP Component</a> - -</body> -</html> http://git-wip-us.apache.org/repos/asf/camel/blob/0d96e56d/components/camel-jetty/src/main/jetty8/org/apache/camel/component/jetty8/CamelHttpClient8.java ---------------------------------------------------------------------- diff --git a/components/camel-jetty/src/main/jetty8/org/apache/camel/component/jetty8/CamelHttpClient8.java b/components/camel-jetty/src/main/jetty8/org/apache/camel/component/jetty8/CamelHttpClient8.java deleted file mode 100644 index a484230..0000000 --- a/components/camel-jetty/src/main/jetty8/org/apache/camel/component/jetty8/CamelHttpClient8.java +++ /dev/null @@ -1,68 +0,0 @@ -/** - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.apache.camel.component.jetty8; - -import java.util.concurrent.Executor; - -import org.apache.camel.component.jetty.CamelHttpClient; -import org.eclipse.jetty.util.ssl.SslContextFactory; -import org.eclipse.jetty.util.thread.ThreadPool; - -@SuppressWarnings("unchecked") -public class CamelHttpClient8 extends CamelHttpClient { - - public CamelHttpClient8(SslContextFactory sslContextFactory) { - super(sslContextFactory); - setConnectorType(); - } - - @Override - protected void doStart() throws Exception { - super.doStart(); - } - - private void setConnectorType() { - setConnectorType(2); - } - - protected boolean hasThreadPool() { - return getThreadPool() != null; - } - - protected void setThreadPoolOrExecutor(Executor pool) { - setThreadPool((ThreadPool)pool); - } - - public void setProxy(String host, int port) { - setProxy(new org.eclipse.jetty.client.Address(host, port)); - } - - private void setupRedirectListener() { - registerListener(CamelRedirectListener.class.getName()); - } - - @Override - public String getProxyHost() { - return getProxy().getHost(); - } - - @Override - public int getProxyPort() { - return getProxy().getPort(); - } - -}
