@UriEndpoint(scheme="atmosphere-websocket", extendsScheme="servlet", title="Atmosphere Websocket", syntax="atmosphere-websocket:servicePath", consumerClass=WebsocketConsumer.class, label="websocket", excludeProperties="httpUri,contextPath") 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.
|
getContextPath, getServletName, isLenientProperties, setContextPath, setServletName
connect, disconnect, getAuthMethodPriority, getBinding, getComponent, getHeaderFilterStrategy, getHttpBinding, getHttpMethodRestrict, getHttpUri, getOkStatusCodeRange, getPath, getPort, getProtocol, getProxyHost, getProxyPort, getResponseBufferSize, getUrlRewrite, isBridgeEndpoint, isChunked, isConnectionClose, isCopyHeaders, isDisableStreamCache, isEagerCheckContentAvailable, isIgnoreResponseBody, isMapHttpMessageBody, isMapHttpMessageHeaders, isMatchOnUriPrefix, isOptionsEnabled, isPreserveHostHeader, 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 WebsocketEndpoint(String endPointURI, WebsocketComponent component, URI httpUri) throws URISyntaxException
URISyntaxException
public org.apache.camel.Producer createProducer() throws Exception
createProducer
in interface org.apache.camel.Endpoint
createProducer
in class org.apache.camel.component.servlet.ServletEndpoint
Exception
public org.apache.camel.Consumer createConsumer(org.apache.camel.Processor processor) throws Exception
createConsumer
in interface org.apache.camel.Endpoint
createConsumer
in class org.apache.camel.component.servlet.ServletEndpoint
Exception
public boolean isSingleton()
isSingleton
in interface org.apache.camel.IsSingleton
isSingleton
in class org.apache.camel.http.common.HttpCommonEndpoint
public boolean isSendToAll()
public void setSendToAll(boolean sendToAll)
public boolean isUseStreaming()
public void setUseStreaming(boolean useStreaming)
public WebsocketConsumer getWebsocketConsumer()
Apache Camel