org.apache.camel.component.websocket
Class WebsocketEndpoint
java.lang.Object
org.apache.camel.support.ServiceSupport
org.apache.camel.impl.DefaultEndpoint
org.apache.camel.component.websocket.WebsocketEndpoint
- All Implemented Interfaces:
- org.apache.camel.CamelContextAware, org.apache.camel.Endpoint, org.apache.camel.IsSingleton, org.apache.camel.Service, org.apache.camel.ShutdownableService, org.apache.camel.spi.HasId, org.apache.camel.StatefulService, org.apache.camel.SuspendableService
public class WebsocketEndpoint
- extends org.apache.camel.impl.DefaultEndpoint
Fields inherited from class org.apache.camel.support.ServiceSupport |
shutdown, shuttingdown, started, starting, stopped, stopping, suspended, suspending |
Methods inherited from class org.apache.camel.impl.DefaultEndpoint |
configureConsumer, configurePollingConsumer, configureProperties, createEndpointConfiguration, createEndpointUri, createExchange, createExchange, createExchange, createPollingConsumer, equals, getCamelContext, getConsumerProperties, getEndpointConfiguration, getEndpointKey, getEndpointUri, getExchangePattern, getId, hashCode, isLenientProperties, isSynchronous, setCamelContext, setConsumerProperties, setEndpointConfiguration, setEndpointUri, setEndpointUriIfNotSpecified, setExchangePattern, setProperties, setSynchronous, toString |
Methods inherited from class org.apache.camel.support.ServiceSupport |
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, resume, shutdown, start, stop, suspend |
Methods inherited from interface org.apache.camel.Service |
start, stop |
WebsocketEndpoint
public WebsocketEndpoint(WebsocketComponent component,
String uri,
String remaining,
Map<String,Object> parameters)
getComponent
public WebsocketComponent getComponent()
- Overrides:
getComponent
in class org.apache.camel.impl.DefaultEndpoint
createConsumer
public org.apache.camel.Consumer createConsumer(org.apache.camel.Processor processor)
throws Exception
- Throws:
Exception
createProducer
public org.apache.camel.Producer createProducer()
throws Exception
- Throws:
Exception
connect
public void connect(WebsocketConsumer consumer)
throws Exception
- Throws:
Exception
disconnect
public void disconnect(WebsocketConsumer consumer)
throws Exception
- Throws:
Exception
connect
public void connect(WebsocketProducer producer)
throws Exception
- Throws:
Exception
disconnect
public void disconnect(WebsocketProducer producer)
throws Exception
- Throws:
Exception
isSingleton
public boolean isSingleton()
getUri
public URI getUri()
getPort
public Integer getPort()
getHost
public String getHost()
setHost
public void setHost(String host)
setPort
public void setPort(int port)
getStaticResources
public String getStaticResources()
setStaticResources
public void setStaticResources(String staticResources)
getSendToAll
public Boolean getSendToAll()
setSendToAll
public void setSendToAll(Boolean sendToAll)
getProtocol
public String getProtocol()
getPath
public String getPath()
setSessionSupport
public void setSessionSupport(boolean support)
isSessionSupport
public boolean isSessionSupport()
getBufferSize
public Integer getBufferSize()
setBufferSize
public void setBufferSize(Integer bufferSize)
getMaxIdleTime
public Integer getMaxIdleTime()
setMaxIdleTime
public void setMaxIdleTime(Integer maxIdleTime)
getMaxTextMessageSize
public Integer getMaxTextMessageSize()
setMaxTextMessageSize
public void setMaxTextMessageSize(Integer maxTextMessageSize)
getMaxBinaryMessageSize
public Integer getMaxBinaryMessageSize()
setMaxBinaryMessageSize
public void setMaxBinaryMessageSize(Integer maxBinaryMessageSize)
getMinVersion
public Integer getMinVersion()
setMinVersion
public void setMinVersion(Integer minVersion)
getHandlers
public List<org.eclipse.jetty.server.Handler> getHandlers()
setHandlers
public void setHandlers(List<org.eclipse.jetty.server.Handler> handlers)
getSslContextParameters
public org.apache.camel.util.jsse.SSLContextParameters getSslContextParameters()
setSslContextParameters
public void setSslContextParameters(org.apache.camel.util.jsse.SSLContextParameters sslContextParameters)
isEnableJmx
public boolean isEnableJmx()
setEnableJmx
public void setEnableJmx(boolean enableJmx)
getAllowedOrigins
public String getAllowedOrigins()
setAllowedOrigins
public void setAllowedOrigins(String allowedOrigins)
isCrossOriginFilterOn
public boolean isCrossOriginFilterOn()
setCrossOriginFilterOn
public void setCrossOriginFilterOn(boolean crossOriginFilterOn)
getFilterPath
public String getFilterPath()
setFilterPath
public void setFilterPath(String filterPath)
doStart
protected void doStart()
throws Exception
- Overrides:
doStart
in class org.apache.camel.impl.DefaultEndpoint
- Throws:
Exception
doStop
protected void doStop()
throws Exception
- Overrides:
doStop
in class org.apache.camel.impl.DefaultEndpoint
- Throws:
Exception
Apache Camel