Package | Description |
---|---|
org.atmosphere.cache | |
org.atmosphere.cpr |
Modifier and Type | Field and Description |
---|---|
protected List<CacheMessage> |
AbstractBroadcasterCache.messages |
Modifier and Type | Method and Description |
---|---|
CacheMessage |
UUIDBroadcasterCache.addToCache(String broadcasterId,
String uuid,
BroadcastMessage message) |
CacheMessage |
SessionBroadcasterCache.addToCache(String broadcasterId,
String uuid,
BroadcastMessage message) |
CacheMessage |
DefaultBroadcasterCache.addToCache(String broadcasterId,
String uuid,
BroadcastMessage message) |
protected CacheMessage |
AbstractBroadcasterCache.put(BroadcastMessage message,
Long now,
String uuid) |
Modifier and Type | Method and Description |
---|---|
ConcurrentLinkedQueue<CacheMessage> |
UUIDBroadcasterCache.ClientQueue.getQueue() |
Modifier and Type | Method and Description |
---|---|
BroadcasterCache |
UUIDBroadcasterCache.clearCache(String broadcasterId,
String uuid,
CacheMessage message) |
BroadcasterCache |
DefaultBroadcasterCache.clearCache(String broadcasterId,
String uuid,
CacheMessage cache) |
BroadcasterCache |
AbstractBroadcasterCache.clearCache(String broadcasterId,
String uuid,
CacheMessage cache) |
Modifier and Type | Field and Description |
---|---|
protected CacheMessage |
Deliver.cache |
Modifier and Type | Method and Description |
---|---|
CacheMessage |
BroadcasterCache.addToCache(String broadcasterId,
String uuid,
BroadcastMessage message)
Start tracking messages associated with
AtmosphereResource from the cache. |
CacheMessage |
Deliver.getCache() |
Modifier and Type | Method and Description |
---|---|
BroadcasterCache |
BroadcasterCache.clearCache(String broadcasterId,
String uuid,
CacheMessage cache)
Remove the previously cached message.
|
protected boolean |
DefaultBroadcaster.endBroadcast(Deliver deliver,
AtmosphereResource r,
CacheMessage cacheMsg,
boolean deliverMessage) |
void |
BroadcasterCacheListener.onAddCache(String broadcasterId,
CacheMessage cacheMessage)
Invoked when a message is added to the cache
|
void |
BroadcasterCacheListener.onRemoveCache(String broadcasterId,
CacheMessage cacheMessage)
Invoked when a message is removed from the cache.
|
void |
Deliver.setCache(CacheMessage cache) |
Constructor and Description |
---|
AsyncWriteToken(AtmosphereResource resource,
Object msg,
BroadcasterFuture future,
Object originalMessage,
CacheMessage cache,
AtomicInteger count) |
Deliver(AtmosphereResource r,
Deliver e,
CacheMessage cacheMessage) |
Deliver(Deliver.TYPE type,
Object originalMessage,
Object message,
AtmosphereResource r,
BroadcasterFuture<?> future,
CacheMessage cache,
boolean writeLocally,
Set<AtmosphereResource> resources,
boolean async) |
Copyright © 2016. All rights reserved.