org.apache.camel.component.websocket
Class WebsocketConsumer

java.lang.Object
  extended by org.apache.camel.support.ServiceSupport
      extended by org.apache.camel.impl.DefaultConsumer
          extended by org.apache.camel.component.websocket.WebsocketConsumer
All Implemented Interfaces:
WebsocketProducerConsumer, org.apache.camel.Consumer, org.apache.camel.RouteAware, org.apache.camel.Service, org.apache.camel.ShutdownableService, org.apache.camel.StatefulService, org.apache.camel.SuspendableService

public class WebsocketConsumer
extends org.apache.camel.impl.DefaultConsumer
implements WebsocketProducerConsumer


Field Summary
 
Fields inherited from class org.apache.camel.impl.DefaultConsumer
log
 
Fields inherited from class org.apache.camel.support.ServiceSupport
shutdown, shuttingdown, started, starting, stopped, stopping, suspended, suspending
 
Constructor Summary
WebsocketConsumer(WebsocketEndpoint endpoint, org.apache.camel.Processor processor)
           
 
Method Summary
 WebsocketEndpoint getEndpoint()
          Gets the endpoint
 String getPath()
           
 void sendMessage(String connectionKey, String message)
           
 void start()
           
 void stop()
           
 
Methods inherited from class org.apache.camel.impl.DefaultConsumer
createUoW, doneUoW, doStart, doStop, getAsyncProcessor, getExceptionHandler, getProcessor, getRoute, handleException, handleException, setExceptionHandler, setRoute, 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, suspend
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Constructor Detail

WebsocketConsumer

public WebsocketConsumer(WebsocketEndpoint endpoint,
                         org.apache.camel.Processor processor)
Method Detail

start

public void start()
           throws Exception
Specified by:
start in interface org.apache.camel.Service
Overrides:
start in class org.apache.camel.support.ServiceSupport
Throws:
Exception

stop

public void stop()
          throws Exception
Specified by:
stop in interface org.apache.camel.Service
Overrides:
stop in class org.apache.camel.support.ServiceSupport
Throws:
Exception

getEndpoint

public WebsocketEndpoint getEndpoint()
Description copied from interface: WebsocketProducerConsumer
Gets the endpoint

Specified by:
getEndpoint in interface WebsocketProducerConsumer
Specified by:
getEndpoint in interface org.apache.camel.Consumer
Overrides:
getEndpoint in class org.apache.camel.impl.DefaultConsumer

getPath

public String getPath()

sendMessage

public void sendMessage(String connectionKey,
                        String message)


Apache Camel