public abstract class JettyHttpEndpoint
extends org.apache.camel.http.common.HttpCommonEndpoint
Constructor and Description |
---|
JettyHttpEndpoint(JettyHttpComponent component,
String uri,
URI httpURL) |
Modifier and Type | Method and Description |
---|---|
org.apache.camel.Consumer |
createConsumer(org.apache.camel.Processor processor) |
abstract JettyContentExchange |
createContentExchange() |
protected org.eclipse.jetty.client.HttpClient |
createJettyHttpClient() |
org.apache.camel.Producer |
createProducer() |
JettyHttpComponent |
getComponent() |
Long |
getContinuationTimeout() |
Map<String,String> |
getFilterInitParameters() |
List<javax.servlet.Filter> |
getFilters() |
List<org.eclipse.jetty.server.Handler> |
getHandlers() |
org.eclipse.jetty.client.HttpClient |
getHttpClient() |
Integer |
getHttpClientMaxThreads() |
Integer |
getHttpClientMinThreads() |
Map<String,Object> |
getHttpClientParameters() |
JettyHttpBinding |
getJettyBinding(org.eclipse.jetty.client.HttpClient httpClient) |
javax.servlet.Filter |
getMultipartFilter() |
org.apache.camel.util.jsse.SSLContextParameters |
getSslContextParameters() |
String |
getSslContextParametersRef()
Deprecated.
|
Boolean |
getUseContinuation() |
boolean |
isEnableCORS() |
boolean |
isEnableJmx() |
boolean |
isEnableMultipartFilter() |
boolean |
isSendDateHeader() |
boolean |
isSendServerVersion() |
boolean |
isSessionSupport() |
void |
setContinuationTimeout(Long continuationTimeout)
Allows to set a timeout in millis when using Jetty as consumer (server).
|
void |
setEnableCORS(boolean enableCORS)
If the option is true, Jetty server will setup the CrossOriginFilter which supports the CORS out of box.
|
void |
setEnableJmx(boolean enableJmx)
If this option is true, Jetty JMX support will be enabled for this endpoint.
|
void |
setEnableMultipartFilter(boolean enableMultipartFilter)
Whether Jetty org.eclipse.jetty.servlets.MultiPartFilter is enabled or not.
|
void |
setFilterInitParameters(Map<String,String> filterInitParameters)
Configuration of the filter init parameters.
|
void |
setFilters(List<javax.servlet.Filter> filterList)
Allows using a custom filters which is putted into a list and can be find in the Registry.
|
void |
setHandlers(List<org.eclipse.jetty.server.Handler> handlers)
Specifies a comma-delimited set of org.mortbay.jetty.Handler instances in your Registry (such as your Spring ApplicationContext).
|
void |
setHttpClient(org.eclipse.jetty.client.HttpClient httpClient)
Sets a shared
HttpClient to use for all producers
created by this endpoint. |
void |
setHttpClientMaxThreads(Integer httpClientMaxThreads)
To set a value for maximum number of threads in HttpClient thread pool.
|
void |
setHttpClientMinThreads(Integer httpClientMinThreads)
To set a value for minimum number of threads in HttpClient thread pool.
|
void |
setHttpClientParameters(Map<String,Object> httpClientParameters)
Configuration of Jetty's HttpClient.
|
void |
setJettyBinding(JettyHttpBinding jettyBinding)
To use a custom JettyHttpBinding which be used to customize how a response should be written for the producer.
|
void |
setMultipartFilter(javax.servlet.Filter filter)
Allows using a custom multipart filter.
|
void |
setSendDateHeader(boolean sendDateHeader)
If the option is true, jetty server will send the date header to the client which sends the request.
|
void |
setSendServerVersion(boolean sendServerVersion)
If the option is true, jetty will send the server header with the jetty version information to the client which sends the request.
|
void |
setSessionSupport(boolean support)
Specifies whether to enable the session manager on the server side of Jetty.
|
void |
setSslContextParameters(org.apache.camel.util.jsse.SSLContextParameters sslContextParameters)
To configure security using SSLContextParameters
|
void |
setSslContextParametersRef(String sslContextParametersRef)
Deprecated.
|
void |
setUseContinuation(Boolean useContinuation)
Whether or not to use Jetty continuations for the Jetty Server.
|
canConnect, connect, disconnect, getAuthMethodPriority, getBinding, getHeaderFilterStrategy, getHttpBinding, getHttpMethodRestrict, getHttpUri, getOkStatusCodeRange, getPath, getPort, getProtocol, getProxyHost, getProxyPort, getResponseBufferSize, getUrlRewrite, isBridgeEndpoint, isChunked, isConnectionClose, isCopyHeaders, isDisableStreamCache, isEagerCheckContentAvailable, isIgnoreResponseBody, isLenientProperties, isMapHttpMessageBody, isMapHttpMessageHeaders, isMatchOnUriPrefix, isOptionsEnabled, isPreserveHostHeader, isSingleton, isThrowExceptionOnFailure, isTraceEnabled, isTransferException, setAuthMethodPriority, setBinding, setBridgeEndpoint, setChunked, setConnectionClose, setCopyHeaders, setDisableStreamCache, setEagerCheckContentAvailable, setHeaderFilterStrategy, setHttpBinding, setHttpMethodRestrict, setHttpUri, setIgnoreResponseBody, setMapHttpMessageBody, setMapHttpMessageHeaders, setMatchOnUriPrefix, setOkStatusCodeRange, setOptionsEnabled, setPreserveHostHeader, setProxyHost, setProxyPort, setResponseBufferSize, setThrowExceptionOnFailure, setTraceEnabled, setTransferException, setUrlRewrite
configureConsumer, configurePollingConsumer, configureProperties, createEndpointConfiguration, createEndpointUri, createExchange, createExchange, createExchange, createPollingConsumer, doStart, doStop, equals, getCamelContext, getConsumerProperties, getEndpointConfiguration, getEndpointKey, getEndpointUri, getExceptionHandler, getExchangePattern, getId, getPollingConsumerBlockTimeout, getPollingConsumerQueueSize, hashCode, isBridgeErrorHandler, isPollingConsumerBlockWhenFull, isSynchronous, setBridgeErrorHandler, setCamelContext, setConsumerProperties, setEndpointConfiguration, setEndpointUri, setEndpointUriIfNotSpecified, setExceptionHandler, setExchangePattern, setPollingConsumerBlockTimeout, setPollingConsumerBlockWhenFull, setPollingConsumerQueueSize, setProperties, setSynchronous, toString
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
public JettyHttpEndpoint(JettyHttpComponent component, String uri, URI httpURL) throws URISyntaxException
URISyntaxException
public JettyHttpComponent getComponent()
getComponent
in class org.apache.camel.http.common.HttpCommonEndpoint
protected org.eclipse.jetty.client.HttpClient createJettyHttpClient() throws Exception
Exception
public org.apache.camel.Consumer createConsumer(org.apache.camel.Processor processor) throws Exception
Exception
public void setSessionSupport(boolean support)
public boolean isSessionSupport()
public List<org.eclipse.jetty.server.Handler> getHandlers()
public void setHandlers(List<org.eclipse.jetty.server.Handler> handlers)
public org.eclipse.jetty.client.HttpClient getHttpClient() throws Exception
Exception
public void setHttpClient(org.eclipse.jetty.client.HttpClient httpClient)
HttpClient
to use for all producers
created by this endpoint. By default each producer will
use a new http client, and not share.
Important: 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 start method on the client to ensure
its started when this endpoint creates a producer.
This options should only be used in special circumstances.public JettyHttpBinding getJettyBinding(org.eclipse.jetty.client.HttpClient httpClient)
public void setJettyBinding(JettyHttpBinding jettyBinding)
public boolean isEnableJmx()
public void setEnableJmx(boolean enableJmx)
public boolean isSendServerVersion()
public void setSendServerVersion(boolean sendServerVersion)
public boolean isSendDateHeader()
public void setSendDateHeader(boolean sendDateHeader)
public boolean isEnableMultipartFilter()
public void setEnableMultipartFilter(boolean enableMultipartFilter)
public void setMultipartFilter(javax.servlet.Filter filter)
public javax.servlet.Filter getMultipartFilter()
public void setFilters(List<javax.servlet.Filter> filterList)
public List<javax.servlet.Filter> getFilters()
public Long getContinuationTimeout()
public void setContinuationTimeout(Long continuationTimeout)
public Boolean getUseContinuation()
public void setUseContinuation(Boolean useContinuation)
public org.apache.camel.util.jsse.SSLContextParameters getSslContextParameters()
public void setSslContextParameters(org.apache.camel.util.jsse.SSLContextParameters sslContextParameters)
@Deprecated public String getSslContextParametersRef()
@Deprecated public void setSslContextParametersRef(String sslContextParametersRef)
public Integer getHttpClientMinThreads()
public void setHttpClientMinThreads(Integer httpClientMinThreads)
public Integer getHttpClientMaxThreads()
public void setHttpClientMaxThreads(Integer httpClientMaxThreads)
public void setHttpClientParameters(Map<String,Object> httpClientParameters)
public void setFilterInitParameters(Map<String,String> filterInitParameters)
public boolean isEnableCORS()
public void setEnableCORS(boolean enableCORS)
public abstract JettyContentExchange createContentExchange()
Apache Camel