All Classes
| Class | Description |
|---|---|
| AbstractBayeuxContext | |
| AbstractClientSession |
Partial implementation of
ClientSession. |
| AbstractHttpTransport |
HTTP ServerTransport base class, used by ServerTransports that use
HTTP as transport or to initiate a transport connection.
|
| AbstractHttpTransport.HttpScheduler | |
| AbstractServerTransport |
The base class of all server transports.
|
| AbstractServerTransport.Scheduler | |
| 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 | |
| AbstractWebSocketTransport | |
| AbstractWebSocketTransport<S> | |
| 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. |
| 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.
|
| BayeuxClient |
BayeuxClient is the implementation of a client for the Bayeux protocol.
|
| 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.Extension.Adapter |
Empty implementation of
BayeuxServer.Extension. |
| 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. |
| 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.Extension.Adapter |
Empty implementation of
ClientSession.Extension. |
| 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.Abort | Deprecated.
use
DataFilter.AbortException instead |
| 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<T extends Message.Mutable,I extends T> | |
| JacksonJSONContextClient | |
| JacksonJSONContextServer | |
| JettyJSONContext<T extends Message.Mutable> | |
| JettyJSONContextClient | |
| JettyJSONContextServer | |
| JettyWebSocketTransport | |
| JettyWebSocketTransport | |
| JettyWebSocketTransport.Factory | |
| JSONContext | |
| JSONContext.Client | |
| JSONContext.Generator | |
| JSONContext.Parser | |
| JSONContext.Server | |
| 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 |
A
LocalSession is a ClientSession within the server. |
| LocalSessionImpl |
A
LocalSession implementation. |
| LongPollingTransport | |
| LongPollingTransport.Factory | |
| 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 | |
| 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.Adapter |
Empty implementation of
Oort.CometListener |
| 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.
|
| OortList.ElementListener.Adapter<E> |
Empty implementation of
OortList.ElementListener. |
| 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> |
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.
|
| OortMap.EntryListener.Adapter<K,V> |
Empty implementation of
OortMap.EntryListener. |
| OortMasterLong |
A distributed counter service to be deployed on a Oort cluster that
modifies a
long value hosted in a "master" node. |
| OortMasterLong.Callback |
Callback invoked when the result of the operation on the counter is available,
or when the operation failed.
|
| OortMasterLong.Callback.Adapter |
Empty implementation of
OortMasterLong.Callback |
| OortMasterLong.Context | |
| OortMasterService<R,C> |
OortMasterService extends OortService to allow applications
to perform actions on entities that always live in a "master" node. |
| 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.Listener.Adapter<T> |
An empty implementation of
OortObject.Listener. |
| 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> | |
| 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<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. |
| 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.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.Extension.Adapter |
Empty implementation of
ServerSession.Extension. |
| ServerSession.MaxQueueListener |
Listeners objects that implement this interface will be notified when the session queue is full.
|
| 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.RemoveListener |
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
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.Adapter |
Empty implementation of
Seti.PresenceListener |
| 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. |
| TransportListener.Empty | |
| TransportRegistry | |
| 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 |