@UriEndpoint(firstVersion="2.14.0",
scheme="atmosphere-websocket",
extendsScheme="servlet",
title="Atmosphere Websocket",
syntax="atmosphere-websocket:servicePath",
consumerClass=WebsocketConsumer.class,
label="websocket",
excludeProperties="httpUri,contextPath,authMethod,authMethodPriority,authUsername,authPassword,authDomain,authHostproxyAuthScheme,proxyAuthMethod,proxyAuthUsername,proxyAuthPassword,proxyAuthHost,proxyAuthPort,proxyAuthDomain")
public class WebsocketEndpoint
extends org.apache.camel.component.servlet.ServletEndpoint
| Constructor and Description |
|---|
WebsocketEndpoint(String endPointURI,
WebsocketComponent component,
URI httpUri) |
| Modifier and Type | Method and Description |
|---|---|
org.apache.camel.Consumer |
createConsumer(org.apache.camel.Processor processor) |
org.apache.camel.Producer |
createProducer() |
WebsocketConsumer |
getWebsocketConsumer() |
boolean |
isSendToAll() |
boolean |
isSingleton() |
boolean |
isUseStreaming() |
void |
setSendToAll(boolean sendToAll)
Whether to send to all (broadcast) or send to a single receiver.
|
void |
setUseStreaming(boolean useStreaming)
To enable streaming to send data as multiple text fragments.
|
getComponent, getContextPath, getHttpBinding, getServletName, isAttachmentMultipartBinding, isLenientProperties, setAttachmentMultipartBinding, setContextPath, setHttpBinding, setServletNameconnect, disconnect, getAuthDomain, getAuthHost, getAuthMethod, getAuthMethodPriority, getAuthPassword, getAuthUsername, getBinding, getCookieHandler, getHeaderFilterStrategy, getHttpMethod, getHttpMethodRestrict, getHttpUri, getOkStatusCodeRange, getPath, getPort, getProtocol, getProxyAuthDomain, getProxyAuthHost, getProxyAuthMethod, getProxyAuthPassword, getProxyAuthPort, getProxyAuthScheme, getProxyAuthUsername, getProxyHost, getProxyPort, getResponseBufferSize, getUrlRewrite, isAsync, isBridgeEndpoint, isChunked, isConnectionClose, isCopyHeaders, isDisableStreamCache, isEagerCheckContentAvailable, isIgnoreResponseBody, isMapHttpMessageBody, isMapHttpMessageFormUrlEncodedBody, isMapHttpMessageHeaders, isMatchOnUriPrefix, isOptionsEnabled, isPreserveHostHeader, isThrowExceptionOnFailure, isTraceEnabled, isTransferException, setAsync, setAuthDomain, setAuthHost, setAuthMethod, setAuthMethodPriority, setAuthPassword, setAuthUsername, setBinding, setBridgeEndpoint, setChunked, setConnectionClose, setCookieHandler, setCopyHeaders, setDisableStreamCache, setEagerCheckContentAvailable, setHeaderFilterStrategy, setHttpMethod, setHttpMethodRestrict, setHttpUri, setIgnoreResponseBody, setMapHttpMessageBody, setMapHttpMessageFormUrlEncodedBody, setMapHttpMessageHeaders, setMatchOnUriPrefix, setOkStatusCodeRange, setOptionsEnabled, setPreserveHostHeader, setProxyAuthDomain, setProxyAuthHost, setProxyAuthMethod, setProxyAuthPassword, setProxyAuthPort, setProxyAuthScheme, setProxyAuthUsername, setProxyHost, setProxyPort, setResponseBufferSize, setThrowExceptionOnFailure, setTraceEnabled, setTransferException, setUrlRewriteconfigureConsumer, 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, toStringdoResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspendpublic WebsocketEndpoint(String endPointURI, WebsocketComponent component, URI httpUri) throws URISyntaxException
URISyntaxExceptionpublic org.apache.camel.Producer createProducer()
throws Exception
createProducer in interface org.apache.camel.EndpointcreateProducer in class org.apache.camel.component.servlet.ServletEndpointExceptionpublic org.apache.camel.Consumer createConsumer(org.apache.camel.Processor processor)
throws Exception
createConsumer in interface org.apache.camel.EndpointcreateConsumer in class org.apache.camel.component.servlet.ServletEndpointExceptionpublic boolean isSingleton()
isSingleton in interface org.apache.camel.IsSingletonisSingleton in class org.apache.camel.http.common.HttpCommonEndpointpublic boolean isSendToAll()
public void setSendToAll(boolean sendToAll)
public boolean isUseStreaming()
public void setUseStreaming(boolean useStreaming)
public WebsocketConsumer getWebsocketConsumer()
Apache Camel