public class DefaultBroadcasterFactory extends Object implements BroadcasterFactory
Broadcaster
instances. You can also add and remove Broadcaster
BroadcasterFactory.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
Broadcaster s. |
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)
BroadcasterFactory
configure
in interface BroadcasterFactory
clazz
- Broadcaster
broadcasterLifeCyclePolicy
- BroadcasterLifeCyclePolicy
c
- AtmosphereConfig
protected void configure(String broadcasterLifeCyclePolicy)
public Broadcaster get()
BroadcasterFactory
Broadcaster
.
The name of the Broadcaster will be randomly generated.get
in interface BroadcasterFactory
Broadcaster
public Broadcaster get(Object id)
BroadcasterFactory
Broadcaster
and store it for.get
in interface BroadcasterFactory
id
- The unique ID used to retrieve Broadcaster
Broadcaster
public <T extends Broadcaster> T get(Class<T> c, Object id)
BroadcasterFactory
Broadcaster
and store it for.get
in interface BroadcasterFactory
c
- The Broadcaster
class instance.id
- The unique ID used to retrieve Broadcaster
Broadcaster
protected <T extends Broadcaster> T createBroadcaster(Class<T> c, Object id) throws BroadcasterFactory.BroadcasterCreationException
public boolean add(Broadcaster b, Object id)
BroadcasterFactory
Broadcaster
to the list.add
in interface BroadcasterFactory
b
- a Broadcaster
Broadcaster
was already storedpublic boolean remove(Broadcaster b, Object id)
BroadcasterFactory
Broadcaster
from the list.remove
in interface BroadcasterFactory
b
- a Broadcaster
id
- the ID
Broadcaster
public <T extends Broadcaster> T lookup(Class<T> c, Object id)
BroadcasterFactory
Broadcaster
instance using Broadcaster.getID()
or IDlookup
in interface BroadcasterFactory
id
- The Broadcaster's unique ID, or name.public Broadcaster lookup(Object id)
BroadcasterFactory
Broadcaster
instance using Broadcaster.getID()
or IDlookup
in interface BroadcasterFactory
id
- The Broadcaster's unique ID, or name.public Broadcaster lookup(Object id, boolean createIfNull)
BroadcasterFactory
Broadcaster
instance using Broadcaster.getID()
or IDlookup
in interface BroadcasterFactory
id
- 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)
BroadcasterFactory
Broadcaster
instance using Broadcaster.getID()
or IDlookup
in interface BroadcasterFactory
id
- 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)
BroadcasterFactory
AtmosphereResource
from all registered Broadcaster
s.removeAllAtmosphereResource
in interface BroadcasterFactory
r
- an void AtmosphereResource
public boolean remove(Object id)
BroadcasterFactory
Broadcaster
.remove
in interface BroadcasterFactory
public Collection<Broadcaster> lookupAll()
BroadcasterFactory
Broadcaster
this factory contains.lookupAll
in interface BroadcasterFactory
Broadcaster
this factory contains.public void destroy()
BroadcasterFactory
Broadcaster
s.destroy
in interface BroadcasterFactory
public void notifyOnPostCreate(Broadcaster b)
public BroadcasterFactory addBroadcasterListener(BroadcasterListener l)
BroadcasterFactory
BroadcasterListener
addBroadcasterListener
in interface BroadcasterFactory
l
- a BroadcasterListener
public BroadcasterFactory removeBroadcasterListener(BroadcasterListener l)
BroadcasterFactory
BroadcasterListener
removeBroadcasterListener
in interface BroadcasterFactory
l
- a BroadcasterListener
public Collection<BroadcasterListener> broadcasterListeners()
BroadcasterListener
.broadcasterListeners
in interface BroadcasterFactory
BroadcasterListener
Copyright © 2016. All rights reserved.