org.apache.camel.component.websocket
Class WebsocketEndpoint

java.lang.Object
  extended by org.apache.camel.support.ServiceSupport
      extended by org.apache.camel.impl.DefaultEndpoint
          extended by 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


Field Summary
 
Fields inherited from class org.apache.camel.support.ServiceSupport
shutdown, shuttingdown, started, starting, stopped, stopping, suspended, suspending
 
Constructor Summary
WebsocketEndpoint(WebsocketComponent component, String uri, String remaining, Map<String,Object> parameters)
           
 
Method Summary
 void connect(WebsocketConsumer consumer)
           
 void connect(WebsocketProducer producer)
           
 org.apache.camel.Consumer createConsumer(org.apache.camel.Processor processor)
           
 org.apache.camel.Producer createProducer()
           
 void disconnect(WebsocketConsumer consumer)
           
 void disconnect(WebsocketProducer producer)
           
protected  void doStart()
           
protected  void doStop()
           
 String getAllowedOrigins()
           
 Integer getBufferSize()
           
 WebsocketComponent getComponent()
           
 String getFilterPath()
           
 List<org.eclipse.jetty.server.Handler> getHandlers()
           
 String getHost()
           
 Integer getMaxBinaryMessageSize()
           
 Integer getMaxIdleTime()
           
 Integer getMaxTextMessageSize()
           
 Integer getMinVersion()
           
 String getPath()
           
 Integer getPort()
           
 String getProtocol()
           
 Boolean getSendToAll()
           
 org.apache.camel.util.jsse.SSLContextParameters getSslContextParameters()
           
 String getStaticResources()
           
 URI getUri()
           
 boolean isCrossOriginFilterOn()
           
 boolean isEnableJmx()
           
 boolean isSessionSupport()
           
 boolean isSingleton()
           
 void setAllowedOrigins(String allowedOrigins)
           
 void setBufferSize(Integer bufferSize)
           
 void setCrossOriginFilterOn(boolean crossOriginFilterOn)
           
 void setEnableJmx(boolean enableJmx)
           
 void setFilterPath(String filterPath)
           
 void setHandlers(List<org.eclipse.jetty.server.Handler> handlers)
           
 void setHost(String host)
           
 void setMaxBinaryMessageSize(Integer maxBinaryMessageSize)
           
 void setMaxIdleTime(Integer maxIdleTime)
           
 void setMaxTextMessageSize(Integer maxTextMessageSize)
           
 void setMinVersion(Integer minVersion)
           
 void setPort(int port)
           
 void setSendToAll(Boolean sendToAll)
           
 void setSessionSupport(boolean support)
           
 void setSslContextParameters(org.apache.camel.util.jsse.SSLContextParameters sslContextParameters)
           
 void setStaticResources(String staticResources)
           
 
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 class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
 
Methods inherited from interface org.apache.camel.Service
start, stop
 

Constructor Detail

WebsocketEndpoint

public WebsocketEndpoint(WebsocketComponent component,
                         String uri,
                         String remaining,
                         Map<String,Object> parameters)
Method Detail

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