Class WebsocketConsumer

  • All Implemented Interfaces:
    AutoCloseable, org.apache.camel.Consumer, org.apache.camel.EndpointAware, org.apache.camel.RouteAware, org.apache.camel.Service, org.apache.camel.ShutdownableService, org.apache.camel.spi.RouteIdAware, org.apache.camel.StatefulService, org.apache.camel.Suspendable, org.apache.camel.SuspendableService

    public class WebsocketConsumer
    extends org.apache.camel.component.servlet.ServletConsumer
    • Field Summary

      • Fields inherited from class org.apache.camel.http.common.HttpConsumer

        canConnected
      • Fields inherited from class org.apache.camel.support.service.BaseService

        BUILT, FAILED, INITIALIZED, INITIALIZING, lock, NEW, SHUTDOWN, SHUTTING_DOWN, STARTED, STARTING, status, STOPPED, STOPPING, SUSPENDED, SUSPENDING
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method 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)  
      • Methods inherited from class org.apache.camel.http.common.HttpConsumer

        doResume, doStart, doStop, doSuspend, getBinding, getPath, isOptionsEnabled, isSuspended, isTraceEnabled, setOptionsEnabled, setTraceEnabled
      • Methods inherited from class org.apache.camel.support.DefaultConsumer

        createUoW, doInit, doneUoW, getAsyncProcessor, getExceptionHandler, getProcessor, getRoute, getRouteId, handleException, handleException, setExceptionHandler, setRoute, setRouteId, toString
      • Methods inherited from class org.apache.camel.support.service.BaseService

        build, doBuild, doFail, doLifecycleChange, doShutdown, fail, getStatus, init, isBuild, isInit, isNew, isRunAllowed, isShutdown, isStarted, isStarting, isStartingOrStarted, isStopped, isStopping, isStoppingOrStopped, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
      • Methods inherited from interface org.apache.camel.Service

        build, close, init, start, stop
      • Methods inherited from interface org.apache.camel.ShutdownableService

        shutdown
      • Methods inherited from interface org.apache.camel.StatefulService

        getStatus, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isSuspending
      • Methods inherited from interface org.apache.camel.SuspendableService

        resume, suspend
    • Constructor Detail

      • WebsocketConsumer

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

      • configureEventsResending

        public void configureEventsResending​(boolean enableEventsResending)
      • configureFramework

        public void configureFramework​(javax.servlet.ServletConfig config)
                                throws javax.servlet.ServletException
        Throws:
        javax.servlet.ServletException
      • getEndpoint

        public WebsocketEndpoint getEndpoint()
        Specified by:
        getEndpoint in interface org.apache.camel.EndpointAware
        Overrides:
        getEndpoint in class org.apache.camel.component.servlet.ServletConsumer
      • sendMessage

        public void sendMessage​(String connectionKey,
                                Object message)
      • sendEventNotification

        public void sendEventNotification​(String connectionKey,
                                          int eventType)
      • sendNotDeliveredMessage

        public void sendNotDeliveredMessage​(List<String> failedConnectionKeys,
                                            Object message)
      • isEnableEventsResending

        public boolean isEnableEventsResending()