public class WebsocketConsumer
extends org.apache.camel.component.servlet.ServletConsumer
| Constructor and Description |
|---|
WebsocketConsumer(WebsocketEndpoint endpoint,
org.apache.camel.Processor processor) |
| Modifier and Type | Method and Description |
|---|---|
void |
configureEventsResending(boolean enableEventsResending) |
void |
configureFramework(javax.servlet.ServletConfig config) |
WebsocketEndpoint |
getEndpoint() |
boolean |
isEnableEventsResending() |
void |
sendEventNotification(String connectionKey,
int eventType) |
void |
sendMessage(String connectionKey,
Object message) |
void |
sendNotDeliveredMessage(List<String> failedConnectionKeys,
Object message) |
doResume, doStart, doStop, doSuspend, getBinding, getPath, isOptionsEnabled, isSuspended, isTraceEnabled, setOptionsEnabled, setTraceEnabledcreateUoW, doneUoW, getAsyncProcessor, getExceptionHandler, getProcessor, getRoute, handleException, handleException, setExceptionHandler, setRoute, toStringdoShutdown, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspendpublic WebsocketConsumer(WebsocketEndpoint endpoint, org.apache.camel.Processor processor)
public void configureEventsResending(boolean enableEventsResending)
public void configureFramework(javax.servlet.ServletConfig config)
throws javax.servlet.ServletException
javax.servlet.ServletExceptionpublic WebsocketEndpoint getEndpoint()
getEndpoint in interface org.apache.camel.EndpointAwaregetEndpoint in class org.apache.camel.component.servlet.ServletConsumerpublic void sendEventNotification(String connectionKey, int eventType)
public void sendNotDeliveredMessage(List<String> failedConnectionKeys, Object message)
public boolean isEnableEventsResending()
Apache Camel