Modifier and Type | Method and Description |
---|---|
static Broadcaster |
AnnotationUtil.broadcaster(AtmosphereFramework framework,
Class<? extends Broadcaster> broadcaster,
String path) |
Modifier and Type | Method and Description |
---|---|
static Class<? extends Broadcaster> |
AnnotationUtil.broadcasterClass(AtmosphereFramework framework,
Class<? extends Broadcaster> broadcaster) |
Modifier and Type | Method and Description |
---|---|
static Broadcaster |
AnnotationUtil.broadcaster(AtmosphereFramework framework,
Class<? extends Broadcaster> broadcaster,
String path) |
static Class<? extends Broadcaster> |
AnnotationUtil.broadcasterClass(AtmosphereFramework framework,
Class<? extends Broadcaster> broadcaster) |
void |
BroadcasterServiceProcessor.handle(AtmosphereFramework framework,
Class<Broadcaster> annotatedClass) |
Modifier and Type | Method and Description |
---|---|
Class<? extends Broadcaster> |
ManagedServiceInterceptor.ManagedAnnotation.broadcaster() |
Modifier and Type | Class and Description |
---|---|
class |
DefaultBroadcaster
The default
Broadcaster implementation. |
Modifier and Type | Field and Description |
---|---|
protected Broadcaster |
AtmosphereResourceImpl.broadcaster |
Broadcaster |
AtmosphereFramework.AtmosphereHandlerWrapper.broadcaster |
protected Broadcaster[] |
AtmosphereSession.relatedBroadcasters |
Modifier and Type | Field and Description |
---|---|
protected List<Broadcaster> |
AtmosphereResourceImpl.broadcasters |
protected Class<? extends Broadcaster> |
DefaultBroadcasterFactory.clazz |
protected ConcurrentHashMap<Object,Broadcaster> |
DefaultBroadcasterFactory.store |
Modifier and Type | Method and Description |
---|---|
protected <T extends Broadcaster> |
DefaultBroadcasterFactory.createBroadcaster(Class<T> c,
Object id) |
<T extends Broadcaster> |
DefaultBroadcasterFactory.get(Class<T> c,
Object id) |
<T extends Broadcaster> |
BroadcasterFactory.get(Class<T> c,
Object id)
Create a new instance of
Broadcaster and store it for. |
<T extends Broadcaster> |
DefaultBroadcasterFactory.lookup(Class<T> c,
Object id) |
<T extends Broadcaster> |
BroadcasterFactory.lookup(Class<T> c,
Object id)
Lookup a
Broadcaster instance using getID() or ID |
<T extends Broadcaster> |
DefaultBroadcasterFactory.lookup(Class<T> c,
Object id,
boolean createIfNull) |
<T extends Broadcaster> |
BroadcasterFactory.lookup(Class<T> c,
Object id,
boolean createIfNull)
Lookup a
Broadcaster instance using getID() or ID |
<T extends Broadcaster> |
DefaultBroadcasterFactory.lookup(Class<T> c,
Object id,
boolean createIfNull,
boolean unique) |
<T extends Broadcaster> |
BroadcasterFactory.lookup(Object id)
Lookup a
Broadcaster instance using getID() or ID |
<T extends Broadcaster> |
BroadcasterFactory.lookup(Object id,
boolean createIfNull)
Lookup a
Broadcaster instance using getID() or ID |
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 broadcast(java.lang.Object) is invoked. |
Broadcaster |
DefaultBroadcaster.addBroadcasterListener(BroadcasterListener b) |
Broadcaster |
Broadcaster.addBroadcasterListener(BroadcasterListener b)
Add a
BroadcasterListener . |
Broadcaster |
AtmosphereResourceEventImpl.broadcaster() |
Broadcaster |
AtmosphereResourceEvent.broadcaster()
Return the broadcaster associated with the
AtmosphereResource this object contains. |
Broadcaster |
DefaultBroadcasterFactory.get() |
Broadcaster |
BroadcasterFactory.get()
Return an instance of the default
Broadcaster . |
Broadcaster |
DefaultBroadcasterFactory.get(Object id) |
Broadcaster |
BroadcasterFactory.get(Object id)
Create a new instance of
Broadcaster and store it for. |
Broadcaster |
Meteor.getBroadcaster()
Return the underlying
Broadcaster . |
Broadcaster |
ClusterBroadcastFilter.getBroadcaster()
Return the
Broadcaster . |
Broadcaster |
AtmosphereResourceImpl.getBroadcaster() |
Broadcaster |
AtmosphereResource.getBroadcaster()
Return the first added
Broadcaster . |
protected Broadcaster |
AtmosphereResourceImpl.getBroadcaster(boolean autoCreate) |
Broadcaster |
DefaultBroadcaster.initialize(String name,
AtmosphereConfig config) |
Broadcaster |
DefaultBroadcaster.initialize(String name,
URI uri,
AtmosphereConfig config) |
Broadcaster |
Broadcaster.initialize(String name,
URI uri,
AtmosphereConfig config)
Configure a Broadcaster.
|
Broadcaster |
DefaultBroadcasterFactory.lookup(Object id) |
Broadcaster |
DefaultBroadcasterFactory.lookup(Object id,
boolean createIfNull) |
Broadcaster |
DefaultBroadcaster.removeAtmosphereResource(AtmosphereResource r) |
Broadcaster |
Broadcaster.removeAtmosphereResource(AtmosphereResource resource)
Remove a
AtmosphereResource from the list of s to be notified when
the broadcast(java.lang.Object) is invoked. |
protected Broadcaster |
DefaultBroadcaster.removeAtmosphereResource(AtmosphereResource r,
boolean executeDone) |
Broadcaster |
DefaultBroadcaster.removeBroadcasterListener(BroadcasterListener b) |
Broadcaster |
Broadcaster.removeBroadcasterListener(BroadcasterListener b)
Remove a
BroadcasterListener . |
Broadcaster |
DefaultBroadcaster.rename(String id)
Rename this Broadcaster without invoking it's associated
BroadcasterFactory . |
Modifier and Type | Method and Description |
---|---|
List<Broadcaster> |
AtmosphereResourceImpl.broadcasters() |
List<Broadcaster> |
AtmosphereResource.broadcasters()
Return an unmodifiable list of
Broadcaster s associated with this resource |
Set<Broadcaster> |
DefaultAtmosphereResourceFactory.broadcasters(String uuid)
Deprecated.
Use
AtmosphereResourceFactory.find(String) .broadcasters() instead |
Set<Broadcaster> |
AtmosphereResourceFactory.broadcasters(String uuid)
Deprecated.
Use
AtmosphereResourceFactory.find(String) .broadcasters() instead |
Future<List<Broadcaster>> |
MetaBroadcaster.broadcastTo(String broadcasterID,
Object message)
Broadcast the message to all Broadcasters whose
getID() matches the broadcasterID value. |
Future<List<Broadcaster>> |
DefaultMetaBroadcaster.broadcastTo(String broadcasterID,
Object message) |
Future<List<Broadcaster>> |
MetaBroadcaster.broadcastTo(String broadcasterID,
Object message,
boolean cacheMessage)
Broadcast the message to all Broadcasters whose
getID() matches the broadcasterID value. |
Future<List<Broadcaster>> |
DefaultMetaBroadcaster.broadcastTo(String broadcasterID,
Object message,
boolean cacheMessage) |
Future<List<Broadcaster>> |
MetaBroadcaster.delayTo(String broadcasterID,
Object message,
int time,
TimeUnit unit)
Delay the message delivery to Broadcasters whose
getID()
matches the broadcasterID value. |
Future<List<Broadcaster>> |
DefaultMetaBroadcaster.delayTo(String broadcasterID,
Object message,
int time,
TimeUnit unit) |
Collection<Broadcaster> |
DefaultBroadcasterFactory.lookupAll() |
Collection<Broadcaster> |
BroadcasterFactory.lookupAll()
Return an immutable Collection of
Broadcaster this factory contains. |
Future<List<Broadcaster>> |
MetaBroadcaster.scheduleTo(String broadcasterID,
Object message,
int time,
TimeUnit unit)
Broadcast the message at a fixed rate to all Broadcasters whose
getID()
matches the broadcasterID value. |
Future<List<Broadcaster>> |
DefaultMetaBroadcaster.scheduleTo(String broadcasterID,
Object message,
int time,
TimeUnit unit) |
Modifier and Type | Method and Description |
---|---|
boolean |
DefaultBroadcasterFactory.add(Broadcaster b,
Object id) |
boolean |
BroadcasterFactory.add(Broadcaster b,
Object id)
Add a
Broadcaster to the list. |
AtmosphereFramework |
AtmosphereFramework.addAtmosphereHandler(String mapping,
AtmosphereHandler h,
Broadcaster broadcaster)
Add an
AtmosphereHandler serviced by the Servlet . |
AtmosphereFramework |
AtmosphereFramework.addAtmosphereHandler(String mapping,
AtmosphereHandler h,
Broadcaster broadcaster,
List<AtmosphereInterceptor> l)
Add an
AtmosphereHandler serviced by the Servlet . |
AtmosphereResource |
AtmosphereResourceImpl.addBroadcaster(Broadcaster broadcaster) |
AtmosphereResource |
AtmosphereResource.addBroadcaster(Broadcaster broadcaster)
Add/Associate a
Broadcaster with this resource. |
AtmosphereResource |
DefaultAtmosphereResourceFactory.create(AtmosphereConfig config,
Broadcaster broadcaster,
AtmosphereRequest request,
AtmosphereResponse response,
AsyncSupport<?> a,
AtmosphereHandler handler)
Create an
AtmosphereResourceImpl . |
AtmosphereResource |
AtmosphereResourceFactory.create(AtmosphereConfig config,
Broadcaster broadcaster,
AtmosphereRequest request,
AtmosphereResponse response,
AsyncSupport<?> a,
AtmosphereHandler handler)
Create an
AtmosphereResourceImpl . |
AtmosphereResource |
DefaultAtmosphereResourceFactory.create(AtmosphereConfig config,
Broadcaster broadcaster,
AtmosphereRequest request,
AtmosphereResponse response,
AsyncSupport<?> a,
AtmosphereHandler handler,
AtmosphereResource.TRANSPORT t)
Create an
AtmosphereResourceImpl . |
AtmosphereResource |
AtmosphereResourceFactory.create(AtmosphereConfig config,
Broadcaster broadcaster,
AtmosphereRequest request,
AtmosphereResponse response,
AsyncSupport<?> a,
AtmosphereHandler handler,
AtmosphereResource.TRANSPORT t)
Create an
AtmosphereResourceImpl . |
AtmosphereResource |
DefaultAtmosphereResourceFactory.create(AtmosphereConfig config,
Broadcaster broadcaster,
AtmosphereResponse response,
AsyncSupport<?> a,
AtmosphereHandler handler)
Create an
AtmosphereResourceImpl . |
AtmosphereResource |
AtmosphereResourceFactory.create(AtmosphereConfig config,
Broadcaster broadcaster,
AtmosphereResponse response,
AsyncSupport<?> a,
AtmosphereHandler handler)
Create an
AtmosphereResourceImpl . |
AtmosphereResource |
DefaultAtmosphereResourceFactory.create(AtmosphereConfig config,
Broadcaster broadcaster,
AtmosphereResponse response,
AsyncSupport<?> a,
AtmosphereHandler handler,
AtmosphereResource.TRANSPORT t) |
AtmosphereResource |
AtmosphereResourceFactory.create(AtmosphereConfig config,
Broadcaster broadcaster,
AtmosphereResponse response,
AsyncSupport<?> a,
AtmosphereHandler handler,
AtmosphereResource.TRANSPORT t) |
AtmosphereResource |
AtmosphereResourceImpl.initialize(AtmosphereConfig config,
Broadcaster broadcaster,
AtmosphereRequest req,
AtmosphereResponse response,
AsyncSupport asyncSupport,
AtmosphereHandler atmosphereHandler)
Initialize an
AtmosphereResource . |
AtmosphereResource |
AtmosphereResource.initialize(AtmosphereConfig config,
Broadcaster broadcaster,
AtmosphereRequest req,
AtmosphereResponse response,
AsyncSupport asyncSupport,
AtmosphereHandler atmosphereHandler)
Initialize an
AtmosphereResource . |
void |
DefaultBroadcasterFactory.notifyOnPostCreate(Broadcaster b) |
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 |
BroadcasterListenerAdapter.onComplete(Broadcaster b)
Invoked when the Broadcast operation completes for all
AtmosphereResource . |
void |
BroadcasterListener.onComplete(Broadcaster b)
Invoked when the Broadcast operation completes for all
AtmosphereResource . |
void |
BroadcasterListenerAdapter.onMessage(Broadcaster b,
Deliver deliver)
Invoked when a
broadcast(Object) is called. |
void |
BroadcasterListener.onMessage(Broadcaster b,
Deliver deliver)
Invoked when a
broadcast(Object) is called. |
void |
BroadcasterListenerAdapter.onPostCreate(Broadcaster b)
Invoked just after the
Broadcaster has been created. |
void |
BroadcasterListener.onPostCreate(Broadcaster b)
Invoked just after the
Broadcaster has been created. |
void |
BroadcasterListenerAdapter.onPreDestroy(Broadcaster b)
Invoked before a Broadcaster is about to be deleted.
|
void |
BroadcasterListener.onPreDestroy(Broadcaster b)
Invoked before a Broadcaster is about to be deleted.
|
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 . |
boolean |
DefaultBroadcasterFactory.remove(Broadcaster b,
Object id) |
boolean |
BroadcasterFactory.remove(Broadcaster b,
Object id)
Remove a
Broadcaster from the list. |
AtmosphereResource |
AtmosphereResourceImpl.removeBroadcaster(Broadcaster broadcaster) |
AtmosphereResource |
AtmosphereResource.removeBroadcaster(Broadcaster broadcaster)
Remove a
Broadcaster with this resource. |
void |
Meteor.setBroadcaster(Broadcaster b)
Set a
Broadcaster instance. |
void |
ClusterBroadcastFilter.setBroadcaster(Broadcaster bc)
The
Broadcaster to use. |
AtmosphereResource |
AtmosphereResourceImpl.setBroadcaster(Broadcaster broadcaster) |
AtmosphereResource |
AtmosphereResource.setBroadcaster(Broadcaster broadcaster)
Set the first
Broadcaster associated with this resource. |
protected AtmosphereResource |
AtmosphereResourceImpl.uniqueBroadcaster(Broadcaster newB) |
Modifier and Type | Method and Description |
---|---|
void |
DefaultBroadcasterFactory.configure(Class<? extends Broadcaster> clazz,
String broadcasterLifeCyclePolicy,
AtmosphereConfig c) |
void |
BroadcasterFactory.configure(Class<? extends Broadcaster> clazz,
String broadcasterLifeCyclePolicy,
AtmosphereConfig c)
Configure the factory
|
Constructor and Description |
---|
AtmosphereHandlerWrapper(AtmosphereHandler atmosphereHandler,
Broadcaster broadcaster,
AtmosphereConfig config) |
AtmosphereResourceImpl(AtmosphereConfig config,
Broadcaster broadcaster,
AtmosphereRequest req,
AtmosphereResponse response,
AsyncSupport asyncSupport,
AtmosphereHandler atmosphereHandler)
Deprecated.
|
AtmosphereSession(AtmosphereResource r,
Broadcaster... broadcasters) |
Constructor and Description |
---|
DefaultBroadcasterFactory(Class<? extends Broadcaster> clazz,
String broadcasterLifeCyclePolicy,
AtmosphereConfig c)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
Broadcaster |
BroadcasterIntrospector.injectable(AtmosphereResource r) |
Modifier and Type | Method and Description |
---|---|
AtmosphereResourceStateRecovery.BroadcasterTracker |
AtmosphereResourceStateRecovery.BroadcasterTracker.add(Broadcaster b) |
void |
AtmosphereResourceStateRecovery.B.onAddAtmosphereResource(Broadcaster b,
AtmosphereResource r) |
void |
AtmosphereResourceStateRecovery.B.onRemoveAtmosphereResource(Broadcaster b,
AtmosphereResource r) |
AtmosphereResourceStateRecovery.BroadcasterTracker |
AtmosphereResourceStateRecovery.BroadcasterTracker.remove(Broadcaster b) |
Modifier and Type | Class and Description |
---|---|
class |
JerseyBroadcaster
Special
Broadcaster that use the ContainerResponse under the hood
to serialize the response. |
Modifier and Type | Method and Description |
---|---|
Broadcaster |
SuspendResponse.broadcaster()
Return the
Broadcaster that will be used to broadcast events. |
Broadcaster |
Broadcastable.getBroadcaster() |
Modifier and Type | Method and Description |
---|---|
SuspendResponse.SuspendResponseBuilder<E> |
SuspendResponse.SuspendResponseBuilder.broadcaster(Broadcaster broadcaster)
Set the
Broadcaster |
Constructor and Description |
---|
Broadcastable(Broadcaster b) |
Broadcastable(Object message,
Broadcaster b)
Broadcast the message to the set of suspended
AtmosphereResource , and write back
the message to the request which invoked the current resource method. |
Broadcastable(Object message,
Object callerMessage,
Broadcaster b)
Broadcast the message to the set of suspended
AtmosphereResource , and write back
the callerMessage to the request which invoked the current resource method. |
Modifier and Type | Class and Description |
---|---|
class |
JerseySimpleBroadcaster
Simple
Broadcaster implementation that use the calling thread when broadcasting events. |
Modifier and Type | Method and Description |
---|---|
static void |
JerseyBroadcasterUtil.broadcast(AtmosphereResource r,
AtmosphereResourceEvent e,
Broadcaster broadcaster) |
Modifier and Type | Method and Description |
---|---|
void |
BroadcasterLifecyclePolicyHandler.onPostCreate(Broadcaster b)
Invoked just after the
Broadcaster has been created. |
void |
BroadcasterLifecyclePolicyHandler.onPreDestroy(Broadcaster b)
Invoked before a Broadcaster is about to be deleted.
|
void |
BroadcasterLifecyclePolicyHandler.onRemoveAtmosphereResource(Broadcaster b,
AtmosphereResource r)
Invoked when an
AtmosphereResource is getting removed to a Broadcaster . |
Modifier and Type | Interface and Description |
---|---|
interface |
PoolableProvider<T extends Broadcaster,U>
Implements this interface for provisioning the
PoolableBroadcasterFactory
with Broadcaster |
Modifier and Type | Field and Description |
---|---|
protected org.apache.commons.pool2.impl.GenericObjectPool<Broadcaster> |
UnboundedApachePoolableProvider.genericObjectPool |
Modifier and Type | Method and Description |
---|---|
<T extends Broadcaster> |
PoolableBroadcasterFactory.lookup(Class<T> c,
Object id,
boolean createIfNull,
boolean unique) |
<T extends Broadcaster,U> |
PoolableProvider.returnBroadcaster(T b)
Return a destroyed
Broadcaster instance. |
Modifier and Type | Method and Description |
---|---|
Broadcaster |
UnboundedApachePoolableProvider.borrowBroadcaster(Object id) |
Broadcaster |
BoundedApachePoolableProvider.borrowBroadcaster(Object id) |
Broadcaster |
PoolableBroadcasterFactory.createBroadcaster() |
Broadcaster |
PoolableBroadcasterFactory.get() |
Modifier and Type | Method and Description |
---|---|
Collection<Broadcaster> |
PoolableBroadcasterFactory.lookupAll() |
PoolableProvider<? extends Broadcaster,?> |
PoolableBroadcasterFactory.poolableProvider()
The current
PoolableProvider |
Modifier and Type | Method and Description |
---|---|
boolean |
PoolableBroadcasterFactory.add(Broadcaster b,
Object id) |
boolean |
PoolableBroadcasterFactory.remove(Broadcaster b,
Object id) |
PoolableProvider |
UnboundedApachePoolableProvider.returnBroadcaster(Broadcaster b) |
Modifier and Type | Method and Description |
---|---|
PoolableBroadcasterFactory |
PoolableBroadcasterFactory.poolableProvider(PoolableProvider<? extends Broadcaster,?> poolableProvider)
Set the implementation of
PoolableProvider |
Constructor and Description |
---|
PoolableBroadcasterFactory(Class<? extends Broadcaster> clazz,
String broadcasterLifeCyclePolicy,
AtmosphereConfig c)
Deprecated.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractBroadcasterProxy
Abstract
Broadcaster that delegates the internal processing to a proxy. |
class |
ExcludeSessionBroadcaster
An implementation of
DefaultBroadcaster that exclude one or more AtmosphereResource |
class |
SimpleBroadcaster
Simple
Broadcaster implementation that use the calling thread when broadcasting events. |
Modifier and Type | Method and Description |
---|---|
Broadcaster |
SimpleBroadcaster.initialize(String id,
AtmosphereConfig config) |
Broadcaster |
ExcludeSessionBroadcaster.initialize(String id,
AtmosphereConfig config) |
Broadcaster |
AbstractBroadcasterProxy.initialize(String id,
URI uri,
AtmosphereConfig config) |
Constructor and Description |
---|
WebSocketHandlerProxy(Class<? extends Broadcaster> broadcasterClazz,
WebSocketHandler proxied) |
Copyright © 2016. All rights reserved.