public class ExcludeSessionBroadcaster extends DefaultBroadcaster
DefaultBroadcaster
that exclude one or more AtmosphereResource
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 |
---|
ExcludeSessionBroadcaster() |
Modifier and Type | Method and Description |
---|---|
Future<Object> |
broadcast(Object msg,
AtmosphereResource r)
the AtmosphereResource r will be exclude for this broadcast
|
Future<Object> |
broadcast(Object msg,
javax.servlet.http.HttpSession s)
session will be exclude for this broadcast
|
Future<Object> |
broadcast(Object msg,
List<javax.servlet.http.HttpSession> sessions)
a list of sessions will be exclude for this broadcast
|
Future<Object> |
broadcast(Object msg,
Set<AtmosphereResource> subset)
the AtmosphereResources subset will be exclude for this broadcast
|
Broadcaster |
initialize(String id,
AtmosphereConfig config) |
addAtmosphereResource, addBroadcasterLifeCyclePolicyListener, addBroadcasterListener, awaitAndBroadcast, broadcast, 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, getBroadcastHandler, getID, getScope, initialize, invokeOnStateChange, 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, AtmosphereConfig config)
initialize
in class DefaultBroadcaster
public Future<Object> broadcast(Object msg, AtmosphereResource r)
broadcast
in interface Broadcaster
broadcast
in class DefaultBroadcaster
msg
- r
- public Future<Object> broadcast(Object msg, Set<AtmosphereResource> subset)
broadcast
in interface Broadcaster
broadcast
in class DefaultBroadcaster
msg
- subset
- public Future<Object> broadcast(Object msg, List<javax.servlet.http.HttpSession> sessions)
msg
- sessions
- Copyright © 2016. All rights reserved.