org.atmosphere.jersey.util

Class JerseySimpleBroadcaster

java.lang.Object

org.atmosphere.cpr.DefaultBroadcaster

org.atmosphere.util.SimpleBroadcaster

org.atmosphere.jersey.util.JerseySimpleBroadcaster

All Implemented Interfaces:

Broadcaster

public class JerseySimpleBroadcaster
extends SimpleBroadcaster

Simple Broadcaster implementation that use the calling thread when broadcasting events.

Author:

Jeanfrancois Arcand

Nested Class Summary

Nested classes/interfaces inherited from class org.atmosphere.cpr.DefaultBroadcaster

DefaultBroadcaster.AsyncWriteToken, DefaultBroadcaster.WriteQueue

Nested classes/interfaces inherited from interface org.atmosphere.cpr.Broadcaster

Broadcaster.POLICY, Broadcaster.SCOPE

Field Summary

Fields inherited from class org.atmosphere.cpr.DefaultBroadcaster

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

Fields inherited from interface org.atmosphere.cpr.Broadcaster

ROOT_MASTER

Constructor Summary

Constructors

Constructor and Description
JerseySimpleBroadcaster()

Method Summary

Modifier and Type	Method and Description
protected void	invokeOnStateChange(AtmosphereResource r, AtmosphereResourceEvent e)

Methods inherited from class org.atmosphere.util.SimpleBroadcaster

broadcast, broadcast, broadcast, createBroadcasterConfig, initialize, prepareInvokeOnStateChange, queueWriteIO, setBroadcasterConfig, start

Methods inherited from class org.atmosphere.cpr.DefaultBroadcaster

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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

JerseySimpleBroadcaster

public JerseySimpleBroadcaster()

Method Detail

invokeOnStateChange

protected void invokeOnStateChange(AtmosphereResource r,
                                   AtmosphereResourceEvent e)

Overrides:

invokeOnStateChange in class DefaultBroadcaster