@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 org.asynchttpclient.AsyncHttpClient |
createClient(org.asynchttpclient.AsyncHttpClientConfig config) |
org.apache.camel.Consumer |
createConsumer(org.apache.camel.Processor processor) |
org.apache.camel.Producer |
createProducer() |
protected void |
doStop() |
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
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
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 org.asynchttpclient.AsyncHttpClient createClient(org.asynchttpclient.AsyncHttpClientConfig config)
createClient
in class org.apache.camel.component.ahc.AhcEndpoint
Apache Camel