@UriEndpoint(scheme="ahc-ws,ahc-wss", extendsScheme="ahc,ahc", title="AHC Websocket,AHC Secure Websocket", syntax="ahc-ws:httpUri", consumerClass=WsConsumer.class, label="websocket") public class WsEndpoint extends org.apache.camel.component.ahc.AhcEndpoint
Constructor and Description |
---|
WsEndpoint(String endpointUri,
WsComponent component) |
Modifier and Type | Method and Description |
---|---|
void |
connect() |
protected com.ning.http.client.AsyncHttpClient |
createClient(com.ning.http.client.AsyncHttpClientConfig config) |
org.apache.camel.Consumer |
createConsumer(org.apache.camel.Processor processor) |
org.apache.camel.Producer |
createProducer() |
protected void |
doStop() |
protected com.ning.http.client.AsyncHttpProvider |
getAsyncHttpProvider(com.ning.http.client.AsyncHttpClientConfig config) |
WsComponent |
getComponent() |
boolean |
isSendMessageOnError() |
boolean |
isUseStreaming() |
void |
setSendMessageOnError(boolean sendMessageOnError)
Whether to send an message if the web-socket listener received an error.
|
void |
setUseStreaming(boolean useStreaming)
To enable streaming to send data as multiple text fragments.
|
doStart, getBinding, getBufferSize, getClient, getClientConfig, getClientConfigOptions, getHeaderFilterStrategy, getHttpUri, getSslContextParameters, isBridgeEndpoint, isConnectionClose, isLenientProperties, isSingleton, isThrowExceptionOnFailure, isTransferException, setBinding, setBridgeEndpoint, setBufferSize, setClient, setClientConfig, setClientConfigOptions, setConnectionClose, setHeaderFilterStrategy, setHttpUri, setSslContextParameters, setThrowExceptionOnFailure, setTransferException
configureConsumer, configurePollingConsumer, configureProperties, createEndpointConfiguration, createEndpointUri, createExchange, createExchange, createExchange, createPollingConsumer, 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 WsEndpoint(String endpointUri, WsComponent component)
public WsComponent getComponent()
getComponent
in class org.apache.camel.component.ahc.AhcEndpoint
public org.apache.camel.Producer createProducer() throws Exception
createProducer
in interface org.apache.camel.Endpoint
createProducer
in class org.apache.camel.component.ahc.AhcEndpoint
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.ahc.AhcEndpoint
Exception
public boolean isUseStreaming()
public void setUseStreaming(boolean useStreaming)
public boolean isSendMessageOnError()
public void setSendMessageOnError(boolean sendMessageOnError)
protected com.ning.http.client.AsyncHttpClient createClient(com.ning.http.client.AsyncHttpClientConfig config)
createClient
in class org.apache.camel.component.ahc.AhcEndpoint
protected void doStop() throws Exception
doStop
in class org.apache.camel.component.ahc.AhcEndpoint
Exception
protected com.ning.http.client.AsyncHttpProvider getAsyncHttpProvider(com.ning.http.client.AsyncHttpClientConfig config)
Apache Camel