public class DefaultBroadcasterFactory extends Object implements BroadcasterFactory
Broadcaster instances. You can also add and remove BroadcasterBroadcasterFactory.BroadcasterCreationException| Modifier and Type | Field and Description |
|---|---|
protected ConcurrentLinkedQueue<BroadcasterListener> |
broadcasterListeners |
protected Class<? extends Broadcaster> |
clazz |
protected AtmosphereConfig |
config |
protected Broadcaster.POLICY |
defaultPolicy |
protected int |
defaultPolicyInteger |
static URI |
legacyBroadcasterURI |
protected BroadcasterListener |
lifeCycleListener |
protected BroadcasterLifeCyclePolicy |
policy |
protected ConcurrentHashMap<Object,Broadcaster> |
store |
| Constructor and Description |
|---|
DefaultBroadcasterFactory() |
DefaultBroadcasterFactory(Class<? extends Broadcaster> clazz,
String broadcasterLifeCyclePolicy,
AtmosphereConfig c)
Deprecated.
|
| Modifier and Type | Method and Description |
|---|---|
boolean |
add(Broadcaster b,
Object id)
Add a
Broadcaster to the list. |
BroadcasterFactory |
addBroadcasterListener(BroadcasterListener l)
Add a
BroadcasterListener |
Collection<BroadcasterListener> |
broadcasterListeners()
Return all
BroadcasterListener. |
void |
configure(Class<? extends Broadcaster> clazz,
String broadcasterLifeCyclePolicy,
AtmosphereConfig c)
Configure the factory
|
protected void |
configure(String broadcasterLifeCyclePolicy) |
protected <T extends Broadcaster> |
createBroadcaster(Class<T> c,
Object id) |
void |
destroy()
Shutdown all
Broadcasters. |
Broadcaster |
get()
Return an instance of the default
Broadcaster. |
<T extends Broadcaster> |
get(Class<T> c,
Object id)
Create a new instance of
Broadcaster and store it for. |
Broadcaster |
get(Object id)
Create a new instance of
Broadcaster and store it for. |
<T extends Broadcaster> |
lookup(Class<T> c,
Object id)
Lookup a
Broadcaster instance using Broadcaster.getID() or ID |
<T extends Broadcaster> |
lookup(Class<T> c,
Object id,
boolean createIfNull)
Lookup a
Broadcaster instance using Broadcaster.getID() or ID |
<T extends Broadcaster> |
lookup(Class<T> c,
Object id,
boolean createIfNull,
boolean unique) |
Broadcaster |
lookup(Object id)
Lookup a
Broadcaster instance using Broadcaster.getID() or ID |
Broadcaster |
lookup(Object id,
boolean createIfNull)
Lookup a
Broadcaster instance using Broadcaster.getID() or ID |
Collection<Broadcaster> |
lookupAll()
Return an immutable Collection of
Broadcaster this factory contains. |
void |
notifyOnPostCreate(Broadcaster b) |
boolean |
remove(Broadcaster b,
Object id)
Remove a
Broadcaster from the list. |
boolean |
remove(Object id)
Remove the associated
Broadcaster. |
void |
removeAllAtmosphereResource(AtmosphereResource r)
Deprecated.
|
BroadcasterFactory |
removeBroadcasterListener(BroadcasterListener l)
Remove a
BroadcasterListener |
protected final ConcurrentLinkedQueue<BroadcasterListener> broadcasterListeners
protected final ConcurrentHashMap<Object,Broadcaster> store
protected Class<? extends Broadcaster> clazz
protected BroadcasterLifeCyclePolicy policy
protected Broadcaster.POLICY defaultPolicy
protected int defaultPolicyInteger
protected AtmosphereConfig config
protected final BroadcasterListener lifeCycleListener
public static final URI legacyBroadcasterURI
public DefaultBroadcasterFactory()
@Deprecated public DefaultBroadcasterFactory(Class<? extends Broadcaster> clazz, String broadcasterLifeCyclePolicy, AtmosphereConfig c)
public void configure(Class<? extends Broadcaster> clazz, String broadcasterLifeCyclePolicy, AtmosphereConfig c)
BroadcasterFactoryconfigure in interface BroadcasterFactoryclazz - BroadcasterbroadcasterLifeCyclePolicy - BroadcasterLifeCyclePolicyc - AtmosphereConfigprotected void configure(String broadcasterLifeCyclePolicy)
public Broadcaster get()
BroadcasterFactoryBroadcaster.
The name of the Broadcaster will be randomly generated.get in interface BroadcasterFactoryBroadcasterpublic Broadcaster get(Object id)
BroadcasterFactoryBroadcaster and store it for.get in interface BroadcasterFactoryid - The unique ID used to retrieve BroadcasterBroadcasterpublic <T extends Broadcaster> T get(Class<T> c, Object id)
BroadcasterFactoryBroadcaster and store it for.get in interface BroadcasterFactoryc - The Broadcaster class instance.id - The unique ID used to retrieve BroadcasterBroadcasterprotected <T extends Broadcaster> T createBroadcaster(Class<T> c, Object id) throws BroadcasterFactory.BroadcasterCreationException
public boolean add(Broadcaster b, Object id)
BroadcasterFactoryBroadcaster to the list.add in interface BroadcasterFactoryb - a BroadcasterBroadcaster was already storedpublic boolean remove(Broadcaster b, Object id)
BroadcasterFactoryBroadcaster from the list.remove in interface BroadcasterFactoryb - a Broadcasterid - the IDBroadcasterpublic <T extends Broadcaster> T lookup(Class<T> c, Object id)
BroadcasterFactoryBroadcaster instance using Broadcaster.getID() or IDlookup in interface BroadcasterFactoryid - The Broadcaster's unique ID, or name.public Broadcaster lookup(Object id)
BroadcasterFactoryBroadcaster instance using Broadcaster.getID() or IDlookup in interface BroadcasterFactoryid - The Broadcaster's unique ID, or name.public Broadcaster lookup(Object id, boolean createIfNull)
BroadcasterFactoryBroadcaster instance using Broadcaster.getID() or IDlookup in interface BroadcasterFactoryid - The Broadcaster's unique ID, or name.createIfNull - If the broadcaster is not found, create it.public <T extends Broadcaster> T lookup(Class<T> c, Object id, boolean createIfNull)
BroadcasterFactoryBroadcaster instance using Broadcaster.getID() or IDlookup in interface BroadcasterFactoryid - The Broadcaster's unique ID, or name.createIfNull - If the broadcaster is not found, create it.public <T extends Broadcaster> T lookup(Class<T> c, Object id, boolean createIfNull, boolean unique)
@Deprecated public void removeAllAtmosphereResource(AtmosphereResource r)
BroadcasterFactoryAtmosphereResource from all registered Broadcasters.removeAllAtmosphereResource in interface BroadcasterFactoryr - an void AtmosphereResourcepublic boolean remove(Object id)
BroadcasterFactoryBroadcaster.remove in interface BroadcasterFactorypublic Collection<Broadcaster> lookupAll()
BroadcasterFactoryBroadcaster this factory contains.lookupAll in interface BroadcasterFactoryBroadcaster this factory contains.public void destroy()
BroadcasterFactoryBroadcasters.destroy in interface BroadcasterFactorypublic void notifyOnPostCreate(Broadcaster b)
public BroadcasterFactory addBroadcasterListener(BroadcasterListener l)
BroadcasterFactoryBroadcasterListeneraddBroadcasterListener in interface BroadcasterFactoryl - a BroadcasterListenerpublic BroadcasterFactory removeBroadcasterListener(BroadcasterListener l)
BroadcasterFactoryBroadcasterListenerremoveBroadcasterListener in interface BroadcasterFactoryl - a BroadcasterListenerpublic Collection<BroadcasterListener> broadcasterListeners()
BroadcasterListener.broadcasterListeners in interface BroadcasterFactoryBroadcasterListenerCopyright © 2016. All rights reserved.