org.apache.camel.component.websocket
Class MemoryWebsocketStore

java.lang.Object
  java.util.AbstractMap<K,V>
      java.util.concurrent.ConcurrentHashMap<String,DefaultWebsocket>
          org.apache.camel.component.websocket.MemoryWebsocketStore

All Implemented Interfaces:

Serializable, ConcurrentMap<String,DefaultWebsocket>, Map<String,DefaultWebsocket>, WebsocketStore, org.apache.camel.Service

public class MemoryWebsocketStore
extends ConcurrentHashMap<String,DefaultWebsocket>
implements WebsocketStore

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class java.util.AbstractMap

AbstractMap.SimpleEntry<K,V>, AbstractMap.SimpleImmutableEntry<K,V>

Nested classes/interfaces inherited from interface java.util.Map

Map.Entry<K,V>

Constructor Summary

MemoryWebsocketStore()

Method Summary

void	add(DefaultWebsocket ws)
DefaultWebsocket	get(String key)
Collection<DefaultWebsocket>	getAll()
void	remove(DefaultWebsocket ws)
void	remove(String key)
void	start()
void	stop()

Methods inherited from class java.util.concurrent.ConcurrentHashMap

clear, contains, containsKey, containsValue, elements, entrySet, get, isEmpty, keys, keySet, put, putAll, putIfAbsent, remove, remove, replace, replace, size, values

Methods inherited from class java.util.AbstractMap

clone, equals, hashCode, toString

Methods inherited from class java.lang.Object

finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface java.util.Map

equals, hashCode

Constructor Detail

MemoryWebsocketStore

public MemoryWebsocketStore()

Method Detail

add

public void add(DefaultWebsocket ws)

Specified by:

add in interface WebsocketStore

remove

public void remove(DefaultWebsocket ws)

Specified by:

remove in interface WebsocketStore

remove

public void remove(String key)

Specified by:

remove in interface WebsocketStore

get

public DefaultWebsocket get(String key)

Specified by:

get in interface WebsocketStore

getAll

public Collection<DefaultWebsocket> getAll()

Specified by:

getAll in interface WebsocketStore

start

public void start()
           throws Exception

Specified by:

start in interface org.apache.camel.Service

Throws:

Exception

stop

public void stop()
          throws Exception

Specified by:

stop in interface org.apache.camel.Service

Throws:

Exception