All Classes Interface Summary Class Summary Enum Summary Exception Summary Annotation Types Summary
Class |
Description |
AbstractBayeuxContext |
|
AbstractClientSession |
|
AbstractHttpClientTransport |
|
AbstractHttpTransport |
HTTP ServerTransport base class, used by ServerTransports that use
HTTP as transport or to initiate a transport connection.
|
AbstractHttpTransport.Context |
|
AbstractHttpTransport.HttpScheduler |
|
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.
|
AcknowledgedMessagesExtension.Listener |
A listener for acknowledgement events.
|
AcknowledgedMessagesSessionExtension |
Tracks the batch id of messages sent to a client.
|
ActivityExtension |
Monitors the activity of ServerSession s 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 |
|
BayeuxServer.Extension |
|
BayeuxServer.SessionListener |
|
BayeuxServer.SubscriptionListener |
|
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 |
|
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 |
|
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 |
|
ClientSessionChannel.MessageListener |
|
ClientTransport |
|
ClientTransport.Factory |
|
ClientTransport.FailureHandler |
|
ClientTransport.FailureInfo |
|
CometDDemo |
Main class for CometD demo.
|
CometDDemoServlet |
|
CometDDemoServlet.EchoRPC |
|
CometDDemoServlet.Monitor |
|
CometDLoadClient |
|
CometDLoadServer |
|
CometDLoadServer.StatisticsService |
|
CometDServlet |
|
Config |
|
ConfigurableServerChannel |
|
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 |
|
ConfigurableServerChannel.ServerChannelListener.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 |
|
JSONContext.Generator |
A JSON stringifier.
|
JSONContext.Parser |
A blocking JSON parser.
|
JSONContextServer |
|
JSONDataFilter |
JSONDataFilter walks an object to see if it is
a JSON data structure and calls the appropriate methods
JSONDataFilter.filterString(ServerSession, ServerChannel, String) ,
JSONDataFilter.filterNumber(ServerSession, ServerChannel, Number) ,
JSONDataFilter.filterBoolean(ServerSession, ServerChannel, Boolean) ,
JSONDataFilter.filterArray(ServerSession, ServerChannel, Object) ,
JSONDataFilter.filterCollection(ServerSession, ServerChannel, Collection) ,
JSONDataFilter.filterList(ServerSession, ServerChannel, List) ,
JSONDataFilter.filterMap(ServerSession, ServerChannel, Map) .
|
JSONPTransport |
|
JSONTransport |
|
Listener |
For server-side services, identifies callback methods that are invoked
when a message is processed on server-side.
|
LocalSession |
|
LocalSessionImpl |
|
MarkedReference<T> |
Immutable, non-volatile, non-atomic version of AtomicMarkableReference .
|
Message |
The Bayeux protocol exchange information by means of messages.
|
Message.Mutable |
|
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 |
|
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> |
|
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<Long,V> .
|
OortMap<K,V> |
A specialized oort object whose entity is a ConcurrentMap .
|
OortMap.DeltaListener<K,V> |
|
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 OortObject s.
|
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> |
|
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> |
|
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> |
|
OortService.ServerContext |
|
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<String,V> .
|
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 |
|
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 |
|
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 |
|
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 |
|
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 |
|
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 |
|
TransportRegistry |
|
WebSocketEndPoint |
|
WebSocketTransport |
|
WebSocketTransport |
|
WebSocketTransport.Factory |
|
Z85 |
An implementation of Z85, a format for representing binary data as printable
text defined at ZeroMQ Z85.
|
Z85.Decoder |
|
Z85.Encoder |
|