All Classes

Class Description
AbstractBayeuxContext  
AbstractClientSession
Partial implementation of ClientSession.
AbstractHttpClientTransport  
AbstractHttpTransport
HTTP ServerTransport base class, used by ServerTransports that use HTTP as transport or to initiate a transport connection.
AbstractHttpTransport.Context  
AbstractHttpTransport.HttpScheduler
A AbstractServerTransport.Scheduler for HTTP-based transports.
AbstractServerTransport
The base class of all server transports.
AbstractServerTransport.Scheduler
Performs server-to-client transport operations when a /meta/connect message is held and a server-side message is published.
AbstractServerTransport.Scheduler.None
A scheduler that does not perform any operation but remembers the /meta/connect cycle.
AbstractService
AbstractService provides convenience methods to assist with the creation of a CometD services.
AbstractStreamHttpTransport
The base class for HTTP transports that use blocking stream I/O.
AbstractTransport  
AbstractWebSocketEndPoint  
AbstractWebSocketEndPoint.Context  
AbstractWebSocketTransport  
AbstractWebSocketTransport  
AckExtension
This client-side extension enables the client to acknowledge to the server the messages that the client has received.
AcknowledgedMessagesExtension
Installing this extension in a BayeuxServer provides support for server-to-client message acknowledgement if a client also supports it.
AcknowledgedMessagesSessionExtension
Tracks the batch id of messages sent to a client.
ActivityExtension
Monitors the activity of ServerSessions and disconnects them after a period of inactivity.
ActivityExtension.Activity
The possible activity to monitor
ActivityExtension.SessionExtension
Monitors the activity of a single ServerSession, disconnecting it when the max inactivity period is exceeded.
AnnotationCometDServlet
A specialized version of CometDServlet that can be configured with the init-parameter services to be a comma separated list of class names of annotated services, that will be processed by ServerAnnotationProcessor upon initialization.
AnnotationProcessor
Base class for common functionality in annotation processors
AsyncFoldLeft
Processes asynchronously a sequence of elements, producing a result that is the reduction of the results produced by the processing of each element.
AsyncFoldLeft.Loop<R>
Controls the iteration over a sequence of elements, allowing to continue the iteration (with a result), break out of the iteration (with a result), or fail the iteration (with an exception).
AsyncFoldLeft.Operation<T,​R>
The operation to invoke for each element.
AsyncJSONTransport  
Atomics  
Authorizer
Authorizer.Operation
Operations that are to be authorized on a channel
Authorizer.Result
The result of an authentication request.
Authorizer.Result.Denied  
Authorizer.Result.Granted  
Authorizer.Result.Ignored  
BatchArrayQueue<T>  
Bayeux
The Bayeux interface is the common API for both client-side and server-side configuration and usage of the Bayeux object.
Bayeux.BayeuxListener
The common base interface for Bayeux listeners.
Bayeux.Validator
Validates Bayeux protocol elements such as channel ids and message ids.
BayeuxClient
BayeuxClient is the implementation of a client for the Bayeux protocol.
BayeuxClient.BackOffStrategy
A strategy to controls wait times of the retry attempts in case of heartbeat failures.
BayeuxClient.BackOffStrategy.Constant
A back off strategy that always returns the same wait time.
BayeuxClient.BackOffStrategy.Linear
A strategy that increases the wait time linearly up to a maximum.
BayeuxClient.Scheduler  
BayeuxClient.State
The states that a BayeuxClient may assume.
BayeuxContext
The Bayeux Context provides information about the current context of a Bayeux message.
BayeuxServer
The server-side Bayeux interface.
BayeuxServer.BayeuxServerListener
Common base interface for all server-side Bayeux listeners.
BayeuxServer.ChannelListener
Specialized listener for ServerChannel events.
BayeuxServer.Extension
Extension API for BayeuxServer.
BayeuxServer.SessionListener
Specialized listener for ServerSession events.
BayeuxServer.SubscriptionListener
Specialized listener for ServerChannel subscription events.
BayeuxServerImpl  
BayeuxServerImplMBean  
BinaryData
Reified representation of binary data chunk contained in a message.
BinaryExtension
A client extension that encodes byte[] or ByteBuffer into a BinaryData object using the Z85 format for outgoing messages, and decodes BinaryData objects back into byte[] or ByteBuffer for incoming messages.
BinaryExtension
A server extension that encodes byte[] or ByteBuffer into a BinaryData object using the Z85 format for outgoing messages, and decodes BinaryData objects back into byte[] or ByteBuffer for incoming messages.
BinarySessionExtension
An extension that encodes/decodes binary data for a ServerSession.
BufferingJSONAsyncParser
A JSONContext.AsyncParser that parses an array of Bayeux messages.
Channel
A Bayeux channel is the primary message routing mechanism within Bayeux: both Bayeux clients and Bayeux server use channels to group listeners that are interested in receiving messages with that channel.
ChannelId
Reification of a channel id with methods to test properties and compare with other ChannelIds.
ChatService  
ClientAnnotationProcessor
Processes annotations in client-side service objects.
ClientSession
This interface represents the client side Bayeux session.
ClientSession.Extension
Extension API for client session.
ClientSession.MessageListener
A listener for remote call messages.
ClientSessionChannel
A client side channel representation.
ClientSessionChannel.ClientSessionChannelListener
Represents a listener on a ClientSessionChannel.
ClientSessionChannel.MessageListener
A listener for messages on a ClientSessionChannel.
ClientTransport
ClientTransports are used by BayeuxClient to send and receive Bayeux messages.
ClientTransport.Factory  
ClientTransport.FailureHandler  
ClientTransport.FailureInfo  
CometDDemo
Main class for CometD demo.
CometDDemoServlet  
CometDDemoServlet.EchoRPC  
CometDDemoServlet.Monitor  
CometDLoadClient  
CometDLoadServer  
CometDLoadServer.StatisticsService  
CometDServlet
The CometD Servlet maps HTTP requests to the AbstractHttpTransport of a BayeuxServer instance.
Config  
ConfigurableServerChannel
A ConfigurableServerChannel offers an API that can be used to configure ServerChannels at creation time.
ConfigurableServerChannel.Initializer
A listener interface by means of which listeners can atomically set the initial configuration of a channel.
ConfigurableServerChannel.Initializer.Persistent
Utility class that initializes channels to be persistent
ConfigurableServerChannel.ServerChannelListener
Common interface for ServerChannel listeners.
ConfigurableServerChannel.ServerChannelListener.Weak
Tag interface that marks ConfigurableServerChannel.ServerChannelListeners as "weak".
Configure
For server-side services, identifies channel configuration methods that are invoked when a message is processed on server-side.
ConsoleChatClient  
CookieParser
A parser for "Cookie" headers.
DataFilter
A filter that can add, modify or remove fields from the message data.
DataFilter.AbortException
Aborts the filtering of the message data.
DataFilterMessageListener
A MessageListener that applies DataFilters to the received messages.
DefaultSecurityPolicy  
GrantAuthorizer
This Authorizer implementation grants permission for a set of operations defined at construction time.
HashMapMessage  
HttpClientTransport  
JacksonJSONContext<M extends Message.Mutable,​I extends M>  
JacksonJSONContextClient  
JacksonJSONContextServer  
JettyHttpClientTransport  
JettyHttpClientTransport.Factory  
JettyJSONContext<M extends Message.Mutable>  
JettyJSONContext.AsyncJSONParser  
JettyJSONContextClient  
JettyJSONContextServer  
JettyWebSocketEndPoint  
JettyWebSocketTransport  
JettyWebSocketTransport  
JettyWebSocketTransport.Factory  
JSONContext<T extends Message.Mutable>
Abstraction for JSON parsing and generation.
JSONContext.AsyncParser
A non-blocking JSON parser.
JSONContext.Client
Client specific JSONContext that binds to Message.Mutable.
JSONContext.Generator
A JSON stringifier.
JSONContext.Parser
A blocking JSON parser.
JSONContextServer
Server specific JSONContext that binds to ServerMessage.Mutable.
JSONDataFilter
JSONPTransport  
JSONTransport  
Listener
For server-side services, identifies callback methods that are invoked when a message is processed on server-side.
LocalSession
A LocalSession is a ClientSession within the server.
LocalSessionImpl
A LocalSession implementation.
MarkedReference<T>
Immutable, non-volatile, non-atomic version of AtomicMarkableReference.
Message
The Bayeux protocol exchange information by means of messages.
Message.Mutable
The mutable version of a Message
MessageClientTransport
Classes implementing MessageClientTransport indicate that the transport they provide receives messages without the need of a previous request, like it happens in HTTP long poll.
MonitoringQueuedThreadPool  
MonitoringQueuedThreadPool.MonitoringBlockingArrayQueue  
MonitoringThreadPoolExecutor  
NoMarkupFilter  
NoScriptsFilter  
OkHttpClientTransport  
OkHttpClientTransport.Factory  
OkHttpWebSocketTransport  
OkHttpWebSocketTransport.Factory  
Oort
Oort is the cluster manager that links one CometD server to a set of other CometD servers.
Oort.CometListener
Listener interface that gets notified of comet events, that is when a new comet joins the cloud or when a comet leaves the cloud.
Oort.CometListener.Event
Comet event object delivered to Oort.CometListener methods.
OortComet
The Oort comet client connects a local Oort comet server to a remote Oort comet server.
OortConfigServlet
This servlet serves as a base class for initializing and configuring an instance of the Oort CometD cluster manager.
OortContainer<T>  
OortList<E>
A specialized oort object whose entity is a List.
OortList.DeltaListener<E>
An implementation of OortObject.Listener that converts whole list events into OortList.ElementListener events.
OortList.ElementListener<E>
Listener for element events that update the entity list, either locally or remotely.
OortLong
A shared atomic long made of an internal AtomicLong and of an internal OortObject<Long>.
OortLongMap<V>
The equivalent of an OortMap&lt;Long,V&gt;.
OortMap<K,​V>
A specialized oort object whose entity is a ConcurrentMap.
OortMap.DeltaListener<K,​V>
An implementation of OortObject.Listener that converts whole map events into OortMap.EntryListener events.
OortMap.Entry<K,​V>
A triple that holds the key, the previous value and the new value, used to notify entry updates:
OortMap.EntryListener<K,​V>
Listener for entry events that update the entity map, either locally or remotely.
OortMBean  
OortMulticastConfigServlet
This servlet initializes and configures an instance of the Oort CometD cluster manager via autodiscovery of other Oort comets using UDP multicast.
OortMulticastConfigurer  
OortObject<T>
An OortObject represents a named composite entity that is distributed in an Oort cluster.
OortObject.Data<T>  
OortObject.Factory<T>
Factory that creates objects stored by OortObjects.
OortObject.Info<T>
The oort object part holding the object and the metadata associated with it.
OortObject.Listener<T>
Listener for events that update the value of a OortObject.Info, either local or remote.
OortObject.Merger<T,​R>
A merge strategy for object values.
OortObject.Result<R>
An asynchronous result.
OortObject.Result.Deferred<D>
Implementation of OortObject.Result that allows applications to block, waiting for the result, via OortObject.Result.Deferred.get(long, TimeUnit).
OortObjectFactories  
OortObjectMergers  
OortObjectMergers.ListUnionMerger<E>  
OortPrimaryLong
A distributed counter service to be deployed on a Oort cluster that modifies a long value hosted in a "primary" node.
OortPrimaryLong.Callback
Callback invoked when the result of the operation on the counter is available, or when the operation failed.
OortPrimaryLong.Context  
OortPrimaryService<R,​C>
OortPrimaryService extends OortService to allow applications to perform actions on entities that always live in a "primary" node.
OortService<R,​C>
An OortService allows applications to forward actions to Oort nodes that own the entity onto which the action should be applied.
OortService.Request
Encapsulates a forwarded request.
OortService.Result<U>
Encapsulates the result of a forwarded request returned by OortService.onForward(Request).
OortService.ServerContext
Utility context that stores the ServerSession and the ServerMessage.
OortStaticConfigServlet
This servlet initializes and configures an instance of the Oort CometD cluster manager with a static list of other Oort comet URLs.
OortStringMap<V>
The equivalent of an OortMap&lt;String,V&gt;.
Param
For methods annotated with Listener or Subscription whose value is a channel template such as /game/{gameId}, this annotation binds parameters of those methods with the value obtained matching the actual channel with the channel template.
Promise<C>
The future result of an operation, either a value if the operation succeeded, or a failure if the operation failed.
Promise.Completable<S>
A CompletableFuture that is also a Promise.
RegexFilter  
RemoteCall
Identifies callback methods on server-side services that are invoked when the client is performing a remote call.
RemoteCall.Caller
Objects implementing this interface represent remote clients that performed remote calls.
SecurityPolicy
A SecurityPolicy defines the broad authorization constraints that must be enforced by a BayeuxServer.
ServerAnnotationProcessor
Processes annotations in server-side service objects.
ServerChannel
Server side representation of a Bayeux channel.
ServerChannel.MessageListener
Listeners objects that implement this interface will be notified of message publish.
ServerChannel.SubscriptionListener
Listener objects that implement this interface will be notified of subscription events.
ServerChannelImpl  
ServerMessage
Representation of a server side message.
ServerMessage.Mutable
The mutable version of a ServerMessage
ServerMessageImpl  
ServerSession
Objects implementing this interface are the server-side representation of remote Bayeux clients.
ServerSession.AddedListener
Listener objects that implement this interface will be notified of session addition.
ServerSession.DeQueueListener
Listeners objects that implement this interface will be notified when the session queue is being drained to actually deliver the messages.
ServerSession.Extension
Extension API for ServerSession.
ServerSession.HeartBeatListener
Listeners objects that implement this interface will be notified when a /meta/connect message is suspended by the server, and when it is subsequently resumed.
ServerSession.MessageListener
Listeners objects that implement this interface will be notified of message sending.
ServerSession.QueueListener
Listener objects that implement this interface will be notified when a message is queued in the session queue.
ServerSession.QueueMaxedListener
Listeners objects that implement this interface will be notified when the session queue is full.
ServerSession.RemovedListener
Listeners objects that implement this interface will be notified of session removal.
ServerSession.ServerSessionListener
Common interface for ServerSession listeners.
ServerSessionImpl  
ServerTransport
Server side extension of a Bayeux transport.
Service
Identifies classes whose instances are services that interact with the Bayeux API.
Session
Identifies fields and methods that can be injected with org.cometd.bayeux.Session sessions objects scoped to the service instance.
Session
A Bayeux session represents a connection between a bayeux client and a bayeux server.
Seti
The component that Searches for Extra Terrestrial Intelligence or, in this case, just searches for a user logged onto a comet in an Oort cloud.
Seti.Location
The representation of where a user is.
Seti.PresenceListener
Listener interface that gets notified of remote Seti presence events.
Seti.PresenceListener.Event
Seti presence event object, delivered to Seti.PresenceListener methods.
SetiServlet
This servlet initializes and configures and instance of the Seti user mapper.
Subscription
For server-side services, identifies callback methods that are invoked when a message is processed on local-side.
TimestampClientExtension  
TimestampExtension  
TimesyncClientExtension  
TimesyncExtension
Timesync extension (server side).
Transport
A transport abstract the details of the protocol used to send Bayeux messages over the network, for example using HTTP or using WebSocket.
TransportException  
TransportListener
Abstracts the communication between BayeuxClient and ClientTransport.
TransportRegistry  
WebSocketEndPoint  
WebSocketTransport  
WebSocketTransport  
WebSocketTransport.Factory  
Z85
An implementation of Z85, a format for representing binary data as printable text defined at https://rfc.zeromq.org/spec:32/Z85/.
Z85.Decoder  
Z85.Encoder