public class WebsocketProducer extends org.apache.camel.impl.DefaultProducer implements WebsocketProducerConsumer
Constructor and Description |
---|
WebsocketProducer(WebsocketEndpoint endpoint) |
Modifier and Type | Method and Description |
---|---|
void |
doStart() |
void |
doStop() |
WebsocketEndpoint |
getEndpoint()
Gets the endpoint
|
protected void |
handleSleepInterruptedException(InterruptedException e,
org.apache.camel.Exchange exchange)
Called when a sleep is interrupted; allows derived classes to handle this case differently
|
void |
process(org.apache.camel.Exchange exchange) |
void |
setStore(WebsocketStore store) |
createExchange, createExchange, createExchange, isSingleton, toString
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
public WebsocketProducer(WebsocketEndpoint endpoint)
public void process(org.apache.camel.Exchange exchange) throws Exception
process
in interface org.apache.camel.Processor
Exception
public WebsocketEndpoint getEndpoint()
WebsocketProducerConsumer
getEndpoint
in interface WebsocketProducerConsumer
getEndpoint
in interface org.apache.camel.EndpointAware
getEndpoint
in class org.apache.camel.impl.DefaultProducer
public void doStart() throws Exception
doStart
in class org.apache.camel.impl.DefaultProducer
Exception
public void doStop() throws Exception
doStop
in class org.apache.camel.impl.DefaultProducer
Exception
public void setStore(WebsocketStore store)
protected void handleSleepInterruptedException(InterruptedException e, org.apache.camel.Exchange exchange) throws InterruptedException
InterruptedException
Apache Camel