Modifier and Type | Method and Description |
---|---|
BroadcasterCache |
UUIDBroadcasterCache.excludeFromCache(String broadcasterId,
AtmosphereResource r) |
BroadcasterCache |
DefaultBroadcasterCache.excludeFromCache(String broadcasterId,
AtmosphereResource r) |
BroadcasterCache |
AbstractBroadcasterCache.excludeFromCache(String broadcasterId,
AtmosphereResource r) |
protected String |
UUIDBroadcasterCache.uuid(AtmosphereResource r) |
Modifier and Type | Method and Description |
---|---|
BroadcastFilter.BroadcastAction |
TrackMessageSizeFilter.filter(String broadcasterId,
AtmosphereResource r,
Object originalMessage,
Object message) |
Action |
TrackMessageSizeInterceptor.inspect(AtmosphereResource r) |
Modifier and Type | Method and Description |
---|---|
Action |
ServiceInterceptor.inspect(AtmosphereResource r) |
protected ManagedServiceInterceptor.ManagedAnnotation |
ManagedServiceInterceptor.managed(AnnotatedProxy ap,
AtmosphereResource r) |
void |
ManagedAtmosphereHandler.onRequest(AtmosphereResource resource) |
void |
ManagedServiceInterceptor.postInspect(AtmosphereResource r) |
protected void |
ManagedAtmosphereHandler.processReady(AtmosphereResource r) |
Modifier and Type | Interface and Description |
---|---|
interface |
AsyncSupport<E extends AtmosphereResource>
Atmosphere's supported WebServer must implement this interface in order to be auto detected by the
AtmosphereFramework . |
Modifier and Type | Class and Description |
---|---|
class |
AtmosphereResourceImpl
|
Modifier and Type | Field and Description |
---|---|
protected AtmosphereResource |
Deliver.resource |
Modifier and Type | Field and Description |
---|---|
protected AtomicReference<AtmosphereResource> |
AtmosphereSession.resource |
protected Set<AtmosphereResource> |
Deliver.resources |
protected ConcurrentLinkedQueue<AtmosphereResource> |
DefaultBroadcaster.resources |
Modifier and Type | Method and Description |
---|---|
Collection<AtmosphereResource> |
DefaultAtmosphereResourceFactory.findAll() |
Collection<AtmosphereResource> |
AtmosphereResourceFactory.findAll() |
Collection<AtmosphereResource> |
DefaultBroadcaster.getAtmosphereResources() |
Collection<AtmosphereResource> |
Broadcaster.getAtmosphereResources()
Return an
List of AtmosphereResource . |
Set<AtmosphereResource> |
Deliver.getResources() |
ConcurrentMap<String,AtmosphereResource> |
DefaultAtmosphereResourceFactory.resources() |
ConcurrentMap<String,AtmosphereResource> |
AtmosphereResourceFactory.resources() |
Modifier and Type | Method and Description |
---|---|
Broadcaster |
DefaultBroadcaster.addAtmosphereResource(AtmosphereResource r) |
Broadcaster |
Broadcaster.addAtmosphereResource(AtmosphereResource resource)
Add a
AtmosphereResource to the list of items to be notified when
the Broadcaster.broadcast(java.lang.Object) is invoked. |
List<Object> |
BroadcasterConfig.applyFilters(AtmosphereResource r,
List<Object> cacheMessages)
Apply all filters to the
AtmosphereResource and the provided List of messages. |
void |
AtmosphereResourceFactory.Async.available(AtmosphereResource r)
A stub representing an
AtmosphereResource located somewhere in a cluster |
Future<Object> |
DefaultBroadcaster.broadcast(Object msg,
AtmosphereResource r) |
Future<Object> |
Broadcaster.broadcast(Object o,
AtmosphereResource resource)
Broadcast the
Object to all suspended responses, eg. |
protected void |
DefaultBroadcaster.broadcastOnResume(AtmosphereResource r) |
protected void |
DefaultBroadcaster.cacheAndSuspend(AtmosphereResource r)
Look in the cache to see if there are messages available, and take the appropriate actions.
|
void |
DefaultBroadcaster.cacheLostMessage(AtmosphereResource r,
boolean force)
Cache the message because an unexpected exception occurred.
|
void |
DefaultBroadcaster.cacheLostMessage(AtmosphereResource r,
DefaultBroadcaster.AsyncWriteToken token)
Cache the message because an unexpected exception occurred.
|
void |
DefaultBroadcaster.cacheLostMessage(AtmosphereResource r,
DefaultBroadcaster.AsyncWriteToken token,
boolean force)
Cache the message because an unexpected exception occurred.
|
protected boolean |
DefaultBroadcaster.checkCachedAndPush(AtmosphereResource r,
AtmosphereResourceEvent e) |
AtmosphereResourceImpl |
AtmosphereResourceImpl.cloneState(AtmosphereResource r) |
boolean |
AsynchronousProcessor.completeLifecycle(AtmosphereResource r,
boolean cancelled)
Cancel or times out an
AtmosphereResource by invoking it's associated AtmosphereHandler.onStateChange(AtmosphereResourceEvent) |
protected boolean |
DefaultBroadcaster.endBroadcast(Deliver deliver,
AtmosphereResource r,
CacheMessage cacheMsg,
boolean deliverMessage) |
BroadcasterCache |
BroadcasterCache.excludeFromCache(String broadcasterId,
AtmosphereResource r)
Allow an application to exclude, or block, an
AtmosphereResource to received cached message. |
protected void |
DefaultBroadcaster.executeBlockingWrite(AtmosphereResource r,
Deliver deliver,
AtomicInteger count) |
protected BroadcastFilter.BroadcastAction |
BroadcasterConfig.filter(AtmosphereResource r,
Object message,
Object originalMessage)
Invoke
BroadcastFilter s in the order they were added, with a unique AtmosphereRequest . |
BroadcastFilter.BroadcastAction |
PerRequestBroadcastFilter.filter(String broadcasterId,
AtmosphereResource r,
Object originalMessage,
Object message)
Transform or filter a message per
AtmosphereResource . |
BroadcastFilter.BroadcastAction |
BroadcastFilterAdapter.filter(String broadcasterId,
AtmosphereResource r,
Object originalMessage,
Object message) |
AtmosphereResourceSession |
DefaultAtmosphereResourceSessionFactory.getSession(AtmosphereResource resource) |
AtmosphereResourceSession |
AtmosphereResourceSessionFactory.getSession(AtmosphereResource resource)
Returns the current session associated with the
AtmosphereResource , or creates one if it does not yet exist. |
AtmosphereResourceSession |
DefaultAtmosphereResourceSessionFactory.getSession(AtmosphereResource r,
boolean create) |
AtmosphereResourceSession |
AtmosphereResourceSessionFactory.getSession(AtmosphereResource resource,
boolean create)
Returns the current session associated with the
AtmosphereResource or, if there is no current session and create
is true, returns a new session. |
Action |
AtmosphereInterceptorAdapter.inspect(AtmosphereResource r) |
Action |
AtmosphereInterceptor.inspect(AtmosphereResource r)
Invoked before an
AtmosphereResource gets dispatched to AtmosphereHandler . |
Action |
AsynchronousProcessor.invokeInterceptors(List<AtmosphereInterceptor> c,
AtmosphereResource r,
int tracing) |
protected void |
DefaultBroadcaster.invokeOnStateChange(AtmosphereResource r,
AtmosphereResourceEvent e) |
protected void |
DefaultBroadcaster.notifyAndAdd(AtmosphereResource r) |
protected void |
DefaultBroadcaster.notifyOnAddAtmosphereResourceListener(AtmosphereResource r) |
protected void |
DefaultBroadcaster.notifyOnRemoveAtmosphereResourceListener(AtmosphereResource r) |
void |
BroadcasterListenerAdapter.onAddAtmosphereResource(Broadcaster b,
AtmosphereResource r)
Invoked when an
AtmosphereResource is getting associated to a Broadcaster . |
void |
BroadcasterListener.onAddAtmosphereResource(Broadcaster b,
AtmosphereResource r)
Invoked when an
AtmosphereResource is getting associated to a Broadcaster . |
void |
DefaultBroadcaster.onException(Throwable t,
AtmosphereResource ar) |
void |
DefaultBroadcaster.onException(Throwable t,
AtmosphereResource ar,
boolean notifyAndCache) |
void |
BroadcasterListenerAdapter.onRemoveAtmosphereResource(Broadcaster b,
AtmosphereResource r)
Invoked when an
AtmosphereResource is getting removed to a Broadcaster . |
void |
BroadcasterListener.onRemoveAtmosphereResource(Broadcaster b,
AtmosphereResource r)
Invoked when an
AtmosphereResource is getting removed to a Broadcaster . |
void |
AtmosphereHandler.onRequest(AtmosphereResource resource)
When a client sends a request to its associated
AtmosphereHandler , it can decide if the underlying
connection can be suspended (creating a Continuation) or handle the connection synchronously. |
protected boolean |
DefaultBroadcaster.perRequestFilter(AtmosphereResource r,
Deliver msg) |
void |
AtmosphereInterceptorAdapter.postInspect(AtmosphereResource r) |
void |
AtmosphereInterceptor.postInspect(AtmosphereResource r)
Invoked after an
AtmosphereResource gets dispatched to AtmosphereHandler . |
void |
AsynchronousProcessor.postInterceptors(List<AtmosphereInterceptor> c,
AtmosphereResource r) |
protected void |
DefaultBroadcaster.prepareInvokeOnStateChange(AtmosphereResource r,
AtmosphereResourceEvent e) |
protected void |
DefaultBroadcaster.queueWriteIO(AtmosphereResource r,
Deliver deliver,
AtomicInteger count) |
void |
DefaultAtmosphereResourceFactory.registerUuidForFindCandidate(AtmosphereResource r)
Register an
AtmosphereResource for being a candidate to DefaultAtmosphereResourceFactory.find(String) operation. |
void |
AtmosphereResourceFactory.registerUuidForFindCandidate(AtmosphereResource r)
Register an
AtmosphereResource for being a candidate to AtmosphereResourceFactory.find(String) operation. |
void |
DefaultBroadcasterFactory.removeAllAtmosphereResource(AtmosphereResource r)
Deprecated.
|
void |
BroadcasterFactory.removeAllAtmosphereResource(AtmosphereResource r)
Deprecated.
|
Broadcaster |
DefaultBroadcaster.removeAtmosphereResource(AtmosphereResource r) |
Broadcaster |
Broadcaster.removeAtmosphereResource(AtmosphereResource resource)
Remove a
AtmosphereResource from the list of s to be notified when
the Broadcaster.broadcast(java.lang.Object) is invoked. |
protected Broadcaster |
DefaultBroadcaster.removeAtmosphereResource(AtmosphereResource r,
boolean executeDone) |
protected boolean |
DefaultBroadcaster.retrieveTrackedBroadcast(AtmosphereResource r,
AtmosphereResourceEvent e) |
void |
DefaultAtmosphereResourceFactory.unRegisterUuidForFindCandidate(AtmosphereResource r)
Un register an
AtmosphereResource for being a candidate to DefaultAtmosphereResourceFactory.find(String) operation. |
void |
AtmosphereResourceFactory.unRegisterUuidForFindCandidate(AtmosphereResource r)
Un register an
AtmosphereResource for being a candidate to AtmosphereResourceFactory.find(String) operation. |
Modifier and Type | Method and Description |
---|---|
Future<Object> |
DefaultBroadcaster.broadcast(Object msg,
Set<AtmosphereResource> subset) |
Future<Object> |
Broadcaster.broadcast(Object o,
Set<AtmosphereResource> subset)
Broadcast the
Object to all suspended response, eg. |
Constructor and Description |
---|
AsyncWriteToken(AtmosphereResource resource,
Object msg,
BroadcasterFuture future,
Object originalMessage,
AtomicInteger count) |
AsyncWriteToken(AtmosphereResource resource,
Object msg,
BroadcasterFuture future,
Object originalMessage,
CacheMessage cache,
AtomicInteger count) |
AtmosphereSession(AtmosphereResource resource)
Track the current
AtmosphereResource with all created Broadcaster |
AtmosphereSession(AtmosphereResource r,
Broadcaster... broadcasters) |
Deliver(AtmosphereResource r,
Deliver e) |
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) |
Deliver(Object message,
AtmosphereResource r,
BroadcasterFuture<?> future,
Object originalMessage) |
Constructor and Description |
---|
Deliver(Deliver.TYPE type,
Object originalMessage,
Object message,
AtmosphereResource r,
BroadcasterFuture<?> future,
CacheMessage cache,
boolean writeLocally,
Set<AtmosphereResource> resources,
boolean async) |
Deliver(Object message,
Set<AtmosphereResource> resources,
BroadcasterFuture<?> future,
Object originalMessage) |
Modifier and Type | Method and Description |
---|---|
void |
OnMessage.onOpen(AtmosphereResource resource)
This method will be invoked when an connection has been received and not haven't yet be suspended.
|
void |
ReflectorServletProcessor.onRequest(AtmosphereResource r)
Delegate the request to the Servlet.service method, and add the
AtmosphereResource
to the HttpServletRequest#setAttribute(java.lang.String, java.lang.Object)) . |
void |
OnMessage.onRequest(AtmosphereResource resource) |
void |
AtmosphereHandlerAdapter.onRequest(AtmosphereResource resource) |
void |
AbstractReflectorAtmosphereHandler.Default.onRequest(AtmosphereResource resource)
When a client sends a request to its associated
AtmosphereHandler , it can decide if the underlying
connection can be suspended (creating a Continuation) or handle the connection synchronously. |
Modifier and Type | Method and Description |
---|---|
AtmosphereResource |
AtmosphereResourceIntrospector.injectable(AtmosphereResource r) |
Modifier and Type | Method and Description |
---|---|
String |
PathParamIntrospector.injectable(AtmosphereResource r) |
Object |
InjectIntrospectorAdapter.injectable(AtmosphereResource resource) |
T |
InjectIntrospector.injectable(AtmosphereResource resource)
Returns an instance of the T
|
Broadcaster |
BroadcasterIntrospector.injectable(AtmosphereResource r) |
AtmosphereResponse |
AtmosphereResponseIntrospector.injectable(AtmosphereResource r) |
AtmosphereResource |
AtmosphereResourceIntrospector.injectable(AtmosphereResource r) |
AtmosphereResourceEvent |
AtmosphereResourceEventIntrospector.injectable(AtmosphereResource r) |
AtmosphereRequest |
AtmosphereRequestIntrospector.injectable(AtmosphereResource r) |
void |
InjectableObjectFactory.requestScoped(Object instance,
Class defaultType,
AtmosphereResource r) |
Modifier and Type | Method and Description |
---|---|
HeartbeatInterceptor |
HeartbeatInterceptor.clock(int interval,
AtmosphereResource r,
AtmosphereRequest request,
AtmosphereResponse response)
Configures the heartbeat sent by the server in an interval in seconds specified in parameter for the given
resource.
|
Action |
WebSocketMessageSuspendInterceptor.inspect(AtmosphereResource r) |
Action |
TrackMessageSizeB64Interceptor.inspect(AtmosphereResource r) |
Action |
SuspendTrackerInterceptor.inspect(AtmosphereResource r) |
Action |
SimpleRestInterceptor.inspect(AtmosphereResource r) |
Action |
ShiroInterceptor.inspect(AtmosphereResource r) |
Action |
SessionCreationInterceptor.inspect(AtmosphereResource r) |
Action |
SSEAtmosphereInterceptor.inspect(AtmosphereResource r) |
Action |
PaddingAtmosphereInterceptor.inspect(AtmosphereResource r) |
Action |
OnDisconnectInterceptor.inspect(AtmosphereResource r) |
Action |
NginxInterceptor.inspect(AtmosphereResource r) |
Action |
JavaScriptProtocol.inspect(AtmosphereResource ar) |
Action |
JSONPAtmosphereInterceptor.inspect(AtmosphereResource r) |
Action |
IdleResourceInterceptor.inspect(AtmosphereResource r) |
Action |
HeartbeatInterceptor.inspect(AtmosphereResource r) |
Action |
CorsInterceptor.inspect(AtmosphereResource r) |
Action |
CacheHeadersInterceptor.inspect(AtmosphereResource r) |
Action |
BroadcastOnPostAtmosphereInterceptor.inspect(AtmosphereResource r) |
Action |
AtmosphereResourceStateRecovery.inspect(AtmosphereResource r) |
Action |
AtmosphereResourceLifecycleInterceptor.inspect(AtmosphereResource r)
Automatically suspend the
AtmosphereResource based on AtmosphereResource.TRANSPORT value. |
Action |
AndroidAtmosphereInterceptor.inspect(AtmosphereResource r) |
void |
AtmosphereResourceStateRecovery.B.onAddAtmosphereResource(Broadcaster b,
AtmosphereResource r) |
void |
AtmosphereResourceStateRecovery.B.onRemoveAtmosphereResource(Broadcaster b,
AtmosphereResource r) |
void |
BroadcastOnPostAtmosphereInterceptor.postInspect(AtmosphereResource r) |
void |
AtmosphereResourceStateRecovery.postInspect(AtmosphereResource r) |
void |
AtmosphereResourceLifecycleInterceptor.postInspect(AtmosphereResource r) |
List<Object> |
AtmosphereResourceStateRecovery.retrieveCache(AtmosphereResource r,
AtmosphereResourceStateRecovery.BroadcasterTracker tracker,
boolean force) |
Modifier and Type | Method and Description |
---|---|
protected AtmosphereResource |
BaseInjectableProvider.getAtmosphereResource(Class injectType,
boolean session) |
Modifier and Type | Method and Description |
---|---|
protected void |
JerseyBroadcaster.invokeOnStateChange(AtmosphereResource r,
AtmosphereResourceEvent e) |
Modifier and Type | Method and Description |
---|---|
static void |
JerseyBroadcasterUtil.broadcast(AtmosphereResource r,
AtmosphereResourceEvent e,
Broadcaster broadcaster) |
protected void |
JerseySimpleBroadcaster.invokeOnStateChange(AtmosphereResource r,
AtmosphereResourceEvent e) |
static boolean |
JerseyBroadcasterUtil.isJetty(AtmosphereResource r) |
Modifier and Type | Method and Description |
---|---|
void |
BroadcasterLifecyclePolicyHandler.onRemoveAtmosphereResource(Broadcaster b,
AtmosphereResource r)
Invoked when an
AtmosphereResource is getting removed to a Broadcaster . |
Modifier and Type | Method and Description |
---|---|
void |
PoolableBroadcasterFactory.removeAllAtmosphereResource(AtmosphereResource r) |
Modifier and Type | Method and Description |
---|---|
static AtmosphereResource |
Utils.websocketResource(AtmosphereResource r) |
Modifier and Type | Method and Description |
---|---|
Future<Object> |
SimpleBroadcaster.broadcast(Object msg,
AtmosphereResource r) |
Future<Object> |
ExcludeSessionBroadcaster.broadcast(Object msg,
AtmosphereResource r)
the AtmosphereResource r will be exclude for this broadcast
|
Future<Object> |
AbstractBroadcasterProxy.broadcast(Object msg,
AtmosphereResource r) |
static void |
IOUtils.deliver(Object o,
DeliverTo deliverConfig,
DeliverTo.DELIVER_TO defaultDeliver,
AtmosphereResource r)
Delivers the given message according to the specified {@link org.atmosphere.config.service.DeliverTo configuration).
|
static void |
Utils.inject(AtmosphereResource r) |
static void |
Utils.inject(Object object,
Class clazz,
AtmosphereResource r) |
protected void |
AbstractBroadcasterProxy.invokeOnStateChange(AtmosphereResource r,
AtmosphereResourceEvent e) |
protected void |
SimpleBroadcaster.prepareInvokeOnStateChange(AtmosphereResource r,
AtmosphereResourceEvent e) |
protected void |
SimpleBroadcaster.queueWriteIO(AtmosphereResource r,
Deliver deliver,
AtomicInteger count) |
static Object |
IOUtils.readEntirely(AtmosphereResource r) |
static byte[] |
IOUtils.readEntirelyAsByte(AtmosphereResource r) |
static StringBuilder |
IOUtils.readEntirelyAsString(AtmosphereResource r) |
static boolean |
Utils.webSocketMessage(AtmosphereResource r) |
static AtmosphereResource |
Utils.websocketResource(AtmosphereResource r) |
Modifier and Type | Method and Description |
---|---|
Future<Object> |
SimpleBroadcaster.broadcast(Object msg,
Set<AtmosphereResource> subset) |
Future<Object> |
ExcludeSessionBroadcaster.broadcast(Object msg,
Set<AtmosphereResource> subset)
the AtmosphereResources subset will be exclude for this broadcast
|
Future<Object> |
AbstractBroadcasterProxy.broadcast(Object msg,
Set<AtmosphereResource> subset) |
Modifier and Type | Method and Description |
---|---|
AtmosphereResource |
WebSocket.resource()
Return the an
AtmosphereResource used by this WebSocket, or null if the WebSocket has been closed
before the WebSocket message has been processed. |
Modifier and Type | Method and Description |
---|---|
WebSocket |
WebSocket.resource(AtmosphereResource r)
Associate an
AtmosphereResource to this WebSocket |
Copyright © 2016. All rights reserved.