public class JerseySimpleBroadcaster extends SimpleBroadcaster
Broadcaster
implementation that use the calling thread when broadcasting events.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 |
---|
JerseySimpleBroadcaster() |
Modifier and Type | Method and Description |
---|---|
protected void |
invokeOnStateChange(AtmosphereResource r,
AtmosphereResourceEvent e) |
broadcast, broadcast, broadcast, createBroadcasterConfig, initialize, prepareInvokeOnStateChange, queueWriteIO, setBroadcasterConfig, start
addAtmosphereResource, addBroadcasterLifeCyclePolicyListener, addBroadcasterListener, awaitAndBroadcast, broadcasterListeners, broadcastOnResume, broadcastOnResume, cacheAndSuspend, cacheLostMessage, cacheLostMessage, cacheLostMessage, cacheMessageOnIOException, checkCachedAndPush, currentLifecycleTask, currentLifecycleTask, delayBroadcast, delayBroadcast, deliverPush, destroy, dispatchMessages, endBroadcast, entryDone, executeAsyncWrite, executeBlockingWrite, filter, futureDone, getAsyncWriteHandler, getAtmosphereResources, getBroadcasterConfig, getBroadcasterLifeCyclePolicy, getBroadcastHandler, getID, getScope, initialize, isDestroyed, killReactiveThreads, lifecycleHandler, lifecycleHandler, lifeCycleListeners, lifeCyclePolicy, messages, notifyAndAdd, notifyBroadcastListener, notifyOnAddAtmosphereResourceListener, notifyOnMessage, notifyOnRemoveAtmosphereResourceListener, onException, onException, outOfOrderBroadcastSupported, perRequestFilter, policy, push, reactiveThreadsCount, recentActivity, releaseExternalResources, removeAtmosphereResource, removeAtmosphereResource, removeBroadcasterLifeCyclePolicyListener, removeBroadcasterListener, rename, resumeAll, retrieveTrackedBroadcast, scheduleFixedBroadcast, scheduleFixedBroadcast, setBroadcasterLifeCyclePolicy, setID, setScope, setSuspendPolicy, spawnReactor, toString, writeQueues
protected void invokeOnStateChange(AtmosphereResource r, AtmosphereResourceEvent e)
invokeOnStateChange
in class DefaultBroadcaster
Copyright © 2016. All rights reserved.