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.ServiceExceptionpublic void stop()
throws Exception
stop in interface org.apache.camel.ServiceExceptionpublic void addWebSocket(String connectionKey, org.atmosphere.websocket.WebSocket websocket)
addWebSocket in interface WebSocketStorepublic void removeWebSocket(String connectionKey)
removeWebSocket in interface WebSocketStorepublic void removeWebSocket(org.atmosphere.websocket.WebSocket websocket)
removeWebSocket in interface WebSocketStorepublic String getConnectionKey(org.atmosphere.websocket.WebSocket websocket)
getConnectionKey in interface WebSocketStorepublic org.atmosphere.websocket.WebSocket getWebSocket(String connectionKey)
getWebSocket in interface WebSocketStorepublic Collection<org.atmosphere.websocket.WebSocket> getAllWebSockets()
getAllWebSockets in interface WebSocketStoreApache Camel