Class MemoryWebSocketStore

java.lang.Object
org.apache.camel.component.atmosphere.websocket.MemoryWebSocketStore
All Implemented Interfaces:
AutoCloseable, WebSocketStore, org.apache.camel.Service

public class MemoryWebSocketStore extends Object implements WebSocketStore
  • Constructor Details

    • MemoryWebSocketStore

      public MemoryWebSocketStore()
  • Method Details

    • start

      public void start()
      Specified by:
      start in interface org.apache.camel.Service
    • stop

      public void stop()
      Specified by:
      stop in interface org.apache.camel.Service
    • addWebSocket

      public void addWebSocket(String connectionKey, org.atmosphere.websocket.WebSocket websocket)
      Specified by:
      addWebSocket in interface WebSocketStore
    • removeWebSocket

      public void removeWebSocket(String connectionKey)
      Specified by:
      removeWebSocket in interface WebSocketStore
    • removeWebSocket

      public void removeWebSocket(org.atmosphere.websocket.WebSocket websocket)
      Specified by:
      removeWebSocket in interface WebSocketStore
    • getConnectionKey

      public String getConnectionKey(org.atmosphere.websocket.WebSocket websocket)
      Specified by:
      getConnectionKey in interface WebSocketStore
    • getWebSocket

      public org.atmosphere.websocket.WebSocket getWebSocket(String connectionKey)
      Specified by:
      getWebSocket in interface WebSocketStore
    • getAllWebSockets

      public Collection<org.atmosphere.websocket.WebSocket> getAllWebSockets()
      Specified by:
      getAllWebSockets in interface WebSocketStore