public abstract class AbstractBroadcasterProxy extends DefaultBroadcaster
Broadcaster
that delegates the internal processing to a proxy.DefaultBroadcaster.AsyncWriteToken, DefaultBroadcaster.WriteQueue
Broadcaster.POLICY, Broadcaster.SCOPE
asyncWriteFuture, bc, broadcasterListeners, broadcastOnResume, CACHED, candidateForPoolable, config, delayedBroadcast, destroyed, dispatchThread, initialized, lifeCycleListeners, messages, name, notifierFuture, POLLING_DEFAULT, resources, scope, sharedListeners, started, uniqueWriteQueue, uri, usingTokenIdForAttribute, waitTime, writeQueues, writeTimeoutInSecond
ROOT_MASTER
Constructor and Description |
---|
AbstractBroadcasterProxy() |
Modifier and Type | Method and Description |
---|---|
protected Future<Object> |
b(Object msg) |
Future<Object> |
broadcast(Object msg)
Broadcast the
Object to all suspended responses, eg. |
Future<Object> |
broadcast(Object msg,
AtmosphereResource r)
Broadcast the
Object to all suspended responses, eg. |
Future<Object> |
broadcast(Object msg,
Set<AtmosphereResource> subset)
Broadcast the
Object to all suspended response, eg. |
protected void |
broadcastReceivedMessage(Object message) |
protected Runnable |
getBroadcastHandler() |
abstract void |
incomingBroadcast()
Implement this method to broadcast message received from an external source like JGroups, Redis, etc.
|
Broadcaster |
initialize(String id,
URI uri,
AtmosphereConfig config)
Configure a Broadcaster.
|
protected void |
invokeOnStateChange(AtmosphereResource r,
AtmosphereResourceEvent e) |
abstract void |
outgoingBroadcast(Object message)
Implement this method to broadcast message to external source like JGroups, Redis, etc.
|
protected void |
reconfigure() |
addAtmosphereResource, addBroadcasterLifeCyclePolicyListener, addBroadcasterListener, awaitAndBroadcast, broadcasterListeners, broadcastOnResume, broadcastOnResume, cacheAndSuspend, cacheLostMessage, cacheLostMessage, cacheLostMessage, cacheMessageOnIOException, checkCachedAndPush, createBroadcasterConfig, currentLifecycleTask, currentLifecycleTask, delayBroadcast, delayBroadcast, deliverPush, destroy, dispatchMessages, endBroadcast, entryDone, executeAsyncWrite, executeBlockingWrite, filter, futureDone, getAsyncWriteHandler, getAtmosphereResources, getBroadcasterConfig, getBroadcasterLifeCyclePolicy, getID, getScope, initialize, isDestroyed, killReactiveThreads, lifecycleHandler, lifecycleHandler, lifeCycleListeners, lifeCyclePolicy, messages, notifyAndAdd, notifyBroadcastListener, notifyOnAddAtmosphereResourceListener, notifyOnMessage, notifyOnRemoveAtmosphereResourceListener, onException, onException, outOfOrderBroadcastSupported, perRequestFilter, policy, prepareInvokeOnStateChange, push, queueWriteIO, reactiveThreadsCount, recentActivity, releaseExternalResources, removeAtmosphereResource, removeAtmosphereResource, removeBroadcasterLifeCyclePolicyListener, removeBroadcasterListener, rename, resumeAll, retrieveTrackedBroadcast, scheduleFixedBroadcast, scheduleFixedBroadcast, setBroadcasterConfig, setBroadcasterLifeCyclePolicy, setID, setScope, setSuspendPolicy, spawnReactor, start, toString, writeQueues
public Broadcaster initialize(String id, URI uri, AtmosphereConfig config)
Broadcaster
initialize
in interface Broadcaster
initialize
in class DefaultBroadcaster
config
- an AtmosphereConfig
public abstract void incomingBroadcast()
public abstract void outgoingBroadcast(Object message)
message
- outgoing messageprotected Runnable getBroadcastHandler()
getBroadcastHandler
in class DefaultBroadcaster
protected void reconfigure()
protected void invokeOnStateChange(AtmosphereResource r, AtmosphereResourceEvent e)
invokeOnStateChange
in class DefaultBroadcaster
protected void broadcastReceivedMessage(Object message)
public Future<Object> broadcast(Object msg)
Broadcaster
Object
to all suspended responses, eg. invoke AtmosphereHandler.onStateChange(org.atmosphere.cpr.AtmosphereResourceEvent)
.broadcast
in interface Broadcaster
broadcast
in class DefaultBroadcaster
msg
- the Object
to be broadcastedFuture
that can be used to synchronize using the Future.get()
public Future<Object> broadcast(Object msg, AtmosphereResource r)
Broadcaster
Object
to all suspended responses, eg. invoke
AtmosphereHandler.onStateChange(org.atmosphere.cpr.AtmosphereResourceEvent)
with an instance of AtmosphereResource
, representing
a single suspended response.broadcast
in interface Broadcaster
broadcast
in class DefaultBroadcaster
msg
- the Object
to be broadcastedr
- an AtmosphereResource
Future
that can be used to synchronize using the Future.get()
public Future<Object> broadcast(Object msg, Set<AtmosphereResource> subset)
Broadcaster
Object
to all suspended response, eg. invoke
AtmosphereHandler.onStateChange(org.atmosphere.cpr.AtmosphereResourceEvent)
with a Set
of AtmosphereResource
,
representing a set of AtmosphereHandler
.broadcast
in interface Broadcaster
broadcast
in class DefaultBroadcaster
msg
- the Object
to be broadcastedsubset
- a Set of AtmosphereResource
Future
that can be used to synchronize using the Future.get()
Copyright © 2016. All rights reserved.