public class MemoryWebSocketStore extends Object implements WebSocketStore
Constructor and Description |
---|
MemoryWebSocketStore() |
Modifier and Type | Method and Description |
---|---|
void |
addWebSocket(String connectionKey,
org.atmosphere.websocket.WebSocket websocket) |
Collection<org.atmosphere.websocket.WebSocket> |
getAllWebSockets() |
String |
getConnectionKey(org.atmosphere.websocket.WebSocket websocket) |
org.atmosphere.websocket.WebSocket |
getWebSocket(String connectionKey) |
void |
removeWebSocket(String connectionKey) |
void |
removeWebSocket(org.atmosphere.websocket.WebSocket websocket) |
void |
start() |
void |
stop() |
public void start() throws Exception
start
in interface org.apache.camel.Service
Exception
public void stop() throws Exception
stop
in interface org.apache.camel.Service
Exception
public void addWebSocket(String connectionKey, org.atmosphere.websocket.WebSocket websocket)
addWebSocket
in interface WebSocketStore
public void removeWebSocket(String connectionKey)
removeWebSocket
in interface WebSocketStore
public void removeWebSocket(org.atmosphere.websocket.WebSocket websocket)
removeWebSocket
in interface WebSocketStore
public String getConnectionKey(org.atmosphere.websocket.WebSocket websocket)
getConnectionKey
in interface WebSocketStore
public org.atmosphere.websocket.WebSocket getWebSocket(String connectionKey)
getWebSocket
in interface WebSocketStore
public Collection<org.atmosphere.websocket.WebSocket> getAllWebSockets()
getAllWebSockets
in interface WebSocketStore
Apache Camel