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 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 |
|
| 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 |
|
| CometDApplication |
|
| 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 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> |
|
| 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 |
|