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, setTraceEnabled
createUoW, doneUoW, getAsyncProcessor, getExceptionHandler, getProcessor, getRoute, handleException, handleException, setExceptionHandler, setRoute, toString
doShutdown, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
public 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.ServletException
public WebsocketEndpoint getEndpoint()
getEndpoint
in interface org.apache.camel.EndpointAware
getEndpoint
in class org.apache.camel.component.servlet.ServletConsumer
public void sendEventNotification(String connectionKey, int eventType)
public void sendNotDeliveredMessage(List<String> failedConnectionKeys, Object message)
public boolean isEnableEventsResending()
Apache Camel