- All Implemented Interfaces:
Bayeux
,BayeuxServer
,org.eclipse.jetty.util.component.Container
,org.eclipse.jetty.util.component.Destroyable
,org.eclipse.jetty.util.component.Dumpable
,org.eclipse.jetty.util.component.Dumpable.DumpableContainer
,org.eclipse.jetty.util.component.LifeCycle
-
Nested Class Summary
Nested classes/interfaces inherited from class org.eclipse.jetty.util.component.AbstractLifeCycle
org.eclipse.jetty.util.component.AbstractLifeCycle.AbstractLifeCycleListener, org.eclipse.jetty.util.component.AbstractLifeCycle.StopException
Nested classes/interfaces inherited from interface org.cometd.bayeux.Bayeux
Bayeux.BayeuxListener, Bayeux.Validator
Nested classes/interfaces inherited from interface org.cometd.bayeux.server.BayeuxServer
BayeuxServer.BayeuxServerListener, BayeuxServer.ChannelListener, BayeuxServer.Extension, BayeuxServer.SessionListener, BayeuxServer.SubscriptionListener
Nested classes/interfaces inherited from interface org.eclipse.jetty.util.component.Container
org.eclipse.jetty.util.component.Container.InheritedListener, org.eclipse.jetty.util.component.Container.Listener
Nested classes/interfaces inherited from interface org.eclipse.jetty.util.component.Dumpable
org.eclipse.jetty.util.component.Dumpable.DumpableContainer
Nested classes/interfaces inherited from interface org.eclipse.jetty.util.component.LifeCycle
org.eclipse.jetty.util.component.LifeCycle.Listener
-
Field Summary
FieldsModifier and TypeFieldDescriptionstatic final String
static final String
static final String
static final String
static final String
static final String
static final String
static final String
static final String
Fields inherited from class org.eclipse.jetty.util.component.AbstractLifeCycle
FAILED, STARTED, STARTING, STOPPED, STOPPING
Fields inherited from interface org.cometd.bayeux.server.BayeuxServer
ATTRIBUTE
Fields inherited from interface org.eclipse.jetty.util.component.Dumpable
KEY
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoid
addExtension
(BayeuxServer.Extension extension) Adds the given extension to this Bayeux object.void
addListener
(BayeuxServer.BayeuxServerListener listener) Adds a listener to this Bayeux object.void
addServerSession
(ServerSessionImpl session, ServerMessage message) addTransport
(ServerTransport transport) createChannelIfAbsent
(String channelName, ConfigurableServerChannel.Initializer... initializers) Creates aServerChannel
and initializes it atomically if the channel does not exist, or returns it if it already exists.protected ServerMessage.Mutable
createReply
(ServerMessage.Mutable message) protected void
doStart()
protected void
doStop()
void
dump
(Appendable out, String indent) protected void
error
(ServerMessage.Mutable reply, String error) void
protected void
extendOutgoing
(ServerSession sender, ServerSession session, ServerMessage.Mutable message, Promise<Boolean> promise) void
extendReply
(ServerSessionImpl sender, ServerSessionImpl session, ServerMessage.Mutable reply, Promise<ServerMessage.Mutable> promise) void
freeze
(ServerMessage.Mutable mutable) getChannel
(String channelId) protected List
<BayeuxServer.BayeuxServerListener> getName()
protected boolean
protected long
org.eclipse.jetty.util.thread.Scheduler
getSession
(String clientId) long
int
getTransport
(String transport) void
handle
(ServerSessionImpl session, ServerMessage.Mutable message, Promise<ServerMessage.Mutable> promise) protected void
protected void
protected void
boolean
boolean
newChannelId
(String id) newLocalSession
(String idHint) Creates a newLocalSession
.newMessage
(ServerMessage original) protected void
publish
(ServerSessionImpl session, ServerChannelImpl channel, ServerMessage.Mutable message, boolean receiving, Promise<Boolean> promise) long
void
removeExtension
(BayeuxServer.Extension extension) Removes the given extension from this Bayeux object.void
Removes a listener from this Bayeux object.protected boolean
removeServerChannel
(ServerChannelImpl channel) boolean
removeServerSession
(ServerSession session, boolean timeout) boolean
removeSession
(ServerSession session) Removes the givensession
from this BayeuxServer.resolveLoop
(AsyncFoldLeft.Loop<Boolean> loop) org.eclipse.jetty.util.thread.Scheduler.Task
Entry point to schedule tasks in CometD.void
setAllowedTransports
(String... allowed) void
setAllowedTransports
(List<String> allowed) void
setDetailedDump
(boolean detailedDump) void
setExecutor
(Executor executor) void
void
setOptions
(Map<String, Object> options) void
setScheduler
(org.eclipse.jetty.util.thread.Scheduler scheduler) void
setSecurityPolicy
(SecurityPolicy securityPolicy) void
setSweepPeriod
(long sweepPeriod) void
setSweepThreads
(int sweepThreads) void
setTransports
(List<ServerTransport> transports) void
setTransports
(ServerTransport... transports) void
sweep()
protected void
protected String
validateMessage
(ServerMessage.Mutable message) Methods inherited from class org.eclipse.jetty.util.component.ContainerLifeCycle
addBean, addBean, addEventListener, addManaged, contains, destroy, dump, dump, dumpObjects, dumpStdErr, getBean, getBeans, getBeans, getContainedBeans, getContainedBeans, installBean, installBean, isAuto, isManaged, isUnmanaged, manage, removeBean, removeBeans, removeEventListener, setBeans, start, stop, unmanage, updateBean, updateBean, updateBeans, updateBeans
Methods inherited from class org.eclipse.jetty.util.component.AbstractLifeCycle
getEventListeners, getState, getState, isFailed, isRunning, isStarted, isStarting, isStopped, isStopping, setEventListeners, start, stop, toString
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
Methods inherited from interface org.eclipse.jetty.util.component.Container
getCachedBeans, getEventListeners
Methods inherited from interface org.eclipse.jetty.util.component.Dumpable
dump, dumpSelf
Methods inherited from interface org.eclipse.jetty.util.component.Dumpable.DumpableContainer
isDumpable
-
Field Details
-
ALLOWED_TRANSPORTS_OPTION
- See Also:
-
SWEEP_PERIOD_OPTION
- See Also:
-
SWEEP_THREADS_OPTION
- See Also:
-
TRANSPORTS_OPTION
- See Also:
-
VALIDATE_MESSAGE_FIELDS_OPTION
- See Also:
-
BROADCAST_TO_PUBLISHER_OPTION
- See Also:
-
SCHEDULER_THREADS
- See Also:
-
EXECUTOR_MAX_THREADS
- See Also:
-
CONTEXT_ATTRIBUTE_NAME_OPTION
- See Also:
-
-
Constructor Details
-
BayeuxServerImpl
public BayeuxServerImpl()
-
-
Method Details
-
getName
-
doStart
-
doStop
-
initializeMetaChannels
protected void initializeMetaChannels() -
initializeJSONContext
-
initializeServerTransports
protected void initializeServerTransports() -
setExecutor
-
getExecutor
-
execute
-
setScheduler
public void setScheduler(org.eclipse.jetty.util.thread.Scheduler scheduler) -
getScheduler
public org.eclipse.jetty.util.thread.Scheduler getScheduler() -
schedule
Entry point to schedule tasks in CometD.
Subclasses may override and run the task in a
Executor
, rather than in the scheduler thread.- Parameters:
task
- the task to scheduledelay
- the delay, in milliseconds, to run the task- Returns:
- the task promise
-
newChannelId
-
getOptions
-
getOption
-
getOption
-
getOption
-
getOptionNames
- Specified by:
getOptionNames
in interfaceBayeux
- Returns:
- the set of configuration options
- See Also:
-
setOption
-
setOptions
-
randomLong
public long randomLong() -
getSecurityPolicy
- Specified by:
getSecurityPolicy
in interfaceBayeuxServer
- Returns:
- the
SecurityPolicy
associated with this session - See Also:
-
getJSONContext
-
createChannelIfAbsent
public MarkedReference<ServerChannel> createChannelIfAbsent(String channelName, ConfigurableServerChannel.Initializer... initializers) Description copied from interface:BayeuxServer
Creates a
ServerChannel
and initializes it atomically if the channel does not exist, or returns it if it already exists.This method can be used instead of adding a
BayeuxServer.ChannelListener
to atomically initialize a channel. Theinitializers
will be called before any other thread can access the new channel instance.This method should be used when a channel needs to be initialized (e.g. by adding listeners) before any publish or subscribes can occur on the channel, or before any other thread may concurrently create the same channel.
- Specified by:
createChannelIfAbsent
in interfaceBayeuxServer
- Parameters:
channelName
- the channel nameinitializers
- the initializers invoked to configure the channel- Returns:
- a
MarkedReference
whose reference is the channel, and the mark signals whether the channel has been created because it did not exist before.
-
getSessions
- Specified by:
getSessions
in interfaceBayeuxServer
- Returns:
- the list of
ServerSession
s known to this BayeuxServer object
-
getSession
- Specified by:
getSession
in interfaceBayeuxServer
- Parameters:
clientId
- theServerSession
identifier- Returns:
- the
ServerSession
with the givenclientId
or null if no such valid session exists.
-
addServerSession
-
removeSession
Description copied from interface:BayeuxServer
Removes the given
session
from this BayeuxServer.This method triggers the invocation of all listeners that would be called if the session was disconnected or if the session timed out.
- Specified by:
removeSession
in interfaceBayeuxServer
- Parameters:
session
- the session to remove- Returns:
- true if the session was known to this BayeuxServer and was removed
-
removeServerSession
- Parameters:
session
- the session to removetimeout
- whether the session has been removed due to a timeout- Returns:
- true if the session was removed and was connected
-
newServerSession
-
newLocalSession
Description copied from interface:BayeuxServer
Creates a new
LocalSession
.A
LocalSession
is a server-side ClientSession that allows server-side code to have special clients (resident within the same JVM) that can be used to publish and subscribe like a client-side session would do.- Specified by:
newLocalSession
in interfaceBayeuxServer
- Parameters:
idHint
- a hint to be included in the unique clientId of the session.- Returns:
- a new
LocalSession
-
newMessage
- Specified by:
newMessage
in interfaceBayeuxServer
- Returns:
- a new or recycled mutable message instance.
-
newMessage
-
setSecurityPolicy
- Specified by:
setSecurityPolicy
in interfaceBayeuxServer
- Parameters:
securityPolicy
- theSecurityPolicy
associated with this session- See Also:
-
addExtension
Description copied from interface:BayeuxServer
Adds the given extension to this Bayeux object.
- Specified by:
addExtension
in interfaceBayeuxServer
- Parameters:
extension
- the extension to add- See Also:
-
removeExtension
Description copied from interface:BayeuxServer
Removes the given extension from this Bayeux object.
- Specified by:
removeExtension
in interfaceBayeuxServer
- Parameters:
extension
- the extension to remove- See Also:
-
getExtensions
- Specified by:
getExtensions
in interfaceBayeuxServer
- Returns:
- an immutable list of extensions present in this BayeuxServer instance
- See Also:
-
addListener
Description copied from interface:BayeuxServer
Adds a listener to this Bayeux object.
- Specified by:
addListener
in interfaceBayeuxServer
- Parameters:
listener
- the listener to add- See Also:
-
getChannel
- Specified by:
getChannel
in interfaceBayeuxServer
- Parameters:
channelId
- the channel identifier- Returns:
- a
ServerChannel
with the givenchannelId
, or null if no such channel exists - See Also:
-
getChannels
- Specified by:
getChannels
in interfaceBayeuxServer
- Returns:
- the list of channels known to this BayeuxServer object
-
removeListener
Description copied from interface:BayeuxServer
Removes a listener from this Bayeux object.
- Specified by:
removeListener
in interfaceBayeuxServer
- Parameters:
listener
- the listener to remove- See Also:
-
handle
public void handle(ServerSessionImpl session, ServerMessage.Mutable message, Promise<ServerMessage.Mutable> promise) -
validateMessage
-
publish
protected void publish(ServerSessionImpl session, ServerChannelImpl channel, ServerMessage.Mutable message, boolean receiving, Promise<Boolean> promise) -
resolveLoop
-
freeze
-
extendOutgoing
protected void extendOutgoing(ServerSession sender, ServerSession session, ServerMessage.Mutable message, Promise<Boolean> promise) -
extendReply
public void extendReply(ServerSessionImpl sender, ServerSessionImpl session, ServerMessage.Mutable reply, Promise<ServerMessage.Mutable> promise) -
removeServerChannel
-
getListeners
-
getKnownTransportNames
- Specified by:
getKnownTransportNames
in interfaceBayeux
- Returns:
- the set of known transport names of this Bayeux object.
- See Also:
-
getTransport
- Specified by:
getTransport
in interfaceBayeux
- Specified by:
getTransport
in interfaceBayeuxServer
- Parameters:
transport
- the transport name- Returns:
- the transport with the given name or null if no such transport exist
-
addTransport
-
setTransports
-
setTransports
-
getTransports
-
getAllowedTransports
@ManagedAttribute(value="The transports allowed by this CometD server", readonly=true) public List<String> getAllowedTransports()- Specified by:
getAllowedTransports
in interfaceBayeux
- Returns:
- the ordered list of transport names that will be used in the negotiation of transports with the other peer.
- See Also:
-
setAllowedTransports
-
setAllowedTransports
-
isBroadcastToPublisher
@ManagedAttribute(value="Whether this CometD server broadcast messages to the publisher", readonly=true) public boolean isBroadcastToPublisher() -
unknownSession
-
error
-
createReply
-
sweep
@ManagedOperation(value="Sweeps channels and sessions of this CometD server", impact="ACTION") public void sweep() -
asyncSweep
-
isDetailedDump
@ManagedAttribute("Reports additional details in the dump() operation") public boolean isDetailedDump() -
setDetailedDump
public void setDetailedDump(boolean detailedDump) -
getSweepPeriod
@ManagedAttribute("The period, in milliseconds, of the sweeping activity performed by the server") public long getSweepPeriod() -
setSweepPeriod
public void setSweepPeriod(long sweepPeriod) -
getSweepThreads
@ManagedAttribute("The maximum number of threads that can be used by the sweeping activity performed by the server") public int getSweepThreads() -
setSweepThreads
public void setSweepThreads(int sweepThreads) -
dump
- Specified by:
dump
in interfaceorg.eclipse.jetty.util.component.Dumpable
- Overrides:
dump
in classorg.eclipse.jetty.util.component.ContainerLifeCycle
- Throws:
IOException
-
getLastSweepInfo
-
getLongestSweepInfo
-