A B C D E F G H I J L M N O P Q R S T U V W Z _
All Classes All Packages

A

abort() - Method in class org.cometd.client.BayeuxClient

Interrupts abruptly the communication with the Bayeux server.

abort(Throwable) - Method in class org.cometd.client.http.common.AbstractHttpClientTransport

abort(Throwable) - Method in class org.cometd.client.http.jetty.JettyHttpClientTransport

abort(Throwable) - Method in class org.cometd.client.http.okhttp.OkHttpClientTransport

abort(Throwable) - Method in class org.cometd.client.transport.ClientTransport

Aborts this transport, usually by cancelling all pending Bayeux messages that require a response, such as /meta/connects, without waiting for a response.

abort(Throwable) - Method in class org.cometd.client.websocket.common.AbstractWebSocketTransport

AbortException() - Constructor for exception org.cometd.server.filter.DataFilter.AbortException

AbortException(String) - Constructor for exception org.cometd.server.filter.DataFilter.AbortException

AbortException(String, Throwable) - Constructor for exception org.cometd.server.filter.DataFilter.AbortException

AbortException(Throwable) - Constructor for exception org.cometd.server.filter.DataFilter.AbortException

AbstractBayeuxContext - Class in org.cometd.server.websocket.common

AbstractBayeuxContext(ServletContext, String, String, Map<String, List<String>>, Map<String, List<String>>, Principal, HttpSession, InetSocketAddress, InetSocketAddress, List<Locale>, String, boolean) - Constructor for class org.cometd.server.websocket.common.AbstractBayeuxContext

AbstractClientSession - Class in org.cometd.common

Partial implementation of ClientSession.

AbstractClientSession() - Constructor for class org.cometd.common.AbstractClientSession

AbstractClientSession.AbstractSessionChannel - Class in org.cometd.common

A channel scoped to a ClientSession.

AbstractHttpClientTransport - Class in org.cometd.client.http.common

AbstractHttpClientTransport(String, Map<String, Object>) - Constructor for class org.cometd.client.http.common.AbstractHttpClientTransport

Deprecated.

use AbstractHttpClientTransport(String, Map, ScheduledExecutorService) instead

AbstractHttpClientTransport(String, Map<String, Object>, ScheduledExecutorService) - Constructor for class org.cometd.client.http.common.AbstractHttpClientTransport

AbstractHttpTransport - Class in org.cometd.server.http

HTTP ServerTransport base class, used by ServerTransports that use HTTP as transport or to initiate a transport connection.

AbstractHttpTransport(BayeuxServerImpl, String) - Constructor for class org.cometd.server.http.AbstractHttpTransport

AbstractHttpTransport.Context - Class in org.cometd.server.http

AbstractHttpTransport.HttpScheduler - Interface in org.cometd.server.http

A AbstractServerTransport.Scheduler for HTTP-based transports.

AbstractHttpTransport.LongPollScheduler - Class in org.cometd.server.http

AbstractReader(AbstractHttpTransport.Context, Promise<Void>) - Constructor for class org.cometd.server.http.AsyncJSONTransport.AbstractReader

AbstractServerTransport - Class in org.cometd.server

The base class of all server transports.

AbstractServerTransport(BayeuxServerImpl, String) - Constructor for class org.cometd.server.AbstractServerTransport

The constructor is passed the BayeuxServerImpl instance for the transport.

AbstractServerTransport.Scheduler - Interface in org.cometd.server

Performs server-to-client transport operations when a /meta/connect message is held and a server-side message is published.

AbstractServerTransport.Scheduler.None - Class in org.cometd.server

A scheduler that does not perform any operation but remembers the /meta/connect cycle.

AbstractService - Class in org.cometd.server

AbstractService provides convenience methods to assist with the creation of a CometD services.

AbstractService(BayeuxServer, String) - Constructor for class org.cometd.server.AbstractService

Instantiates a CometD service with the given name.

AbstractService(BayeuxServer, String, int) - Constructor for class org.cometd.server.AbstractService

Instantiate a CometD service with the given name and max number of pooled threads.

AbstractSessionChannel(ChannelId) - Constructor for class org.cometd.common.AbstractClientSession.AbstractSessionChannel

AbstractStreamHttpTransport - Class in org.cometd.server.http

The base class for HTTP transports that use blocking stream I/O.

AbstractStreamHttpTransport(BayeuxServerImpl, String) - Constructor for class org.cometd.server.http.AbstractStreamHttpTransport

AbstractStreamHttpTransport.DispatchingLongPollScheduler - Class in org.cometd.server.http

AbstractTransport - Class in org.cometd.common

AbstractTransport(String, Map<String, Object>) - Constructor for class org.cometd.common.AbstractTransport

AbstractWebSocketEndPoint - Class in org.cometd.server.websocket.common

AbstractWebSocketEndPoint(AbstractWebSocketTransport, BayeuxContext) - Constructor for class org.cometd.server.websocket.common.AbstractWebSocketEndPoint

AbstractWebSocketEndPoint.Context - Class in org.cometd.server.websocket.common

AbstractWebSocketTransport - Class in org.cometd.client.websocket.common

AbstractWebSocketTransport - Class in org.cometd.server.websocket.common

AbstractWebSocketTransport(String, Map<String, Object>, ScheduledExecutorService) - Constructor for class org.cometd.client.websocket.common.AbstractWebSocketTransport

AbstractWebSocketTransport(BayeuxServerImpl) - Constructor for class org.cometd.server.websocket.common.AbstractWebSocketTransport

AbstractWebSocketTransport.Delegate - Class in org.cometd.client.websocket.common

accept(HttpServletRequest) - Method in class org.cometd.server.http.AbstractHttpTransport

accept(HttpServletRequest) - Method in class org.cometd.server.http.AsyncJSONTransport

accept(HttpServletRequest) - Method in class org.cometd.server.http.JSONPTransport

accept(HttpServletRequest) - Method in class org.cometd.server.http.JSONTransport

accept(String) - Method in class org.cometd.client.http.common.AbstractHttpClientTransport

accept(String) - Method in class org.cometd.client.transport.ClientTransport

accept(String) - Method in class org.cometd.client.websocket.javax.WebSocketTransport

accept(String) - Method in class org.cometd.client.websocket.jetty.JettyWebSocketTransport

accept(String) - Method in class org.cometd.client.websocket.okhttp.OkHttpWebSocketTransport

ACK_FIELD - Static variable in class org.cometd.client.ext.AckExtension

AckExtension - Class in org.cometd.client.ext

This client-side extension enables the client to acknowledge to the server the messages that the client has received.

AckExtension() - Constructor for class org.cometd.client.ext.AckExtension

AcknowledgedMessagesExtension - Class in org.cometd.server.ext

Installing this extension in a BayeuxServer provides support for server-to-client message acknowledgement if a client also supports it.

AcknowledgedMessagesExtension() - Constructor for class org.cometd.server.ext.AcknowledgedMessagesExtension

AcknowledgedMessagesExtension.Listener - Interface in org.cometd.server.ext

A listener for acknowledgement events.

AcknowledgedMessagesSessionExtension - Class in org.cometd.server.ext

Tracks the batch id of messages sent to a client.

AcknowledgedMessagesSessionExtension(ServerSession) - Constructor for class org.cometd.server.ext.AcknowledgedMessagesSessionExtension

action - Variable in class org.cometd.client.transport.ClientTransport.FailureInfo

ACTION_FIELD - Static variable in class org.cometd.oort.OortObject.Info

actionToState() - Method in class org.cometd.client.transport.ClientTransport.FailureInfo

ActivityExtension - Class in org.cometd.server.ext

Monitors the activity of ServerSessions and disconnects them after a period of inactivity.

ActivityExtension(ActivityExtension.Activity, long) - Constructor for class org.cometd.server.ext.ActivityExtension

Creates an ActivityExtension to be installed in the BayeuxServer

ActivityExtension.Activity - Enum in org.cometd.server.ext

The possible activity to monitor

ActivityExtension.SessionExtension - Class in org.cometd.server.ext

Monitors the activity of a single ServerSession, disconnecting it when the max inactivity period is exceeded.

add(ClientTransport) - Method in class org.cometd.client.transport.TransportRegistry

add(T) - Method in class org.cometd.server.ext.BatchArrayQueue

addAll(Collection<? extends T>) - Method in class org.cometd.server.ext.BatchArrayQueue

addAndGet(long) - Method in class org.cometd.oort.OortLong

addAndGet(long, OortPrimaryLong.Callback) - Method in class org.cometd.oort.OortPrimaryLong

Adds the given delta and then invokes the given callback with the counter value after the addition.

addAndShare(OortObject.Result<Boolean>, E...) - Method in class org.cometd.oort.OortList

Adds the given elements to the local entity list, and then broadcasts the addition to all nodes in the cluster.

addAuthorizer(Authorizer) - Method in interface org.cometd.bayeux.server.ConfigurableServerChannel

Adds the given Authorizer that grants or denies operations on this channel.

addAuthorizer(Authorizer) - Method in class org.cometd.server.ServerChannelImpl

addCometListener(Oort.CometListener) - Method in class org.cometd.oort.Oort

Registers the given listener to be notified of comet events.

added(ServerSession, ServerMessage) - Method in interface org.cometd.bayeux.server.ServerSession.AddedListener

Callback method invoked when the session is added to a BayeuxServer.

addElementListener(OortList.ElementListener<E>) - Method in class org.cometd.oort.OortList

addEntryListener(OortMap.EntryListener<K, V>) - Method in class org.cometd.oort.OortMap

addExtension(ClientSession.Extension) - Method in interface org.cometd.bayeux.client.ClientSession

Adds an extension to this session.

addExtension(ClientSession.Extension) - Method in class org.cometd.common.AbstractClientSession

addExtension(BayeuxServer.Extension) - Method in interface org.cometd.bayeux.server.BayeuxServer

Adds the given extension to this Bayeux object.

addExtension(BayeuxServer.Extension) - Method in class org.cometd.server.BayeuxServerImpl

addExtension(ServerSession.Extension) - Method in interface org.cometd.bayeux.server.ServerSession

Adds the given extension to this session.

addExtension(ServerSession.Extension) - Method in class org.cometd.server.ServerSessionImpl

addListener(ClientSessionChannel.ClientSessionChannelListener) - Method in interface org.cometd.bayeux.client.ClientSessionChannel

Adds a listener to this channel.

addListener(ClientSessionChannel.ClientSessionChannelListener) - Method in class org.cometd.common.AbstractClientSession.AbstractSessionChannel

addListener(BayeuxServer.BayeuxServerListener) - Method in interface org.cometd.bayeux.server.BayeuxServer

Adds a listener to this Bayeux object.

addListener(BayeuxServer.BayeuxServerListener) - Method in class org.cometd.server.BayeuxServerImpl

addListener(ConfigurableServerChannel.ServerChannelListener) - Method in interface org.cometd.bayeux.server.ConfigurableServerChannel

addListener(ConfigurableServerChannel.ServerChannelListener) - Method in class org.cometd.server.ServerChannelImpl

addListener(ServerSession.ServerSessionListener) - Method in interface org.cometd.bayeux.server.ServerSession

Adds the given listener to this session.

addListener(ServerSession.ServerSessionListener) - Method in class org.cometd.server.ServerSessionImpl

addListener(OortObject.Listener<Long>) - Method in class org.cometd.oort.OortLong

addListener(OortObject.Listener<T>) - Method in class org.cometd.oort.OortObject

addListener(AcknowledgedMessagesExtension.Listener) - Method in class org.cometd.server.ext.AcknowledgedMessagesExtension

addListener(AcknowledgedMessagesExtension.Listener) - Method in class org.cometd.server.ext.AcknowledgedMessagesSessionExtension

addMessage(ServerMessage) - Method in class org.cometd.server.ServerSessionImpl

addPresenceListener(Seti.PresenceListener) - Method in class org.cometd.oort.Seti

addServerSession(ServerSessionImpl, ServerMessage) - Method in class org.cometd.server.BayeuxServerImpl

addService(String, String) - Method in class org.cometd.server.AbstractService

Maps the method of a subclass with the given name to a ServerChannel.MessageListener on the given channel, so that the method is invoked for each message received on the channel.

addTransport(ServerTransport) - Method in class org.cometd.server.BayeuxServerImpl

addTransportListener(TransportListener) - Method in class org.cometd.client.BayeuxClient

ADVICE_FIELD - Static variable in interface org.cometd.bayeux.Message

ALLOW_MESSAGE_DELIVERY_DURING_HANDSHAKE - Static variable in class org.cometd.server.AbstractServerTransport

ALLOWED_TRANSPORTS_OPTION - Static variable in class org.cometd.server.BayeuxServerImpl

allowMessageDeliveryDuringHandshake(ServerSessionImpl) - Method in class org.cometd.server.AbstractServerTransport

AnnotationCometDServlet - Class in org.cometd.annotation.server

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.

AnnotationCometDServlet() - Constructor for class org.cometd.annotation.server.AnnotationCometDServlet

AnnotationProcessor - Class in org.cometd.annotation

Base class for common functionality in annotation processors

AnnotationProcessor() - Constructor for class org.cometd.annotation.AnnotationProcessor

append(byte[], int, int) - Method in class org.cometd.server.http.AsyncJSONTransport.AbstractReader

append(byte[], int, int) - Method in class org.cometd.server.http.AsyncJSONTransport.CharsetReader

append(byte[], int, int) - Method in class org.cometd.server.http.AsyncJSONTransport.UTF8Reader

apply(R, T, AsyncFoldLeft.Loop<R>) - Method in interface org.cometd.common.AsyncFoldLeft.Operation

Processes the given element.

asByteBuffer() - Method in class org.cometd.bayeux.BinaryData

asBytes() - Method in class org.cometd.bayeux.BinaryData

associate(String, ServerSession) - Method in class org.cometd.oort.Seti

Associates the given userId to the given session.

associate(String, Seti.Location) - Method in class org.cometd.oort.Seti

AsyncFoldLeft - Class in org.cometd.common

Processes asynchronously a sequence of elements, producing a result that is the reduction of the results produced by the processing of each element.

AsyncFoldLeft() - Constructor for class org.cometd.common.AsyncFoldLeft

AsyncFoldLeft.Loop<R> - Interface in org.cometd.common

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> - Interface in org.cometd.common

The operation to invoke for each element.

AsyncJSONFactory() - Constructor for class org.cometd.common.JettyJSONContext.AsyncJSONFactory

AsyncJSONParser(AsyncJSON) - Constructor for class org.cometd.common.JettyJSONContext.AsyncJSONParser

AsyncJSONTransport - Class in org.cometd.server.http

AsyncJSONTransport(BayeuxServerImpl) - Constructor for class org.cometd.server.http.AsyncJSONTransport

AsyncJSONTransport.AbstractReader - Class in org.cometd.server.http

AsyncJSONTransport.CharsetReader - Class in org.cometd.server.http

AsyncJSONTransport.UTF8Reader - Class in org.cometd.server.http

AsyncJSONTransport.Writer - Class in org.cometd.server.http

Atomics - Class in org.cometd.benchmark

Atomics() - Constructor for class org.cometd.benchmark.Atomics

ATTRIBUTE - Static variable in interface org.cometd.bayeux.server.BayeuxServer

ServletContext attribute name used to obtain the Bayeux object

authorize(Authorizer.Operation, ChannelId, ServerSession, ServerMessage) - Method in interface org.cometd.bayeux.server.Authorizer

Blocking version of Authorizer.authorize(Operation, ChannelId, ServerSession, ServerMessage, Promise).

authorize(Authorizer.Operation, ChannelId, ServerSession, ServerMessage) - Method in class org.cometd.server.authorizer.GrantAuthorizer

authorize(Authorizer.Operation, ChannelId, ServerSession, ServerMessage, Promise<Authorizer.Result>) - Method in interface org.cometd.bayeux.server.Authorizer

Callback invoked to authorize the given operation on the given channel.

Authorizer - Interface in org.cometd.bayeux.server

Authorizers authorize operations on channels.

Authorizer.Operation - Enum in org.cometd.bayeux.server

Operations that are to be authorized on a channel

Authorizer.Result - Class in org.cometd.bayeux.server

The result of an authentication request.

Authorizer.Result.Denied - Class in org.cometd.bayeux.server

Authorizer.Result.Granted - Class in org.cometd.bayeux.server

Authorizer.Result.Ignored - Class in org.cometd.bayeux.server

authorizers() - Method in class org.cometd.server.ServerChannelImpl

B

BACKOFF_INCREMENT_OPTION - Static variable in class org.cometd.client.BayeuxClient

batch(Runnable) - Method in interface org.cometd.bayeux.Session

Executes the given command in a batch so that any Bayeux message sent by the command (via the Bayeux API) is queued up until the end of the command and then all messages are sent at once.

batch(Runnable) - Method in class org.cometd.common.AbstractClientSession

batch(Runnable) - Method in class org.cometd.server.ServerSessionImpl

BatchArrayQueue<T> - Class in org.cometd.server.ext

BatchArrayQueue(int, Lock) - Constructor for class org.cometd.server.ext.BatchArrayQueue

Bayeux - Interface in org.cometd.bayeux

The Bayeux interface is the common API for both client-side and server-side configuration and usage of the Bayeux object.

BAYEUX_VERSION - Static variable in class org.cometd.client.BayeuxClient

Bayeux.BayeuxListener - Interface in org.cometd.bayeux

The common base interface for Bayeux listeners.

Bayeux.Validator - Class in org.cometd.bayeux

Validates Bayeux protocol elements such as channel ids and message ids.

BayeuxClient - Class in org.cometd.client

BayeuxClient is the implementation of a client for the Bayeux protocol.

BayeuxClient(String, ScheduledExecutorService, ClientTransport, ClientTransport...) - Constructor for class org.cometd.client.BayeuxClient

Creates a BayeuxClient that will connect to the Bayeux server at the given URL, with the given scheduler and with the given transport(s).

BayeuxClient(String, ClientTransport, ClientTransport...) - Constructor for class org.cometd.client.BayeuxClient

Creates a BayeuxClient that will connect to the Bayeux server at the given URL and with the given transport(s).

BayeuxClient.BackOffStrategy - Interface in org.cometd.client

A strategy to controls wait times of the retry attempts in case of heartbeat failures.

BayeuxClient.BackOffStrategy.Constant - Class in org.cometd.client

A back off strategy that always returns the same wait time.

BayeuxClient.BackOffStrategy.Linear - Class in org.cometd.client

A strategy that increases the wait time linearly up to a maximum.

BayeuxClient.BayeuxClientChannel - Class in org.cometd.client

A channel scoped to this BayeuxClient.

BayeuxClient.Scheduler - Class in org.cometd.client

BayeuxClient.State - Enum in org.cometd.client

The states that a BayeuxClient may assume.

BayeuxClientChannel(ChannelId) - Constructor for class org.cometd.client.BayeuxClient.BayeuxClientChannel

bayeuxContext - Variable in class org.cometd.server.http.AbstractHttpTransport.Context

BayeuxContext - Interface in org.cometd.bayeux.server

The Bayeux Context provides information about the current context of a Bayeux message.

BayeuxServer - Interface in org.cometd.bayeux.server

The server-side Bayeux interface.

BayeuxServer.BayeuxServerListener - Interface in org.cometd.bayeux.server

Common base interface for all server-side Bayeux listeners.

BayeuxServer.ChannelListener - Interface in org.cometd.bayeux.server

Specialized listener for ServerChannel events.

BayeuxServer.Extension - Interface in org.cometd.bayeux.server

Extension API for BayeuxServer.

BayeuxServer.SessionListener - Interface in org.cometd.bayeux.server

Specialized listener for ServerSession events.

BayeuxServer.SubscriptionListener - Interface in org.cometd.bayeux.server

Specialized listener for ServerChannel subscription events.

BayeuxServerImpl - Class in org.cometd.server

BayeuxServerImpl() - Constructor for class org.cometd.server.BayeuxServerImpl

BayeuxServerImplMBean - Class in org.cometd.server.jmx

BayeuxServerImplMBean(Object) - Constructor for class org.cometd.server.jmx.BayeuxServerImplMBean

beginWrite(HttpServletRequest, HttpServletResponse) - Method in class org.cometd.server.http.AbstractStreamHttpTransport

beginWrite(HttpServletRequest, HttpServletResponse) - Method in class org.cometd.server.http.JSONPTransport

beginWrite(HttpServletRequest, HttpServletResponse) - Method in class org.cometd.server.http.JSONTransport

BinaryData - Class in org.cometd.bayeux

Reified representation of binary data chunk contained in a message.

BinaryData(byte[], boolean, Map<String, Object>) - Constructor for class org.cometd.bayeux.BinaryData

BinaryData(ByteBuffer, boolean, Map<String, Object>) - Constructor for class org.cometd.bayeux.BinaryData

BinaryData(Map<? extends String, ?>) - Constructor for class org.cometd.bayeux.BinaryData

BinaryExtension - Class in org.cometd.client.ext

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 - Class in org.cometd.server.ext

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.

BinaryExtension() - Constructor for class org.cometd.client.ext.BinaryExtension

BinaryExtension() - Constructor for class org.cometd.server.ext.BinaryExtension

BinaryExtension(boolean) - Constructor for class org.cometd.client.ext.BinaryExtension

BinaryExtension(boolean) - Constructor for class org.cometd.server.ext.BinaryExtension

BinarySessionExtension - Class in org.cometd.server.ext

An extension that encodes/decodes binary data for a ServerSession.

BinarySessionExtension(BayeuxServer) - Constructor for class org.cometd.server.ext.BinarySessionExtension

BinarySessionExtension(BayeuxServer, boolean) - Constructor for class org.cometd.server.ext.BinarySessionExtension

bind(ChannelId) - Method in class org.cometd.bayeux.ChannelId

If this ChannelId is a template, and the given target ChannelId is non-wild and non-template, and the two have the same ChannelId.depth(), then binds the variable(s) defined in this template with the values of the segments defined by the target ChannelId.

BROADCAST_TO_PUBLISHER_OPTION - Static variable in class org.cometd.server.BayeuxServerImpl

BROWSER_COOKIE_DOMAIN_OPTION - Static variable in class org.cometd.server.http.AbstractHttpTransport

BROWSER_COOKIE_HTTP_ONLY_OPTION - Static variable in class org.cometd.server.http.AbstractHttpTransport

BROWSER_COOKIE_MAX_AGE_OPTION - Static variable in class org.cometd.server.http.AbstractHttpTransport

BROWSER_COOKIE_NAME_OPTION - Static variable in class org.cometd.server.http.AbstractHttpTransport

BROWSER_COOKIE_PARTITIONED_OPTION - Static variable in class org.cometd.server.http.AbstractHttpTransport

BROWSER_COOKIE_PATH_OPTION - Static variable in class org.cometd.server.http.AbstractHttpTransport

BROWSER_COOKIE_SAME_SITE_OPTION - Static variable in class org.cometd.server.http.AbstractHttpTransport

BROWSER_COOKIE_SECURE_OPTION - Static variable in class org.cometd.server.http.AbstractHttpTransport

BUFFER_SIZE_OPTION - Static variable in class org.cometd.server.websocket.common.AbstractWebSocketTransport

BufferingJSONAsyncParser - Class in org.cometd.common

A JSONContext.AsyncParser that parses an array of Bayeux messages.

BufferingJSONAsyncParser(JSONContext<? extends Message.Mutable>) - Constructor for class org.cometd.common.BufferingJSONAsyncParser

C

calculateInterval(long) - Method in class org.cometd.server.ServerSessionImpl

calculateMaxNetworkDelay(List<Message.Mutable>) - Method in class org.cometd.client.http.common.AbstractHttpClientTransport

calculateTimeout(long) - Method in class org.cometd.server.ServerSessionImpl

CALLBACK_PARAMETER_MAX_LENGTH_OPTION - Static variable in class org.cometd.server.http.JSONPTransport

CALLBACK_PARAMETER_OPTION - Static variable in class org.cometd.server.http.JSONPTransport

callPublic(Object, Method, Object...) - Static method in class org.cometd.annotation.AnnotationProcessor

cancel() - Method in interface org.cometd.server.AbstractServerTransport.Scheduler

Invoked when the transport wants to cancel scheduled operations that will trigger when the /meta/connect timeout fires.

cancel(Throwable) - Method in interface org.cometd.server.AbstractServerTransport.Scheduler

Invoked when the transport wants to cancel with the given cause scheduled operations that will trigger when the /meta/connect timeout fires.

cancel(Throwable) - Method in class org.cometd.server.http.AbstractHttpTransport.LongPollScheduler

cancelExpiration(boolean) - Method in class org.cometd.server.ServerSessionImpl

canCreate(BayeuxServer, ServerSession, String, ServerMessage) - Method in interface org.cometd.bayeux.server.SecurityPolicy

Blocking version of SecurityPolicy.canCreate(BayeuxServer, ServerSession, String, ServerMessage, Promise).

canCreate(BayeuxServer, ServerSession, String, ServerMessage) - Method in class org.cometd.server.DefaultSecurityPolicy

canCreate(BayeuxServer, ServerSession, String, ServerMessage, Promise<Boolean>) - Method in interface org.cometd.bayeux.server.SecurityPolicy

Checks if a message should be allowed to create a new channel.

canHandshake(BayeuxServer, ServerSession, ServerMessage) - Method in interface org.cometd.bayeux.server.SecurityPolicy

Blocking version of SecurityPolicy.canHandshake(BayeuxServer, ServerSession, ServerMessage, Promise).

canHandshake(BayeuxServer, ServerSession, ServerMessage) - Method in class org.cometd.server.DefaultSecurityPolicy

canHandshake(BayeuxServer, ServerSession, ServerMessage, Promise<Boolean>) - Method in interface org.cometd.bayeux.server.SecurityPolicy

Checks if a handshake message should be accepted.

canPublish(BayeuxServer, ServerSession, ServerChannel, ServerMessage) - Method in interface org.cometd.bayeux.server.SecurityPolicy

Blocking version of SecurityPolicy.canPublish(BayeuxServer, ServerSession, ServerChannel, ServerMessage, Promise).

canPublish(BayeuxServer, ServerSession, ServerChannel, ServerMessage) - Method in class org.cometd.server.DefaultSecurityPolicy

canPublish(BayeuxServer, ServerSession, ServerChannel, ServerMessage, Promise<Boolean>) - Method in interface org.cometd.bayeux.server.SecurityPolicy

Checks if a client can publish a message to a channel.

canSubscribe(BayeuxServer, ServerSession, ServerChannel, ServerMessage) - Method in interface org.cometd.bayeux.server.SecurityPolicy

Blocking version of SecurityPolicy.canSubscribe(BayeuxServer, ServerSession, ServerChannel, ServerMessage, Promise).

canSubscribe(BayeuxServer, ServerSession, ServerChannel, ServerMessage) - Method in class org.cometd.server.DefaultSecurityPolicy

canSubscribe(BayeuxServer, ServerSession, ServerChannel, ServerMessage, Promise<Boolean>) - Method in interface org.cometd.bayeux.server.SecurityPolicy

Checks if a subscribe message from a client is allowed to subscribe to a channel.

cause - Variable in class org.cometd.client.transport.ClientTransport.FailureInfo

Channel - Interface in org.cometd.bayeux

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.

CHANNEL_FIELD - Static variable in interface org.cometd.bayeux.Message

CHANNEL_PREFIX - Static variable in class org.cometd.benchmark.Config

channelAdded(ServerChannel) - Method in interface org.cometd.bayeux.server.BayeuxServer.ChannelListener

Callback invoked when a ServerChannel has been added to a BayeuxServer object.

ChannelId - Class in org.cometd.bayeux

Reification of a channel id with methods to test properties and compare with other ChannelIds.

ChannelId(String) - Constructor for class org.cometd.bayeux.ChannelId

Constructs a new ChannelId with the given id

channelRemoved(String) - Method in interface org.cometd.bayeux.server.BayeuxServer.ChannelListener

Callback invoked when a ServerChannel has been removed from a BayeuxServer object.

CharsetReader(AbstractHttpTransport.Context, Promise<Void>, Charset) - Constructor for class org.cometd.server.http.AsyncJSONTransport.CharsetReader

ChatService - Class in org.cometd.examples

ChatService() - Constructor for class org.cometd.examples.ChatService

checkMethodsPublic(Object, Class<? extends Annotation>) - Static method in class org.cometd.annotation.AnnotationProcessor

checkOrigin(String) - Method in class org.cometd.server.websocket.javax.WebSocketTransport

checkOrigin(JettyServerUpgradeRequest, String) - Method in class org.cometd.server.websocket.jetty.JettyWebSocketTransport

checkSignaturesMatch(Method, Class<?>[], List<String>) - Static method in class org.cometd.annotation.AnnotationProcessor

clear() - Method in class org.cometd.benchmark.MonitoringQueuedThreadPool.MonitoringBlockingArrayQueue

clear() - Method in class org.cometd.server.ext.BatchArrayQueue

clearSubscriptions() - Method in class org.cometd.oort.OortComet

clearToBatch(long) - Method in class org.cometd.server.ext.BatchArrayQueue

CLIENT - org.cometd.server.ext.ActivityExtension.Activity

Constant that indicates to monitor only client activity for a session

CLIENT_ID_FIELD - Static variable in interface org.cometd.bayeux.Message

CLIENT_SERVER - org.cometd.server.ext.ActivityExtension.Activity

Constant that indicates to monitor both client and server activity for a session

ClientAnnotationProcessor - Class in org.cometd.annotation.client

Processes annotations in client-side service objects.

ClientAnnotationProcessor(ClientSession) - Constructor for class org.cometd.annotation.client.ClientAnnotationProcessor

ClientAnnotationProcessor(ClientSession, Object...) - Constructor for class org.cometd.annotation.client.ClientAnnotationProcessor

ClientSession - Interface in org.cometd.bayeux.client

This interface represents the client side Bayeux session.

ClientSession.Extension - Interface in org.cometd.bayeux.client

Extension API for client session.

ClientSession.MessageListener - Interface in org.cometd.bayeux.client

A listener for remote call messages.

ClientSessionChannel - Interface in org.cometd.bayeux.client

A client side channel representation.

ClientSessionChannel.ClientSessionChannelListener - Interface in org.cometd.bayeux.client

Represents a listener on a ClientSessionChannel.

ClientSessionChannel.MessageListener - Interface in org.cometd.bayeux.client

A listener for messages on a ClientSessionChannel.

ClientTransport - Class in org.cometd.client.transport

ClientTransports are used by BayeuxClient to send and receive Bayeux messages.

ClientTransport(String, String, Map<String, Object>) - Constructor for class org.cometd.client.transport.ClientTransport

Deprecated.

ClientTransport(String, String, Map<String, Object>, ScheduledExecutorService) - Constructor for class org.cometd.client.transport.ClientTransport

ClientTransport.Factory - Interface in org.cometd.client.transport

ClientTransport.FailureHandler - Interface in org.cometd.client.transport

ClientTransport.FailureInfo - Class in org.cometd.client.transport

close() - Method in class org.cometd.client.websocket.common.AbstractWebSocketTransport.Delegate

close() - Method in class org.cometd.client.websocket.javax.WebSocketTransport.WebSocketDelegate

close() - Method in class org.cometd.client.websocket.jetty.JettyWebSocketTransport.JettyWebSocketDelegate

close() - Method in class org.cometd.client.websocket.okhttp.OkHttpWebSocketTransport.OkHttpDelegate

close(int, String) - Method in class org.cometd.server.websocket.common.AbstractWebSocketEndPoint

close(int, String) - Method in class org.cometd.server.websocket.jetty.JettyWebSocketEndPoint

CloudListener() - Constructor for class org.cometd.oort.Oort.CloudListener

COMETD_URL_MAPPING_OPTION - Static variable in class org.cometd.server.websocket.common.AbstractWebSocketTransport

CometDDemo - Class in org.cometd.examples

Main class for CometD demo.

CometDDemo() - Constructor for class org.cometd.examples.CometDDemo

CometDDemoServlet - Class in org.cometd.examples

CometDDemoServlet() - Constructor for class org.cometd.examples.CometDDemoServlet

CometDDemoServlet.EchoRPC - Class in org.cometd.examples

CometDDemoServlet.Monitor - Class in org.cometd.examples

CometDLoadClient - Class in org.cometd.benchmark.client

CometDLoadClient() - Constructor for class org.cometd.benchmark.client.CometDLoadClient

CometDLoadServer - Class in org.cometd.benchmark.server

CometDLoadServer() - Constructor for class org.cometd.benchmark.server.CometDLoadServer

CometDLoadServer.StatisticsService - Class in org.cometd.benchmark.server

CometDServlet - Class in org.cometd.server

The CometD Servlet maps HTTP requests to the AbstractHttpTransport of a BayeuxServer instance.

CometDServlet() - Constructor for class org.cometd.server.CometDServlet

cometJoined(Oort.CometListener.Event) - Method in interface org.cometd.oort.Oort.CometListener

Callback method invoked when a new comet joins the cloud

cometJoined(Oort.CometListener.Event) - Method in class org.cometd.oort.OortObject

cometLeft(Oort.CometListener.Event) - Method in interface org.cometd.oort.Oort.CometListener

Callback method invoked when a comet leaves the cloud

cometLeft(Oort.CometListener.Event) - Method in class org.cometd.oort.OortContainer

cometLeft(Oort.CometListener.Event) - Method in class org.cometd.oort.OortObject

compareAndSet(long, long) - Method in class org.cometd.oort.OortLong

Completable() - Constructor for class org.cometd.bayeux.Promise.Completable

complete() - Method in interface org.cometd.bayeux.Promise

Returns a BiConsumer that, when invoked, completes this Promise.

complete() - Method in class org.cometd.common.BufferingJSONAsyncParser

complete() - Method in class org.cometd.common.JettyJSONContext.AsyncJSONParser

complete() - Method in interface org.cometd.common.JSONContext.AsyncParser

Signals the end of the JSON string content to this parser and returns the parsed object.

complete(BiConsumer<T, Throwable>) - Static method in interface org.cometd.bayeux.Promise

Returns a Promise that, when completed, invokes the given BiConsumer function.

concurrentMapUnion() - Static method in class org.cometd.oort.OortObjectMergers

Config - Class in org.cometd.benchmark

ConfigurableServerChannel - Interface in org.cometd.bayeux.server

A ConfigurableServerChannel offers an API that can be used to configure ServerChannels at creation time.

ConfigurableServerChannel.Initializer - Interface in org.cometd.bayeux.server

A listener interface by means of which listeners can atomically set the initial configuration of a channel.

ConfigurableServerChannel.Initializer.Persistent - Class in org.cometd.bayeux.server

Utility class that initializes channels to be persistent

ConfigurableServerChannel.ServerChannelListener - Interface in org.cometd.bayeux.server

Common interface for ServerChannel listeners.

ConfigurableServerChannel.ServerChannelListener.Weak - Interface in org.cometd.bayeux.server

Tag interface that marks ConfigurableServerChannel.ServerChannelListeners as "weak".

Configure - Annotation Type in org.cometd.annotation.server

For server-side services, identifies channel configuration methods that are invoked when a message is processed on server-side.

configureChannel(ConfigurableServerChannel) - Method in interface org.cometd.bayeux.server.ConfigurableServerChannel.Initializer

Callback invoked when a channel is created and needs to be configured

configureChannel(ConfigurableServerChannel) - Method in class org.cometd.bayeux.server.ConfigurableServerChannel.Initializer.Persistent

configureChannel(ConfigurableServerChannel) - Method in class org.cometd.oort.OortObject

Configures the channel used by this oort object.

configureChatStarStar(ConfigurableServerChannel) - Method in class org.cometd.examples.ChatService

configureCloud(ServletConfig, Oort) - Method in class org.cometd.oort.OortConfigServlet

Configures the Oort cloud by establishing connections with other Oort comets.

configureCloud(ServletConfig, Oort) - Method in class org.cometd.oort.OortMulticastConfigServlet

configureCloud(ServletConfig, Oort) - Method in class org.cometd.oort.OortStaticConfigServlet

configureIfExists() - Method in annotation type org.cometd.annotation.server.Configure

configureMembers(ConfigurableServerChannel) - Method in class org.cometd.examples.ChatService

configureOort(ServletConfig, Oort) - Method in class org.cometd.oort.OortConfigServlet

Configures the Oort instance with servlet init parameters.

configureOortComet(OortComet) - Method in class org.cometd.oort.Oort

configurePrivateChat(ConfigurableServerChannel) - Method in class org.cometd.examples.ChatService

connect(WebSocketContainer, ClientEndpointConfig, String) - Method in class org.cometd.client.websocket.javax.WebSocketTransport

connect(String, TransportListener, List<Message.Mutable>) - Method in class org.cometd.client.websocket.common.AbstractWebSocketTransport

connect(String, TransportListener, List<Message.Mutable>) - Method in class org.cometd.client.websocket.javax.WebSocketTransport

connect(String, TransportListener, List<Message.Mutable>) - Method in class org.cometd.client.websocket.jetty.JettyWebSocketTransport

connect(String, TransportListener, List<Message.Mutable>) - Method in class org.cometd.client.websocket.okhttp.OkHttpWebSocketTransport

connect(WebSocketClient, ClientUpgradeRequest, String) - Method in class org.cometd.client.websocket.jetty.JettyWebSocketTransport

CONNECT_TIMEOUT_OPTION - Static variable in class org.cometd.client.websocket.common.AbstractWebSocketTransport

connectComet(OortComet, Map<String, Object>) - Method in class org.cometd.oort.Oort

connected() - Method in class org.cometd.server.ServerSessionImpl

CONNECTED - org.cometd.client.BayeuxClient.State

State assumed when this BayeuxClient is connected to the Bayeux server

CONNECTING - org.cometd.client.BayeuxClient.State

State assumed when the connect is being sent for the first time

CONNECTION_TYPE_FIELD - Static variable in interface org.cometd.bayeux.Message

ConsoleChatClient - Class in org.cometd.examples

ConsoleChatClient() - Constructor for class org.cometd.examples.ConsoleChatClient

Constant(long) - Constructor for class org.cometd.client.BayeuxClient.BackOffStrategy.Constant

contains(E) - Method in class org.cometd.oort.OortList

Returns whether the given element is present in the local entity list of this node.

contains(Object) - Method in class org.cometd.server.ext.BatchArrayQueue

containsAll(Collection<?>) - Method in class org.cometd.server.ext.BatchArrayQueue

Context(HttpServletRequest, HttpServletResponse) - Constructor for class org.cometd.server.http.AbstractHttpTransport.Context

CONTEXT_PATH - Static variable in class org.cometd.benchmark.Config

convert(long) - Method in class org.cometd.benchmark.client.CometDLoadClient

COOKIE_HEADER - Static variable in class org.cometd.client.websocket.common.AbstractWebSocketTransport

CookieParser - Class in org.cometd.server.websocket.common

A parser for "Cookie" headers.

CREATE - org.cometd.bayeux.server.Authorizer.Operation

The operation to create a channel that does not exist

createChannelIfAbsent(String, ConfigurableServerChannel.Initializer...) - Method in interface org.cometd.bayeux.server.BayeuxServer

Creates a ServerChannel and initializes it atomically if the channel does not exist, or returns it if it already exists.

createChannelIfAbsent(String, ConfigurableServerChannel.Initializer...) - Method in class org.cometd.server.BayeuxServerImpl

createReply(ServerMessage.Mutable) - Method in class org.cometd.server.BayeuxServerImpl

current() - Method in class org.cometd.client.BayeuxClient.BackOffStrategy.Constant

current() - Method in interface org.cometd.client.BayeuxClient.BackOffStrategy

current() - Method in class org.cometd.client.BayeuxClient.BackOffStrategy.Linear

customize(Request.Builder, Promise<Request.Builder>) - Method in class org.cometd.client.http.okhttp.OkHttpClientTransport

customize(Request) - Method in class org.cometd.client.http.jetty.JettyHttpClientTransport

customize(Request, Promise<Request>) - Method in class org.cometd.client.http.jetty.JettyHttpClientTransport

D

Data(int, OortObject.Result<T>) - Constructor for class org.cometd.oort.OortObject.Data

DATA - Static variable in class org.cometd.bayeux.BinaryData

DATA_FIELD - Static variable in interface org.cometd.bayeux.Message

DataFilter - Interface in org.cometd.server.filter

A filter that can add, modify or remove fields from the message data.

DataFilter.AbortException - Exception in org.cometd.server.filter

Aborts the filtering of the message data.

DataFilterMessageListener - Class in org.cometd.server.filter

A MessageListener that applies DataFilters to the received messages.

DataFilterMessageListener(BayeuxServer, DataFilter...) - Constructor for class org.cometd.server.filter.DataFilterMessageListener

DataFilterMessageListener(DataFilter...) - Constructor for class org.cometd.server.filter.DataFilterMessageListener

decBrowserId(ServerSessionImpl, boolean) - Method in class org.cometd.server.http.AbstractHttpTransport

decodeByteBuffer(String) - Method in class org.cometd.common.Z85.Decoder

decodeBytes(String) - Method in class org.cometd.common.Z85.Decoder

decoder - Static variable in class org.cometd.common.Z85

Decoder() - Constructor for class org.cometd.common.Z85.Decoder

decrement(AtomicStampedReference<T>) - Static method in class org.cometd.benchmark.Atomics

DEEPWILD - Static variable in class org.cometd.bayeux.ChannelId

DefaultSecurityPolicy - Class in org.cometd.server

DefaultSecurityPolicy() - Constructor for class org.cometd.server.DefaultSecurityPolicy

Deferred() - Constructor for class org.cometd.oort.OortObject.Result.Deferred

delay - Variable in class org.cometd.client.transport.ClientTransport.FailureInfo

Delegate() - Constructor for class org.cometd.client.websocket.common.AbstractWebSocketTransport.Delegate

deliver(Session, String, Object, Promise<Boolean>) - Method in interface org.cometd.bayeux.server.ServerSession

Delivers the given information to this session.

deliver(Session, String, Object, Promise<Boolean>) - Method in class org.cometd.server.ServerSessionImpl

deliver(Session, ServerMessage.Mutable, Promise<Boolean>) - Method in interface org.cometd.bayeux.server.ServerSession

Delivers the given message to this session.

deliver(Session, ServerMessage.Mutable, Promise<Boolean>) - Method in class org.cometd.server.ServerSessionImpl

deliver1(ServerSession, ServerMessage.Mutable, Promise<Boolean>) - Method in class org.cometd.server.ServerSessionImpl

DeltaListener(OortList<E>) - Constructor for class org.cometd.oort.OortList.DeltaListener

DeltaListener(OortMap<K, V>) - Constructor for class org.cometd.oort.OortMap.DeltaListener

deny(String) - Static method in class org.cometd.bayeux.server.Authorizer.Result

deobserveChannel(String) - Method in class org.cometd.oort.Oort

deobserveComet(String) - Method in class org.cometd.oort.Oort

deprocess(Object) - Method in class org.cometd.annotation.client.ClientAnnotationProcessor

Performs the opposite processing done by ClientAnnotationProcessor.process(Object) on callbacks methods annotated with Listener and Subscription, and on lifecycle methods annotated with PreDestroy.

deprocess(Object) - Method in class org.cometd.annotation.server.ServerAnnotationProcessor

Performs the opposite processing done by ServerAnnotationProcessor.process(Object) on callbacks methods annotated with Listener, Subscription and RemoteCall, and on lifecycle methods annotated with PreDestroy.

deprocessCallbacks(Object) - Method in class org.cometd.annotation.client.ClientAnnotationProcessor

Performs the opposite processing done by ClientAnnotationProcessor.processCallbacks(Object) on callback methods annotated with Listener and Subscription.

deprocessCallbacks(Object) - Method in class org.cometd.annotation.server.ServerAnnotationProcessor

Performs the opposite processing done by ServerAnnotationProcessor.processCallbacks(Object) on callback methods annotated with Listener, Subscription and RemoteCall.

deprocessService(ServerAnnotationProcessor, Object) - Method in class org.cometd.annotation.server.AnnotationCometDServlet

depth() - Method in class org.cometd.bayeux.ChannelId

deQueue(ServerSession, Queue<ServerMessage>) - Method in interface org.cometd.bayeux.server.ServerSession.DeQueueListener

Callback invoked to notify that the queue of messages is about to be sent to the remote client.

deQueue(ServerSession, Queue<ServerMessage>) - Method in class org.cometd.server.ext.AcknowledgedMessagesSessionExtension

deQueue(ServerSession, Queue<ServerMessage>, List<ServerMessage.Mutable>) - Method in interface org.cometd.bayeux.server.ServerSession.DeQueueListener

Callback invoked to notify that the queue of messages and the message replies are about to be sent to the remote client.

deQueue(ServerSession, Queue<ServerMessage>, List<ServerMessage.Mutable>) - Method in class org.cometd.server.ext.AcknowledgedMessagesSessionExtension

deregisterService(Object) - Method in class org.cometd.annotation.server.AnnotationCometDServlet

deserialize(Object) - Method in class org.cometd.oort.OortLongMap

deserialize(Object) - Method in class org.cometd.oort.OortObject

destroy() - Method in class org.cometd.annotation.server.AnnotationCometDServlet

destroy() - Method in class org.cometd.oort.OortConfigServlet

destroy() - Method in class org.cometd.oort.OortMulticastConfigServlet

destroy() - Method in class org.cometd.oort.SetiServlet

destroy() - Method in class org.cometd.server.AbstractServerTransport

destroy() - Method in interface org.cometd.server.AbstractServerTransport.Scheduler

Invoked when the transport wants to abort communication.

destroy() - Method in class org.cometd.server.CometDServlet

destroy() - Method in class org.cometd.server.http.AbstractHttpTransport.LongPollScheduler

destroyScheduler() - Method in class org.cometd.server.ServerSessionImpl

disassociate(String) - Method in class org.cometd.oort.Seti

Disassociates the given userId from all sessions.

disassociate(String, ServerSession) - Method in class org.cometd.oort.Seti

Disassociates the given userId from the given session.

disassociate(String, Seti.Location) - Method in class org.cometd.oort.Seti

disconnect() - Method in interface org.cometd.bayeux.client.ClientSession

disconnect() - Method in interface org.cometd.bayeux.Session

Disconnects this session, ending the link between the client and the server peers.

disconnect() - Method in class org.cometd.server.ServerSessionImpl

disconnect(long) - Method in class org.cometd.client.BayeuxClient

Performs a disconnect and uses the given timeout to wait for the disconnect to complete.

disconnect(ClientSession.MessageListener) - Method in interface org.cometd.bayeux.client.ClientSession

Disconnects this session, ending the link between the client and the server peers.

disconnect(ClientSession.MessageListener) - Method in class org.cometd.client.BayeuxClient

disconnect(ClientSession.MessageListener) - Method in class org.cometd.server.LocalSessionImpl

disconnect(ServerSession) - Method in class org.cometd.server.ext.ActivityExtension.SessionExtension

disconnectClient(CometDLoadClient.LoadBayeuxClient) - Method in class org.cometd.benchmark.client.CometDLoadClient

DISCONNECTED - org.cometd.client.BayeuxClient.State

State assumed before the handshake and when the disconnect is completed

DISCONNECTING - org.cometd.client.BayeuxClient.State

State assumed when the disconnect is being sent

dispatch(boolean) - Method in class org.cometd.server.http.AbstractHttpTransport.LongPollScheduler

dispatch(boolean) - Method in class org.cometd.server.http.AbstractStreamHttpTransport.DispatchingLongPollScheduler

DispatchingLongPollScheduler(AbstractHttpTransport.Context, Promise<Void>, ServerMessage.Mutable, long) - Constructor for class org.cometd.server.http.AbstractStreamHttpTransport.DispatchingLongPollScheduler

doEcho(RemoteCall.Caller, Object) - Method in class org.cometd.examples.CometDDemoServlet.EchoRPC

doInvoke(Method, ServerSession, ServerMessage) - Method in class org.cometd.server.AbstractService

doStart() - Method in class org.cometd.oort.Oort

doStart() - Method in class org.cometd.oort.OortLong

doStart() - Method in class org.cometd.oort.OortMulticastConfigurer

doStart() - Method in class org.cometd.oort.OortObject

doStart() - Method in class org.cometd.oort.OortPrimaryService

doStart() - Method in class org.cometd.oort.OortService

doStart() - Method in class org.cometd.oort.Seti

doStart() - Method in class org.cometd.server.BayeuxServerImpl

doStop() - Method in class org.cometd.oort.Oort

doStop() - Method in class org.cometd.oort.OortContainer

doStop() - Method in class org.cometd.oort.OortLong

doStop() - Method in class org.cometd.oort.OortMulticastConfigurer

doStop() - Method in class org.cometd.oort.OortObject

doStop() - Method in class org.cometd.oort.OortPrimaryService

doStop() - Method in class org.cometd.oort.OortService

doStop() - Method in class org.cometd.oort.Seti

doStop() - Method in class org.cometd.server.BayeuxServerImpl

dump(Appendable, String) - Method in class org.cometd.common.AbstractClientSession.AbstractSessionChannel

dump(Appendable, String) - Method in class org.cometd.common.AbstractClientSession

dump(Appendable, String) - Method in class org.cometd.oort.Oort

dump(Appendable, String) - Method in class org.cometd.oort.OortObject

dump(Appendable, String) - Method in class org.cometd.oort.Seti

dump(Appendable, String) - Method in class org.cometd.server.AbstractServerTransport

dump(Appendable, String) - Method in class org.cometd.server.BayeuxServerImpl

dump(Appendable, String) - Method in class org.cometd.server.ServerChannelImpl

dump(Appendable, String) - Method in class org.cometd.server.ServerSessionImpl

dumpSelf() - Method in class org.cometd.common.AbstractClientSession.AbstractSessionChannel

DUPLICATE_META_CONNECT_HTTP_RESPONSE_CODE_OPTION - Static variable in class org.cometd.server.http.AbstractHttpTransport

E

EchoRPC() - Constructor for class org.cometd.examples.CometDDemoServlet.EchoRPC

element() - Method in class org.cometd.server.ext.BatchArrayQueue

empty() - Static method in class org.cometd.bayeux.MarkedReference

ENABLE_EXTENSION_PREFIX_OPTION - Static variable in class org.cometd.server.websocket.common.AbstractWebSocketTransport

encodeByteBuffer(ByteBuffer) - Method in class org.cometd.common.Z85.Encoder

encodeBytes(byte[]) - Method in class org.cometd.common.Z85.Encoder

encoder - Static variable in class org.cometd.common.Z85

Encoder() - Constructor for class org.cometd.common.Z85.Encoder

encodeSecret(String) - Method in class org.cometd.oort.Oort

endBatch() - Method in interface org.cometd.bayeux.Session

Ends a batch started with Session.startBatch().

endBatch() - Method in class org.cometd.common.AbstractClientSession

endBatch() - Method in class org.cometd.server.ServerSessionImpl

EndPoint(BayeuxContext) - Constructor for class org.cometd.server.websocket.javax.WebSocketTransport.EndPoint

EndPoint(BayeuxContext) - Constructor for class org.cometd.server.websocket.jetty.JettyWebSocketTransport.EndPoint

endWrite(HttpServletResponse, ServletOutputStream) - Method in class org.cometd.server.http.AbstractStreamHttpTransport

endWrite(HttpServletResponse, ServletOutputStream) - Method in class org.cometd.server.http.JSONPTransport

endWrite(HttpServletResponse, ServletOutputStream) - Method in class org.cometd.server.http.JSONTransport

enqueueSend(Message.Mutable) - Method in class org.cometd.client.BayeuxClient

Entry(K, V, V) - Constructor for class org.cometd.oort.OortMap.Entry

entrySet() - Method in class org.cometd.server.ServerMessageImpl

equals(Object) - Method in class org.cometd.bayeux.ChannelId

equals(Object) - Method in class org.cometd.oort.Seti.LocalLocation

equals(Object) - Method in interface org.cometd.oort.Seti.Location

equals(Object) - Method in class org.cometd.oort.Seti.SetiLocation

error - Variable in class org.cometd.client.transport.ClientTransport.FailureInfo

error(ServerMessage.Mutable, String) - Method in class org.cometd.server.BayeuxServerImpl

ERROR_FIELD - Static variable in interface org.cometd.bayeux.Message

errorIfExists() - Method in annotation type org.cometd.annotation.server.Configure

Event(Oort, String, String) - Constructor for class org.cometd.oort.Oort.CometListener.Event

Event(Seti, String, String) - Constructor for class org.cometd.oort.Seti.PresenceListener.Event

exception(String, ServerSession, LocalSession, ServerMessage, Throwable) - Method in class org.cometd.server.AbstractService

Handles exceptions during the invocation of a mapped method.

execute(Runnable) - Method in class org.cometd.benchmark.MonitoringQueuedThreadPool

execute(Runnable) - Method in class org.cometd.benchmark.MonitoringThreadPoolExecutor

execute(Runnable) - Method in class org.cometd.server.BayeuxServerImpl

EXECUTOR_MAX_THREADS - Static variable in class org.cometd.server.BayeuxServerImpl

exit(ServerSession, ServerMessage) - Method in class org.cometd.benchmark.server.CometDLoadServer.StatisticsService

exportMessagesToBatch(Queue<T>, long) - Method in class org.cometd.server.ext.BatchArrayQueue

EXT_COMET_URL_FIELD - Static variable in class org.cometd.oort.Oort

EXT_FIELD - Static variable in interface org.cometd.bayeux.Message

EXT_NAME - Static variable in class org.cometd.bayeux.BinaryData

EXT_OORT_ALIAS_URL_FIELD - Static variable in class org.cometd.oort.Oort

EXT_OORT_FIELD - Static variable in class org.cometd.oort.Oort

EXT_OORT_ID_FIELD - Static variable in class org.cometd.oort.Oort

EXT_OORT_SECRET_FIELD - Static variable in class org.cometd.oort.Oort

EXT_OORT_URL_FIELD - Static variable in class org.cometd.oort.Oort

extendIncoming(Message.Mutable, Promise<Boolean>) - Method in class org.cometd.common.AbstractClientSession

extendIncoming(ServerMessage.Mutable, Promise<Boolean>) - Method in class org.cometd.server.ServerSessionImpl

extendOutgoing(Message.Mutable, Promise<Boolean>) - Method in class org.cometd.common.AbstractClientSession

extendOutgoing(ServerSession, ServerMessage.Mutable, Promise<ServerMessage.Mutable>) - Method in class org.cometd.server.ServerSessionImpl

extendOutgoing(ServerSession, ServerSession, ServerMessage.Mutable, Promise<Boolean>) - Method in class org.cometd.server.BayeuxServerImpl

extendReply(ServerSessionImpl, ServerSessionImpl, ServerMessage.Mutable, Promise<ServerMessage.Mutable>) - Method in class org.cometd.server.BayeuxServerImpl

F

Factory() - Constructor for class org.cometd.client.http.jetty.JettyHttpClientTransport.Factory

Factory() - Constructor for class org.cometd.client.http.okhttp.OkHttpClientTransport.Factory

Factory() - Constructor for class org.cometd.client.websocket.javax.WebSocketTransport.Factory

Factory() - Constructor for class org.cometd.client.websocket.jetty.JettyWebSocketTransport.Factory

Factory() - Constructor for class org.cometd.client.websocket.okhttp.OkHttpWebSocketTransport.Factory

Factory(OkHttpClient) - Constructor for class org.cometd.client.http.okhttp.OkHttpClientTransport.Factory

Factory(OkHttpClient) - Constructor for class org.cometd.client.websocket.okhttp.OkHttpWebSocketTransport.Factory

Factory(HttpClient) - Constructor for class org.cometd.client.http.jetty.JettyHttpClientTransport.Factory

Factory(WebSocketClient) - Constructor for class org.cometd.client.websocket.jetty.JettyWebSocketTransport.Factory

fail(Throwable) - Method in class org.cometd.bayeux.Promise.Completable

fail(Throwable) - Method in interface org.cometd.bayeux.Promise

Callback to invoke when the operation fails.

fail(Throwable) - Method in interface org.cometd.common.AsyncFoldLeft.Loop

Makes the loop fail (similarly to throwing an exception).

fail(Throwable, String) - Method in class org.cometd.client.websocket.common.AbstractWebSocketTransport.Delegate

failed(Object) - Method in interface org.cometd.oort.OortPrimaryLong.Callback

Callback method invoked when the operation on the counter failed.

failMessages(Throwable) - Method in class org.cometd.client.websocket.common.AbstractWebSocketTransport.Delegate

failure(Object) - Method in interface org.cometd.annotation.server.RemoteCall.Caller

Returns the given failure to the remote caller.

failure(Object) - Static method in class org.cometd.oort.OortService.Result

Returns a failed OortService.Result containing the given failure object.

FailureInfo() - Constructor for class org.cometd.client.transport.ClientTransport.FailureInfo

filter(ServerSession, ServerChannel, Object) - Method in interface org.cometd.server.filter.DataFilter

Modifies the given message data.

filter(ServerSession, ServerChannel, Object) - Method in class org.cometd.server.filter.JSONDataFilter

filterArray(ServerSession, ServerChannel, Object) - Method in class org.cometd.server.filter.JSONDataFilter

filterBoolean(ServerSession, ServerChannel, Boolean) - Method in class org.cometd.server.filter.JSONDataFilter

filterCollection(ServerSession, ServerChannel, Collection<Object>) - Method in class org.cometd.server.filter.JSONDataFilter

filterList(ServerSession, ServerChannel, List<Object>) - Method in class org.cometd.server.filter.JSONDataFilter

filterMap(ServerSession, ServerChannel, Map<String, Object>) - Method in class org.cometd.server.filter.JSONDataFilter

filterNumber(ServerSession, ServerChannel, Number) - Method in class org.cometd.server.filter.JSONDataFilter

filterObject(ServerSession, ServerChannel, Object) - Method in class org.cometd.server.filter.JSONDataFilter

filterString(ServerSession, ServerChannel, String) - Method in class org.cometd.server.filter.JSONDataFilter

filterString(ServerSession, ServerChannel, String) - Method in class org.cometd.server.filter.NoMarkupFilter

filterString(ServerSession, ServerChannel, String) - Method in class org.cometd.server.filter.NoScriptsFilter

filterString(ServerSession, ServerChannel, String) - Method in class org.cometd.server.filter.RegexFilter

find(K) - Method in class org.cometd.oort.OortMap

Returns the first non-null value mapped to the given key from the entity maps of all nodes.

findAnnotatedMethods(Object, Class<? extends Annotation>) - Method in class org.cometd.annotation.AnnotationProcessor

findBrowserId(AbstractHttpTransport.Context) - Method in class org.cometd.server.http.AbstractHttpTransport

findComet(String) - Method in class org.cometd.oort.Oort

findCurrentSessions(HttpServletRequest) - Method in class org.cometd.server.http.AbstractHttpTransport

findHttpTransport(HttpServletRequest) - Method in class org.cometd.server.BayeuxServerImpl

findInfo(K) - Method in class org.cometd.oort.OortMap

findSession(Collection<ServerSessionImpl>, ServerMessage.Mutable) - Method in class org.cometd.server.http.AbstractHttpTransport

finish(String) - Method in class org.cometd.server.http.AsyncJSONTransport.AbstractReader

finish(List<ServerMessage.Mutable>) - Method in class org.cometd.server.http.AsyncJSONTransport.AbstractReader

flush() - Method in class org.cometd.server.ServerSessionImpl

flush(AbstractHttpTransport.Context, Promise<Void>) - Method in class org.cometd.server.http.AbstractHttpTransport

flush(AbstractWebSocketEndPoint.Context, Promise<Void>) - Method in class org.cometd.server.websocket.common.AbstractWebSocketEndPoint

forBoolean(boolean) - Static method in class org.cometd.oort.OortObjectFactories

forConcurrentList() - Static method in class org.cometd.oort.OortObjectFactories

forConcurrentList(List<E>) - Static method in class org.cometd.oort.OortObjectFactories

forConcurrentMap() - Static method in class org.cometd.oort.OortObjectFactories

forConcurrentMap(Map<K, V>) - Static method in class org.cometd.oort.OortObjectFactories

forLong(long) - Static method in class org.cometd.oort.OortObjectFactories

forMap() - Static method in class org.cometd.oort.OortObjectFactories

forMap(Map<K, V>) - Static method in class org.cometd.oort.OortObjectFactories

forString(String) - Static method in class org.cometd.oort.OortObjectFactories

forward(String, Object, C) - Method in class org.cometd.oort.OortService

Subclasses must call this method to forward the action to the owner node.

freeze(String) - Method in class org.cometd.server.ServerMessageImpl

freeze(ServerMessage.Mutable) - Method in class org.cometd.server.BayeuxServerImpl

from(Consumer<T>, Consumer<Throwable>) - Static method in interface org.cometd.bayeux.Promise

G

generate(Object) - Method in class org.cometd.common.JacksonJSONContext.ObjectMapperGenerator

generate(Object) - Method in class org.cometd.common.JettyJSONContext.JSONGenerator

generate(Object) - Method in interface org.cometd.common.JSONContext.Generator

generate(List<M>) - Method in class org.cometd.common.JacksonJSONContext

generate(List<M>) - Method in class org.cometd.common.JettyJSONContext

generate(List<T>) - Method in interface org.cometd.common.JSONContext

Converts a list of messages to a JSON string.

generate(M) - Method in class org.cometd.common.JacksonJSONContext

generate(M) - Method in class org.cometd.common.JettyJSONContext

generate(ServerMessage.Mutable) - Method in class org.cometd.server.JacksonJSONContextServer

generate(ServerMessage.Mutable) - Method in class org.cometd.server.JettyJSONContextServer

generate(ServerMessage.Mutable) - Method in interface org.cometd.server.JSONContextServer

generate(T) - Method in interface org.cometd.common.JSONContext

Converts a single message to a JSON string.

generateJSON(List<Message.Mutable>) - Method in class org.cometd.client.transport.ClientTransport

generateSetiChannel(String) - Method in class org.cometd.oort.Seti

generateSetiId(String) - Method in class org.cometd.oort.Seti

get() - Method in class org.cometd.oort.OortLong

get(long, TimeUnit) - Method in class org.cometd.oort.OortObject.Result.Deferred

Waits for the result to be available for the specified amount of time.

get(K) - Method in class org.cometd.oort.OortMap

Returns the value mapped to the given key from the local entity map of this node.

get(OortPrimaryLong.Callback) - Method in class org.cometd.oort.OortPrimaryLong

Retrieves the value from the "primary" node and then invokes the given callback with the result value.

getAccuracyTarget() - Method in class org.cometd.server.ext.TimesyncExtension

timesync responses are not set if the measured accuracy is less than the accuracyTarget.

getActivity() - Method in class org.cometd.server.ext.ActivityExtension

getAdvertiseInterval() - Method in class org.cometd.oort.OortMulticastConfigurer

getAdvice() - Method in interface org.cometd.bayeux.Message

Convenience method to retrieve the Message.ADVICE_FIELD

getAdvice() - Method in class org.cometd.client.http.common.AbstractHttpClientTransport

getAdvice() - Method in class org.cometd.common.HashMapMessage

getAdvice() - Method in class org.cometd.server.ServerMessageImpl

getAdvice(boolean) - Method in interface org.cometd.bayeux.Message.Mutable

Convenience method to retrieve the Message.ADVICE_FIELD and create it if it does not exist

getAdvice(boolean) - Method in class org.cometd.common.HashMapMessage

getAllIds() - Method in class org.cometd.bayeux.ChannelId

getAllowedTransports() - Method in interface org.cometd.bayeux.Bayeux

getAllowedTransports() - Method in class org.cometd.client.BayeuxClient

getAllowedTransports() - Method in class org.cometd.client.transport.TransportRegistry

getAllowedTransports() - Method in class org.cometd.server.BayeuxServerImpl

getAndAdd(long) - Method in class org.cometd.oort.OortLong

getAndAdd(long, OortPrimaryLong.Callback) - Method in class org.cometd.oort.OortPrimaryLong

Adds the given delta and then invokes the given callback with the counter value before the addition.

getAndSet(long) - Method in class org.cometd.oort.OortLong

getAssociated() - Method in interface org.cometd.bayeux.server.ServerMessage

getAssociated() - Method in class org.cometd.server.ServerMessageImpl

getAssociatedUserIds() - Method in class org.cometd.oort.Seti

getAssociationCount(String) - Method in class org.cometd.oort.Seti

getAsyncContext(HttpServletRequest) - Method in class org.cometd.server.http.AbstractHttpTransport

getAsyncJSONFactory() - Method in class org.cometd.common.JettyJSONContext

getAttribute(String) - Method in interface org.cometd.bayeux.Channel

Retrieves the value of named channel attribute.

getAttribute(String) - Method in interface org.cometd.bayeux.Session

Retrieves the value of named session attribute.

getAttribute(String) - Method in class org.cometd.common.AbstractClientSession.AbstractSessionChannel

getAttribute(String) - Method in class org.cometd.common.AbstractClientSession

getAttribute(String) - Method in class org.cometd.server.ServerChannelImpl

getAttribute(String) - Method in class org.cometd.server.ServerSessionImpl

getAttributeNames() - Method in interface org.cometd.bayeux.Channel

getAttributeNames() - Method in interface org.cometd.bayeux.Session

getAttributeNames() - Method in class org.cometd.common.AbstractClientSession.AbstractSessionChannel

getAttributeNames() - Method in class org.cometd.common.AbstractClientSession

getAttributeNames() - Method in class org.cometd.server.ServerChannelImpl

getAttributeNames() - Method in class org.cometd.server.ServerSessionImpl

getAuthorizers() - Method in interface org.cometd.bayeux.server.ConfigurableServerChannel

getAuthorizers() - Method in class org.cometd.server.ServerChannelImpl

getAverageQueueLatency() - Method in class org.cometd.benchmark.MonitoringQueuedThreadPool

getAverageQueueLatency() - Method in class org.cometd.benchmark.MonitoringThreadPoolExecutor

getAverageTaskLatency() - Method in class org.cometd.benchmark.MonitoringQueuedThreadPool

getAverageTaskLatency() - Method in class org.cometd.benchmark.MonitoringThreadPoolExecutor

getBackOffStrategy() - Method in class org.cometd.client.BayeuxClient

getBatch() - Method in class org.cometd.server.ext.BatchArrayQueue

getBayeux() - Method in class org.cometd.server.AbstractServerTransport

getBayeux() - Method in class org.cometd.server.AbstractService

getBayeux() - Method in class org.cometd.server.CometDServlet

getBayeuxContext() - Method in interface org.cometd.bayeux.server.ServerMessage

getBayeuxContext() - Method in class org.cometd.server.ServerMessageImpl

getBayeuxServer() - Method in class org.cometd.oort.Oort

getBayeuxServer() - Method in class org.cometd.server.ServerSessionImpl

getBindAddress() - Method in class org.cometd.oort.OortMulticastConfigurer

getBrowserId() - Method in class org.cometd.server.ServerSessionImpl

getCallbackParameter() - Method in class org.cometd.server.http.JSONPTransport

getChannel() - Method in interface org.cometd.bayeux.Message

Convenience method to retrieve the Message.CHANNEL_FIELD.

getChannel() - Method in class org.cometd.common.HashMapMessage

getChannel(String) - Method in interface org.cometd.bayeux.client.ClientSession

Returns a client side channel scoped by this session.

getChannel(String) - Method in interface org.cometd.bayeux.server.BayeuxServer

getChannel(String) - Method in class org.cometd.common.AbstractClientSession

getChannel(String) - Method in class org.cometd.server.BayeuxServerImpl

getChannel(ChannelId) - Method in class org.cometd.common.AbstractClientSession

getChannelCount() - Method in class org.cometd.server.jmx.BayeuxServerImplMBean

getChannelId() - Method in interface org.cometd.bayeux.Channel

getChannelId() - Method in interface org.cometd.bayeux.Message

Convenience method to retrieve the Message.CHANNEL_FIELD.

getChannelId() - Method in class org.cometd.common.AbstractClientSession.AbstractSessionChannel

getChannelId() - Method in class org.cometd.common.HashMapMessage

getChannelId() - Method in class org.cometd.server.ServerChannelImpl

getChannelName() - Method in class org.cometd.oort.OortObject

Returns the channel name used by this oort object for communication with other oort objects in other nodes.

getChannels() - Method in interface org.cometd.bayeux.server.BayeuxServer

getChannels() - Method in class org.cometd.common.AbstractClientSession

getChannels() - Method in class org.cometd.server.BayeuxServerImpl

getClientId() - Method in interface org.cometd.bayeux.Message

Convenience method to retrieve the Message.CLIENT_ID_FIELD

getClientId() - Method in class org.cometd.common.HashMapMessage

getClientTransportFactories() - Method in class org.cometd.oort.Oort

getComet(String) - Method in class org.cometd.oort.Oort

getCometId() - Method in class org.cometd.oort.Oort.CometListener.Event

getCometURL() - Method in class org.cometd.oort.Oort.CometListener.Event

getConnectTimeout() - Method in class org.cometd.client.websocket.common.AbstractWebSocketTransport

getConnectTimeout() - Method in class org.cometd.oort.OortMulticastConfigurer

getContext() - Method in class org.cometd.server.http.AbstractHttpTransport.LongPollScheduler

getContextAttribute(String) - Method in interface org.cometd.bayeux.server.BayeuxContext

Access the ServletContext (if any) attributes.

getContextAttribute(String) - Method in class org.cometd.server.websocket.common.AbstractBayeuxContext

getContextInitParameter(String) - Method in interface org.cometd.bayeux.server.BayeuxContext

Access the ServletContext (if any) init parameter.

getContextInitParameter(String) - Method in class org.cometd.server.websocket.common.AbstractBayeuxContext

getContextPath() - Method in interface org.cometd.bayeux.server.BayeuxContext

getContextPath() - Method in class org.cometd.server.websocket.common.AbstractBayeuxContext

getCookie(String) - Method in interface org.cometd.bayeux.server.BayeuxContext

Get a transport cookie.

getCookie(String) - Method in class org.cometd.client.BayeuxClient

Retrieves the first cookie with the given name, if available.

getCookie(String) - Method in class org.cometd.server.websocket.common.AbstractBayeuxContext

getCookies(URI) - Method in class org.cometd.client.transport.HttpClientTransport

getCookieStore() - Method in class org.cometd.client.BayeuxClient

getCookieStore() - Method in class org.cometd.client.transport.HttpClientTransport

getData() - Method in interface org.cometd.bayeux.Message

Convenience method to retrieve the Message.DATA_FIELD

getData() - Method in class org.cometd.common.HashMapMessage

getData() - Method in class org.cometd.oort.OortService.Request

getData() - Method in class org.cometd.server.ServerMessageImpl

getDataAsMap() - Method in interface org.cometd.bayeux.Message

getDataAsMap() - Method in class org.cometd.common.HashMapMessage

getDataAsMap() - Method in class org.cometd.oort.OortService.Request

getDataAsMap() - Method in class org.cometd.server.ServerMessageImpl

getDataAsMap(boolean) - Method in interface org.cometd.bayeux.Message.Mutable

Convenience method to retrieve the Message.DATA_FIELD and create it if it does not exist

getDataAsMap(boolean) - Method in class org.cometd.common.HashMapMessage

getDelegate() - Method in class org.cometd.client.websocket.common.AbstractWebSocketTransport

getDuplicateMetaConnectHttpResponseCode() - Method in class org.cometd.server.http.AbstractHttpTransport

getExecutor() - Method in class org.cometd.server.BayeuxServerImpl

getExt() - Method in interface org.cometd.bayeux.Message

Convenience method to retrieve the Message.EXT_FIELD

getExt() - Method in class org.cometd.common.HashMapMessage

getExt() - Method in class org.cometd.server.ServerMessageImpl

getExt(boolean) - Method in interface org.cometd.bayeux.Message.Mutable

Convenience method to retrieve the Message.EXT_FIELD and create it if it does not exist

getExt(boolean) - Method in class org.cometd.common.HashMapMessage

getExtensions() - Method in interface org.cometd.bayeux.client.ClientSession

getExtensions() - Method in interface org.cometd.bayeux.server.BayeuxServer

getExtensions() - Method in interface org.cometd.bayeux.server.ServerSession

getExtensions() - Method in class org.cometd.common.AbstractClientSession

getExtensions() - Method in class org.cometd.server.BayeuxServerImpl

getExtensions() - Method in class org.cometd.server.ServerSessionImpl

getFactory() - Method in class org.cometd.oort.OortObject

getField(Object, Field) - Method in class org.cometd.annotation.AnnotationProcessor

getFields() - Method in exception org.cometd.common.TransportException

getGenerator() - Method in class org.cometd.common.JacksonJSONContext

getGenerator() - Method in class org.cometd.common.JettyJSONContext

getGenerator() - Method in interface org.cometd.common.JSONContext

getGenerator() - Method in class org.cometd.server.JacksonJSONContextServer

getGenerator() - Method in class org.cometd.server.JettyJSONContextServer

getGroupAddress() - Method in class org.cometd.oort.OortMulticastConfigurer

getGroupInterfaces() - Method in class org.cometd.oort.OortMulticastConfigurer

getGroupPort() - Method in class org.cometd.oort.OortMulticastConfigurer

getHeader(String) - Method in interface org.cometd.bayeux.server.BayeuxContext

Get a transport header.

getHeader(String) - Method in class org.cometd.server.websocket.common.AbstractBayeuxContext

getHeaderValues(String) - Method in interface org.cometd.bayeux.server.BayeuxContext

Get a multi valued transport header.

getHeaderValues(String) - Method in class org.cometd.server.websocket.common.AbstractBayeuxContext

getHttpClient() - Method in class org.cometd.client.http.jetty.JettyHttpClientTransport

getHttpSessionAttribute(String) - Method in interface org.cometd.bayeux.server.BayeuxContext

Access the HTTP Session (if any) attributes.

getHttpSessionAttribute(String) - Method in class org.cometd.server.websocket.common.AbstractBayeuxContext

getHttpSessionId() - Method in interface org.cometd.bayeux.server.BayeuxContext

Access the HTTP Session (if any) ID.

getHttpSessionId() - Method in class org.cometd.server.websocket.common.AbstractBayeuxContext

getId() - Method in interface org.cometd.bayeux.Channel

getId() - Method in class org.cometd.bayeux.ChannelId

Returns the normalized channel id string.

getId() - Method in interface org.cometd.bayeux.Message

Convenience method to retrieve the Message.ID_FIELD

getId() - Method in interface org.cometd.bayeux.Session

The clientId of the session.

getId() - Method in class org.cometd.client.BayeuxClient

getId() - Method in class org.cometd.common.AbstractClientSession.AbstractSessionChannel

getId() - Method in class org.cometd.common.HashMapMessage

getId() - Method in class org.cometd.oort.Oort

getId() - Method in class org.cometd.oort.Seti

getId() - Method in class org.cometd.server.LocalSessionImpl

getId() - Method in class org.cometd.server.ServerChannelImpl

getId() - Method in class org.cometd.server.ServerSessionImpl

getIdleTimeout() - Method in class org.cometd.client.websocket.common.AbstractWebSocketTransport

getInfo(String) - Method in class org.cometd.oort.OortObject

getInfoByObject(T) - Method in class org.cometd.oort.OortObject

getInfos() - Method in class org.cometd.oort.OortObject

getInterval() - Method in interface org.cometd.bayeux.server.ServerSession

getInterval() - Method in interface org.cometd.bayeux.server.ServerTransport

getInterval() - Method in class org.cometd.server.AbstractServerTransport

getInterval() - Method in class org.cometd.server.ServerSessionImpl

getJSON() - Method in class org.cometd.common.JettyJSONContext

getJSON() - Method in class org.cometd.server.ServerMessageImpl

getJSONBytes() - Method in class org.cometd.server.ServerMessageImpl

getJSONContext() - Method in class org.cometd.server.BayeuxServerImpl

getJSONContextClient() - Method in class org.cometd.client.transport.ClientTransport

getJSONContextClient() - Method in class org.cometd.oort.Oort

getJSONContextServer() - Method in class org.cometd.server.AbstractServerTransport

getKey() - Method in class org.cometd.oort.OortMap.Entry

getKnownComets() - Method in class org.cometd.oort.Oort

getKnownTransportNames() - Method in interface org.cometd.bayeux.Bayeux

getKnownTransportNames() - Method in class org.cometd.client.BayeuxClient

getKnownTransportNames() - Method in class org.cometd.server.BayeuxServerImpl

getKnownTransportNames() - Method in class org.cometd.server.jmx.BayeuxServerImplMBean

getKnownTransports() - Method in class org.cometd.client.transport.TransportRegistry

getLag() - Method in class org.cometd.client.ext.TimesyncClientExtension

getLastActivity() - Method in class org.cometd.server.ext.ActivityExtension.SessionExtension

getLastSweepInfo() - Method in class org.cometd.server.BayeuxServerImpl

getLastSweepInfo() - Method in class org.cometd.server.jmx.BayeuxServerImplMBean

getLazyTimeout() - Method in interface org.cometd.bayeux.server.ConfigurableServerChannel

getLazyTimeout() - Method in class org.cometd.server.ServerChannelImpl

getListeners() - Method in interface org.cometd.bayeux.client.ClientSessionChannel

getListeners() - Method in interface org.cometd.bayeux.server.ConfigurableServerChannel

getListeners() - Method in class org.cometd.common.AbstractClientSession.AbstractSessionChannel

getListeners() - Method in class org.cometd.server.BayeuxServerImpl

getListeners() - Method in class org.cometd.server.ServerChannelImpl

getListeners() - Method in class org.cometd.server.ServerSessionImpl

getLocalAddress() - Method in interface org.cometd.bayeux.server.BayeuxContext

getLocalAddress() - Method in class org.cometd.server.websocket.common.AbstractBayeuxContext

getLocales() - Method in interface org.cometd.bayeux.server.BayeuxContext

getLocales() - Method in class org.cometd.server.websocket.common.AbstractBayeuxContext

getLocalSession() - Method in interface org.cometd.bayeux.server.ServerSession

getLocalSession() - Method in class org.cometd.oort.OortLong

getLocalSession() - Method in class org.cometd.oort.OortObject

getLocalSession() - Method in class org.cometd.oort.OortService

getLocalSession() - Method in class org.cometd.server.AbstractService

getLocalSession() - Method in class org.cometd.server.ServerSessionImpl

getLock() - Method in class org.cometd.server.ServerSessionImpl

getLongestSweepInfo() - Method in class org.cometd.server.BayeuxServerImpl

getLongestSweepInfo() - Method in class org.cometd.server.jmx.BayeuxServerImplMBean

getMaxActiveThreads() - Method in class org.cometd.benchmark.MonitoringQueuedThreadPool

getMaxActiveThreads() - Method in class org.cometd.benchmark.MonitoringThreadPoolExecutor

getMaxInactivityPeriod() - Method in class org.cometd.server.ext.ActivityExtension

getMaxInactivityPeriod() - Method in class org.cometd.server.ext.ActivityExtension.SessionExtension

getMaxInterval() - Method in interface org.cometd.bayeux.server.ServerSession

getMaxInterval() - Method in interface org.cometd.bayeux.server.ServerTransport

getMaxInterval() - Method in class org.cometd.server.AbstractServerTransport

getMaxInterval() - Method in class org.cometd.server.ServerSessionImpl

getMaxLazyTimeout() - Method in interface org.cometd.bayeux.server.ServerTransport

getMaxLazyTimeout() - Method in class org.cometd.server.AbstractServerTransport

getMaxMessageSize() - Method in class org.cometd.client.http.common.AbstractHttpClientTransport

getMaxMessageSize() - Method in class org.cometd.server.AbstractServerTransport

getMaxNetworkDelay() - Method in class org.cometd.client.transport.ClientTransport

getMaxQueueLatency() - Method in class org.cometd.benchmark.MonitoringQueuedThreadPool

getMaxQueueLatency() - Method in class org.cometd.benchmark.MonitoringThreadPoolExecutor

getMaxQueueSize() - Method in class org.cometd.benchmark.MonitoringQueuedThreadPool

getMaxQueueSize() - Method in class org.cometd.benchmark.MonitoringThreadPoolExecutor

getMaxTaskLatency() - Method in class org.cometd.benchmark.MonitoringQueuedThreadPool

getMaxTaskLatency() - Method in class org.cometd.benchmark.MonitoringThreadPoolExecutor

getMaxTransmissionLength() - Method in class org.cometd.oort.OortMulticastConfigurer

getMessage() - Method in interface org.cometd.server.AbstractServerTransport.Scheduler

getMessage() - Method in class org.cometd.server.http.AbstractHttpTransport.LongPollScheduler

getMessagesPerFrame() - Method in class org.cometd.server.websocket.common.AbstractWebSocketTransport

getMetaConnectCycle() - Method in interface org.cometd.server.AbstractServerTransport.Scheduler

getMetaConnectCycle() - Method in class org.cometd.server.AbstractServerTransport.Scheduler.None

getMetaConnectCycle() - Method in class org.cometd.server.http.AbstractHttpTransport.LongPollScheduler

getMetaData() - Method in class org.cometd.bayeux.BinaryData

getMultiSessionInterval() - Method in class org.cometd.server.http.AbstractHttpTransport

getName() - Method in interface org.cometd.bayeux.Transport

getName() - Method in class org.cometd.common.AbstractTransport

getName() - Method in class org.cometd.oort.OortObject

getName() - Method in class org.cometd.oort.OortObject.Info

getName() - Method in class org.cometd.oort.OortService

getName() - Method in class org.cometd.server.AbstractService

getName() - Method in class org.cometd.server.BayeuxServerImpl

getNewValue() - Method in class org.cometd.oort.OortMap.Entry

getObject() - Method in class org.cometd.oort.OortObject.Info

getObjectContextBasis() - Method in class org.cometd.server.jmx.BayeuxServerImplMBean

getObjectMapper() - Method in class org.cometd.common.JacksonJSONContext

getObservedChannels() - Method in class org.cometd.oort.jmx.OortMBean

getObservedChannels() - Method in class org.cometd.oort.Oort

getOffset() - Method in class org.cometd.client.ext.TimesyncClientExtension

getOkHttpClient() - Method in class org.cometd.client.http.okhttp.OkHttpClientTransport

getOldValue() - Method in class org.cometd.oort.OortMap.Entry

getOort() - Method in class org.cometd.oort.Oort.CometListener.Event

getOort() - Method in class org.cometd.oort.OortLong

getOort() - Method in class org.cometd.oort.OortObject

getOort() - Method in class org.cometd.oort.OortService

getOort() - Method in class org.cometd.oort.Seti

getOortSession() - Method in class org.cometd.oort.Oort

getOortURL() - Method in class org.cometd.oort.OortObject.Info

getOortURL() - Method in class org.cometd.oort.OortService.Request

getOortURL() - Method in class org.cometd.oort.Seti.PresenceListener.Event

getOption(String) - Method in interface org.cometd.bayeux.Bayeux

getOption(String) - Method in interface org.cometd.bayeux.Transport

getOption(String) - Method in class org.cometd.client.BayeuxClient

getOption(String) - Method in class org.cometd.common.AbstractTransport

Returns an option value for the given option name, searching the option name tree.

getOption(String) - Method in class org.cometd.server.BayeuxServerImpl

getOption(String, boolean) - Method in class org.cometd.common.AbstractTransport

Get option or default value.

getOption(String, boolean) - Method in class org.cometd.server.BayeuxServerImpl

getOption(String, int) - Method in class org.cometd.common.AbstractTransport

Get option or default value.

getOption(String, long) - Method in class org.cometd.common.AbstractTransport

Get option or default value.

getOption(String, long) - Method in class org.cometd.server.BayeuxServerImpl

getOption(String, String) - Method in class org.cometd.common.AbstractTransport

Get option or default value.

getOptionNames() - Method in interface org.cometd.bayeux.Bayeux

getOptionNames() - Method in interface org.cometd.bayeux.Transport

getOptionNames() - Method in class org.cometd.client.BayeuxClient

getOptionNames() - Method in class org.cometd.common.AbstractTransport

getOptionNames() - Method in class org.cometd.server.BayeuxServerImpl

getOptionNames() - Method in class org.cometd.server.jmx.BayeuxServerImplMBean

getOptionPrefix() - Method in interface org.cometd.bayeux.Transport

Specifies an option prefix made of string segments separated by the "."

getOptionPrefix() - Method in class org.cometd.common.AbstractTransport

getOptions() - Method in class org.cometd.client.BayeuxClient

getOptions() - Method in class org.cometd.server.BayeuxServerImpl

getParameter(String) - Method in interface org.cometd.bayeux.server.BayeuxContext

Get a transport parameter.

getParameter(String) - Method in class org.cometd.server.websocket.common.AbstractBayeuxContext

getParameters() - Method in class org.cometd.bayeux.ChannelId

getParameterValues(String) - Method in interface org.cometd.bayeux.server.BayeuxContext

Get a multi valued transport parameter.

getParameterValues(String) - Method in class org.cometd.server.websocket.common.AbstractBayeuxContext

getParent() - Method in class org.cometd.bayeux.ChannelId

getParser() - Method in class org.cometd.common.JacksonJSONContext

getParser() - Method in class org.cometd.common.JettyJSONContext

getParser() - Method in interface org.cometd.common.JSONContext

getPresenceCount(String) - Method in class org.cometd.oort.Seti

getPrimaryOortURL() - Method in class org.cometd.oort.OortPrimaryService

getPromise() - Method in class org.cometd.server.http.AbstractHttpTransport.LongPollScheduler

getProtocol() - Method in interface org.cometd.bayeux.server.BayeuxContext

getProtocol() - Method in class org.cometd.client.websocket.common.AbstractWebSocketTransport

getProtocol() - Method in class org.cometd.server.websocket.common.AbstractBayeuxContext

getProtocol() - Method in class org.cometd.server.websocket.common.AbstractWebSocketTransport

getQueue() - Method in class org.cometd.server.ServerSessionImpl

getReason() - Method in class org.cometd.bayeux.server.Authorizer.Result.Denied

getReference() - Method in class org.cometd.bayeux.MarkedReference

getRegularPart() - Method in class org.cometd.bayeux.ChannelId

Returns the regular part of this ChannelId: the part of the channel id from the beginning until the first occurrence of a parameter or a wild character.

getRemoteAddress() - Method in interface org.cometd.bayeux.server.BayeuxContext

getRemoteAddress() - Method in class org.cometd.server.websocket.common.AbstractBayeuxContext

getRequestAttribute(String) - Method in interface org.cometd.bayeux.server.BayeuxContext

Access the Request (if any) attributes.

getRequestAttribute(String) - Method in class org.cometd.server.websocket.common.AbstractBayeuxContext

getScheduler() - Method in class org.cometd.client.transport.ClientTransport

getScheduler() - Method in class org.cometd.oort.Oort

getScheduler() - Method in class org.cometd.server.BayeuxServerImpl

getSecret() - Method in class org.cometd.oort.Oort

getSecurityPolicy() - Method in interface org.cometd.bayeux.server.BayeuxServer

getSecurityPolicy() - Method in class org.cometd.server.BayeuxServerImpl

getSegment(int) - Method in class org.cometd.bayeux.ChannelId

getServerMessage() - Method in class org.cometd.oort.OortService.ServerContext

getServerSession() - Method in interface org.cometd.annotation.server.RemoteCall.Caller

getServerSession() - Method in interface org.cometd.bayeux.server.LocalSession

getServerSession() - Method in class org.cometd.oort.OortService.ServerContext

getServerSession() - Method in class org.cometd.server.AbstractService

getServerSession() - Method in class org.cometd.server.LocalSessionImpl

getServerTime() - Method in class org.cometd.client.ext.TimesyncClientExtension

getServerTransport() - Method in interface org.cometd.bayeux.server.ServerMessage

getServerTransport() - Method in interface org.cometd.bayeux.server.ServerSession

getServerTransport() - Method in class org.cometd.server.ServerMessageImpl

getServerTransport() - Method in class org.cometd.server.ServerSessionImpl

getServices() - Method in class org.cometd.annotation.server.AnnotationCometDServlet

getSession() - Method in interface org.cometd.bayeux.client.ClientSessionChannel

getSession() - Method in class org.cometd.client.BayeuxClient.BayeuxClientChannel

getSession() - Method in class org.cometd.server.LocalSessionImpl.LocalChannel

getSession(String) - Method in interface org.cometd.bayeux.server.BayeuxServer

getSession(String) - Method in class org.cometd.server.BayeuxServerImpl

getSessionCount() - Method in class org.cometd.server.jmx.BayeuxServerImplMBean

getSessions() - Method in interface org.cometd.bayeux.server.BayeuxServer

getSessions() - Method in class org.cometd.server.BayeuxServerImpl

getSeti() - Method in class org.cometd.oort.Seti.PresenceListener.Event

getState() - Method in class org.cometd.client.BayeuxClient

getSubscribers() - Method in interface org.cometd.bayeux.client.ClientSessionChannel

getSubscribers() - Method in interface org.cometd.bayeux.server.ServerChannel

getSubscribers() - Method in class org.cometd.common.AbstractClientSession.AbstractSessionChannel

getSubscribers() - Method in class org.cometd.server.ServerChannelImpl

getSubscriptions() - Method in interface org.cometd.bayeux.server.ServerSession

getSubscriptions() - Method in class org.cometd.server.ServerSessionImpl

getSweepPeriod() - Method in class org.cometd.server.BayeuxServerImpl

getSweepThreads() - Method in class org.cometd.server.BayeuxServerImpl

getTasks() - Method in class org.cometd.benchmark.MonitoringQueuedThreadPool

getTasks() - Method in class org.cometd.benchmark.MonitoringThreadPoolExecutor

getThreadPool() - Method in class org.cometd.server.AbstractService

getTimeout() - Method in interface org.cometd.bayeux.server.ServerSession

getTimeout() - Method in interface org.cometd.bayeux.server.ServerTransport

getTimeout() - Method in class org.cometd.oort.OortService

getTimeout() - Method in class org.cometd.server.AbstractServerTransport

getTimeout() - Method in class org.cometd.server.ServerSessionImpl

getTimeToLive() - Method in class org.cometd.oort.OortMulticastConfigurer

getTransport() - Method in class org.cometd.client.BayeuxClient

getTransport(String) - Method in interface org.cometd.bayeux.Bayeux

getTransport(String) - Method in class org.cometd.client.BayeuxClient

getTransport(String) - Method in class org.cometd.client.transport.TransportRegistry

getTransport(String) - Method in class org.cometd.server.BayeuxServerImpl

getTransports() - Method in class org.cometd.server.BayeuxServerImpl

getURL() - Method in interface org.cometd.bayeux.server.BayeuxContext

getURL() - Method in class org.cometd.client.BayeuxClient

getURL() - Method in class org.cometd.client.transport.ClientTransport

getURL() - Method in class org.cometd.oort.Oort

getURL() - Method in class org.cometd.server.websocket.common.AbstractBayeuxContext

getUserAgent() - Method in interface org.cometd.bayeux.server.ServerSession

getUserAgent() - Method in class org.cometd.server.ServerSessionImpl

getUserId() - Method in class org.cometd.oort.Seti.PresenceListener.Event

getUserIds() - Method in class org.cometd.oort.Seti

getUserPrincipal() - Method in interface org.cometd.bayeux.server.BayeuxContext

getUserPrincipal() - Method in class org.cometd.server.websocket.common.AbstractBayeuxContext

getValue() - Method in class org.cometd.oort.OortPrimaryLong

getVersion() - Method in class org.cometd.oort.OortObject.Info

getWildIds() - Method in class org.cometd.bayeux.ChannelId

Returns the list of wild channels that match this channel.

getWilds() - Method in class org.cometd.bayeux.ChannelId

Deprecated.

use ChannelId.getWildIds() instead

grant() - Static method in class org.cometd.bayeux.server.Authorizer.Result

GRANT_ALL - Static variable in class org.cometd.server.authorizer.GrantAuthorizer

Grants Authorizer.Operation.CREATE, Authorizer.Operation.SUBSCRIBE and Authorizer.Operation.PUBLISH authorization

GRANT_CREATE - Static variable in class org.cometd.server.authorizer.GrantAuthorizer

Grants Authorizer.Operation.CREATE authorization

GRANT_CREATE_SUBSCRIBE - Static variable in class org.cometd.server.authorizer.GrantAuthorizer

Grants Authorizer.Operation.CREATE and Authorizer.Operation.SUBSCRIBE authorization

GRANT_NONE - Static variable in class org.cometd.server.authorizer.GrantAuthorizer

Grants no authorization, the authorization request is ignored

GRANT_PUBLISH - Static variable in class org.cometd.server.authorizer.GrantAuthorizer

Grants Authorizer.Operation.PUBLISH authorization

GRANT_SUBSCRIBE - Static variable in class org.cometd.server.authorizer.GrantAuthorizer

Grants Authorizer.Operation.SUBSCRIBE authorization

GRANT_SUBSCRIBE_PUBLISH - Static variable in class org.cometd.server.authorizer.GrantAuthorizer

Grants Authorizer.Operation.SUBSCRIBE and Authorizer.Operation.PUBLISH authorization

GrantAuthorizer - Class in org.cometd.server.authorizer

This Authorizer implementation grants permission for a set of operations defined at construction time.

H

handle(HttpServletRequest, HttpServletResponse) - Method in class org.cometd.server.http.AbstractHttpTransport

handle(HttpServletRequest, HttpServletResponse) - Method in class org.cometd.server.http.AbstractStreamHttpTransport

handle(HttpServletRequest, HttpServletResponse) - Method in class org.cometd.server.http.AsyncJSONTransport

handle(ClientTransport.FailureInfo) - Method in interface org.cometd.client.transport.ClientTransport.FailureHandler

handle(ServerSessionImpl, ServerMessage.Mutable, Promise<ServerMessage.Mutable>) - Method in class org.cometd.server.BayeuxServerImpl

handleJSONParseException(HttpServletRequest, HttpServletResponse, String, Throwable) - Method in class org.cometd.server.http.AbstractHttpTransport

handleMembership(ServerSession, ServerMessage) - Method in class org.cometd.examples.ChatService

handleMessage(AbstractHttpTransport.Context, ServerMessage.Mutable, Promise<ServerMessage.Mutable>) - Method in class org.cometd.server.http.AbstractHttpTransport

handshake() - Method in interface org.cometd.bayeux.client.ClientSession

Equivalent to handshake(null).

handshake(long) - Method in class org.cometd.client.BayeuxClient

Performs the handshake and waits at most the given time for the handshake to complete.

handshake(Map<String, Object>) - Method in interface org.cometd.bayeux.client.ClientSession

Equivalent to handshake(template, null).

handshake(Map<String, Object>, long) - Method in class org.cometd.client.BayeuxClient

Performs the handshake with the given template and waits at most the given time for the handshake to complete.

handshake(Map<String, Object>, ClientSession.MessageListener) - Method in interface org.cometd.bayeux.client.ClientSession

Initiates the bayeux protocol handshake with the server(s).

handshake(Map<String, Object>, ClientSession.MessageListener) - Method in class org.cometd.client.BayeuxClient

handshake(Map<String, Object>, ClientSession.MessageListener) - Method in class org.cometd.server.LocalSessionImpl

handshake(ClientSession.MessageListener) - Method in class org.cometd.client.BayeuxClient

handshake(ServerMessage.Mutable) - Method in class org.cometd.server.ServerSessionImpl

HANDSHAKE_RECONNECT_OPTION - Static variable in class org.cometd.server.AbstractServerTransport

handshakeClient(String, CometDLoadClient.ClientTransportType, boolean) - Method in class org.cometd.benchmark.client.CometDLoadClient

HANDSHAKEN - org.cometd.client.BayeuxClient.State

State assumed when the handshake is received, but before connecting

HANDSHAKING - org.cometd.client.BayeuxClient.State

State assumed when the handshake is being sent

hashCode() - Method in class org.cometd.bayeux.ChannelId

hashCode() - Method in class org.cometd.oort.Seti.LocalLocation

hashCode() - Method in interface org.cometd.oort.Seti.Location

hashCode() - Method in class org.cometd.oort.Seti.SetiLocation

HashMapMessage - Class in org.cometd.common

HashMapMessage() - Constructor for class org.cometd.common.HashMapMessage

HashMapMessage(Message) - Constructor for class org.cometd.common.HashMapMessage

hasNonLazyMessages() - Method in class org.cometd.server.ServerSessionImpl

headersToMap(Headers) - Static method in class org.cometd.client.websocket.okhttp.OkHttpWebSocketTransport

headersToMap(HttpFields) - Static method in class org.cometd.client.websocket.jetty.JettyWebSocketTransport

HTTP2_MAX_SESSIONS_PER_BROWSER_OPTION - Static variable in class org.cometd.server.http.AbstractHttpTransport

HttpClientTransport - Class in org.cometd.client.transport

HttpClientTransport(String, String, Map<String, Object>) - Constructor for class org.cometd.client.transport.HttpClientTransport

Deprecated.

HttpClientTransport(String, String, Map<String, Object>, ScheduledExecutorService) - Constructor for class org.cometd.client.transport.HttpClientTransport

I

ID_FIELD - Static variable in interface org.cometd.bayeux.Message

ID_FIELD - Static variable in class org.cometd.benchmark.Config

IDLE_TIMEOUT_OPTION - Static variable in class org.cometd.client.websocket.common.AbstractWebSocketTransport

IDLE_TIMEOUT_OPTION - Static variable in class org.cometd.server.websocket.common.AbstractWebSocketTransport

ignore() - Static method in class org.cometd.bayeux.server.Authorizer.Result

ignore(Object) - Static method in class org.cometd.oort.OortService.Result

Returns an ignored OortService.Result containing the given data object

importMessages(ServerSessionImpl) - Method in class org.cometd.server.ext.AcknowledgedMessagesSessionExtension

incBrowserId(ServerSessionImpl, boolean) - Method in class org.cometd.server.http.AbstractHttpTransport

Increments the count of sessions for the given browser identifier.

incoming(ClientSession, Message.Mutable, Promise<Boolean>) - Method in interface org.cometd.bayeux.client.ClientSession.Extension

Callback method invoked every time a message is incoming.

incoming(ServerSession, ServerMessage.Mutable, Promise<Boolean>) - Method in interface org.cometd.bayeux.server.BayeuxServer.Extension

Callback method invoked every time a message is incoming.

incoming(ServerSession, ServerMessage.Mutable, Promise<Boolean>) - Method in interface org.cometd.bayeux.server.ServerSession.Extension

Callback method invoked every time a message is incoming.

Info(String, Map<? extends String, ?>) - Constructor for class org.cometd.oort.OortObject.Info

init() - Method in class org.cometd.annotation.server.AnnotationCometDServlet

init() - Method in class org.cometd.client.http.common.AbstractHttpClientTransport

init() - Method in class org.cometd.client.http.jetty.JettyHttpClientTransport

init() - Method in class org.cometd.client.http.okhttp.OkHttpClientTransport

init() - Method in class org.cometd.client.transport.ClientTransport

init() - Method in class org.cometd.client.websocket.common.AbstractWebSocketTransport

init() - Method in class org.cometd.client.websocket.javax.WebSocketTransport

init() - Method in class org.cometd.client.websocket.jetty.JettyWebSocketTransport

init() - Method in class org.cometd.client.websocket.okhttp.OkHttpWebSocketTransport

init() - Method in class org.cometd.examples.CometDDemoServlet

init() - Method in class org.cometd.server.AbstractServerTransport

Initializes the transport, resolving default and direct options.

init() - Method in class org.cometd.server.CometDServlet

init() - Method in class org.cometd.server.http.AbstractHttpTransport

init() - Method in class org.cometd.server.http.JSONPTransport

init() - Method in class org.cometd.server.http.JSONTransport

init() - Method in class org.cometd.server.websocket.common.AbstractWebSocketTransport

init() - Method in class org.cometd.server.websocket.javax.WebSocketTransport

init() - Method in class org.cometd.server.websocket.jetty.JettyWebSocketTransport

init(ServletConfig) - Method in class org.cometd.oort.OortConfigServlet

init(ServletConfig) - Method in class org.cometd.oort.SetiServlet

init(Object) - Method in class org.cometd.server.filter.JSONDataFilter

init(Object) - Method in class org.cometd.server.filter.RegexFilter

The init object must be an array of array of this form:

initialize() - Method in class org.cometd.client.BayeuxClient

initializeJSONContext() - Method in class org.cometd.server.BayeuxServerImpl

initializeMetaChannels() - Method in class org.cometd.server.BayeuxServerImpl

initializeServerTransports() - Method in class org.cometd.server.BayeuxServerImpl

initScheduler() - Method in class org.cometd.client.transport.ClientTransport

INTERVAL_FIELD - Static variable in interface org.cometd.bayeux.Message

INTERVAL_OPTION - Static variable in class org.cometd.server.AbstractServerTransport

invalidateHttpSession() - Method in interface org.cometd.bayeux.server.BayeuxContext

Invalidate the HTTP Session.

invalidateHttpSession() - Method in class org.cometd.server.websocket.common.AbstractBayeuxContext

invokePrivate(Object, Method, Object...) - Method in class org.cometd.annotation.AnnotationProcessor

invokePublic(Object, Method, Object[]) - Static method in class org.cometd.annotation.AnnotationProcessor

isAborted() - Method in class org.cometd.client.http.common.AbstractHttpClientTransport

isAckExtensionEnabled() - Method in class org.cometd.oort.Oort

isAllowMessageDeliveryDuringHandshake() - Method in class org.cometd.server.AbstractServerTransport

isAllowMessageDeliveryDuringHandshake() - Method in class org.cometd.server.ServerSessionImpl

isAncestorOf(ChannelId) - Method in class org.cometd.bayeux.ChannelId

isAppendMessageType() - Method in class org.cometd.client.http.common.AbstractHttpClientTransport

isAssociated(String) - Method in class org.cometd.oort.Seti

isBatching() - Method in class org.cometd.common.AbstractClientSession

isBinaryExtensionEnabled() - Method in class org.cometd.oort.Oort

isBroadcast() - Method in interface org.cometd.bayeux.Channel

A broadcasting channel is a channel that is neither a meta channel nor a service channel.

isBroadcast() - Method in class org.cometd.bayeux.ChannelId

isBroadcast() - Method in class org.cometd.common.AbstractClientSession.AbstractSessionChannel

isBroadcast() - Method in class org.cometd.server.ServerChannelImpl

isBroadcast(String) - Static method in class org.cometd.bayeux.ChannelId

Helper method to test if the string form of a ChannelId represents a broadcast ChannelId.

isBroadcastToPublisher() - Method in interface org.cometd.bayeux.server.ConfigurableServerChannel

isBroadcastToPublisher() - Method in interface org.cometd.bayeux.server.ServerSession

isBroadcastToPublisher() - Method in class org.cometd.server.BayeuxServerImpl

isBroadcastToPublisher() - Method in class org.cometd.server.ServerChannelImpl

isBroadcastToPublisher() - Method in class org.cometd.server.ServerSessionImpl

isCometConnected(String) - Method in class org.cometd.oort.Oort

isConnected() - Method in interface org.cometd.bayeux.Session

A connected session is a session where the link between the client and the server has been established.

isConnected() - Method in class org.cometd.client.BayeuxClient

isConnected() - Method in class org.cometd.server.LocalSessionImpl

isConnected() - Method in class org.cometd.server.ServerSessionImpl

isDeepWild() - Method in interface org.cometd.bayeux.Channel

Tells whether a channel contains the deep wild characters '**', for example /foo/**

isDeepWild() - Method in class org.cometd.bayeux.ChannelId

Deep wild ChannelIds end with a double wild character "**" and match non wild channels with the same or greater depth.

isDeepWild() - Method in class org.cometd.common.AbstractClientSession.AbstractSessionChannel

isDeepWild() - Method in class org.cometd.server.ServerChannelImpl

isDenied() - Method in class org.cometd.bayeux.server.Authorizer.Result.Denied

isDenied() - Method in class org.cometd.bayeux.server.Authorizer.Result

isDetailedDump() - Method in class org.cometd.server.BayeuxServerImpl

isDisconnected() - Method in class org.cometd.client.BayeuxClient

isDisconnected() - Method in class org.cometd.server.ServerSessionImpl

isEmpty() - Method in class org.cometd.server.ext.BatchArrayQueue

isFrozen() - Method in class org.cometd.server.ServerMessageImpl

isGranted() - Method in class org.cometd.bayeux.server.Authorizer.Result.Granted

isGranted() - Method in class org.cometd.bayeux.server.Authorizer.Result

isHandled() - Method in class org.cometd.server.ServerMessageImpl

isHandshakeReconnect() - Method in class org.cometd.server.AbstractServerTransport

isHandshook() - Method in interface org.cometd.bayeux.Session

A handshook session is a session where the handshake has successfully completed

isHandshook() - Method in class org.cometd.client.BayeuxClient

isHandshook() - Method in class org.cometd.server.LocalSessionImpl

isHandshook() - Method in class org.cometd.server.ServerSessionImpl

isHTTP2(HttpServletRequest) - Method in class org.cometd.server.http.AbstractHttpTransport

isInactive() - Method in class org.cometd.server.ext.ActivityExtension.SessionExtension

isItemUpdate(Map<String, Object>) - Method in class org.cometd.oort.OortContainer

isItemUpdate(Map<String, Object>) - Method in class org.cometd.oort.OortList

isItemUpdate(Map<String, Object>) - Method in class org.cometd.oort.OortMap

isLast() - Method in class org.cometd.bayeux.BinaryData

isLazy() - Method in interface org.cometd.bayeux.server.ConfigurableServerChannel

isLazy() - Method in interface org.cometd.bayeux.server.ServerMessage

isLazy() - Method in class org.cometd.server.ServerChannelImpl

isLazy() - Method in class org.cometd.server.ServerMessageImpl

isLocal() - Method in class org.cometd.oort.OortObject.Info

isLocal() - Method in class org.cometd.oort.OortService.Request

isLocal() - Method in class org.cometd.oort.Seti.PresenceListener.Event

isLocalSession() - Method in interface org.cometd.bayeux.server.ServerSession

isLocalSession() - Method in class org.cometd.server.ServerSessionImpl

isMarked() - Method in class org.cometd.bayeux.MarkedReference

isMeta() - Method in interface org.cometd.bayeux.Channel

Tells whether the channel is a meta channel, that is if its id starts with "/meta/".

isMeta() - Method in class org.cometd.bayeux.ChannelId

A ChannelId is a meta ChannelId if it starts with "/meta/".

isMeta() - Method in interface org.cometd.bayeux.Message

A messages that has a meta channel is dubbed a "meta message".

isMeta() - Method in class org.cometd.common.AbstractClientSession.AbstractSessionChannel

isMeta() - Method in class org.cometd.common.HashMapMessage

isMeta() - Method in class org.cometd.server.ServerChannelImpl

isMeta(String) - Static method in class org.cometd.bayeux.ChannelId

Helper method to test if the string form of a ChannelId represents a meta ChannelId.

isMetaConnectDeliveryOnly() - Method in interface org.cometd.bayeux.server.ServerSession

isMetaConnectDeliveryOnly() - Method in interface org.cometd.bayeux.server.ServerTransport

isMetaConnectDeliveryOnly() - Method in class org.cometd.server.AbstractServerTransport

isMetaConnectDeliveryOnly() - Method in class org.cometd.server.ServerSessionImpl

isOort(ServerSession) - Method in class org.cometd.oort.Oort

isOortHandshake(Message) - Method in class org.cometd.oort.Oort

isOpen() - Method in class org.cometd.client.websocket.common.AbstractWebSocketTransport.Delegate

isOpen() - Method in class org.cometd.client.websocket.javax.WebSocketTransport.WebSocketDelegate

isOpen() - Method in class org.cometd.client.websocket.jetty.JettyWebSocketTransport.JettyWebSocketDelegate

isOpen() - Method in class org.cometd.client.websocket.okhttp.OkHttpWebSocketTransport.OkHttpDelegate

isParentOf(ChannelId) - Method in class org.cometd.bayeux.ChannelId

isPerMessageDeflateEnabled() - Method in class org.cometd.client.websocket.common.AbstractWebSocketTransport

isPersistent() - Method in interface org.cometd.bayeux.server.ConfigurableServerChannel

isPersistent() - Method in class org.cometd.server.ServerChannelImpl

isPresent(E) - Method in class org.cometd.oort.OortList

Returns whether the given element is present in one of the entity lists of all nodes.

isPresent(String) - Method in class org.cometd.oort.Seti

isPrimary() - Method in class org.cometd.oort.OortPrimaryService

isPublishReply() - Method in interface org.cometd.bayeux.Message

Publish message replies contain the "successful" field

isPublishReply() - Method in class org.cometd.common.HashMapMessage

isReleased() - Method in interface org.cometd.bayeux.client.ClientSessionChannel

isReleased() - Method in class org.cometd.common.AbstractClientSession.AbstractSessionChannel

isRequireHandshakePerConnection() - Method in class org.cometd.server.websocket.common.AbstractWebSocketTransport

isSecure() - Method in interface org.cometd.bayeux.server.BayeuxContext

isSecure() - Method in class org.cometd.server.websocket.common.AbstractBayeuxContext

isSeeOwnPublishes() - Method in class org.cometd.server.AbstractService

isService() - Method in interface org.cometd.bayeux.Channel

Tells whether the channel is a service channel, that is if its id starts with "/service/".

isService() - Method in class org.cometd.bayeux.ChannelId

A ChannelId is a service ChannelId if it starts with "/service/".

isService() - Method in class org.cometd.common.AbstractClientSession.AbstractSessionChannel

isService() - Method in class org.cometd.server.ServerChannelImpl

isService(String) - Static method in class org.cometd.bayeux.ChannelId

Helper method to test if the string form of a ChannelId represents a service ChannelId.

isShallowWild() - Method in class org.cometd.bayeux.ChannelId

Shallow wild ChannelIds end with a single wild character "*" and match non wild channels with the same depth.

isStickyReconnect() - Method in class org.cometd.client.websocket.common.AbstractWebSocketTransport

isSuccessful() - Method in interface org.cometd.bayeux.Message

Convenience method to retrieve the Message.SUCCESSFUL_FIELD

isSuccessful() - Method in class org.cometd.common.HashMapMessage

isTemplate() - Method in class org.cometd.bayeux.ChannelId

isTerminated() - Method in class org.cometd.server.ServerSessionImpl

isUserInRole(String) - Method in interface org.cometd.bayeux.server.BayeuxContext

isUserInRole(String) - Method in class org.cometd.server.websocket.common.AbstractBayeuxContext

isValidChannelId(String) - Static method in class org.cometd.bayeux.Bayeux.Validator

isValidMessageId(String) - Static method in class org.cometd.bayeux.Bayeux.Validator

isWild() - Method in interface org.cometd.bayeux.Channel

Tells whether a channel contains the wild character '*', for example /foo/* or if it is Channel.isDeepWild().

isWild() - Method in class org.cometd.bayeux.ChannelId

isWild() - Method in class org.cometd.common.AbstractClientSession.AbstractSessionChannel

isWild() - Method in class org.cometd.server.ServerChannelImpl

iterator() - Method in class org.cometd.oort.OortObject

iterator() - Method in class org.cometd.server.ext.BatchArrayQueue

J

JacksonJSONContext<M extends Message.Mutable,I extends M> - Class in org.cometd.common

JacksonJSONContext() - Constructor for class org.cometd.common.JacksonJSONContext

JacksonJSONContext.ObjectMapperGenerator - Class in org.cometd.common

JacksonJSONContextClient - Class in org.cometd.common

JacksonJSONContextClient() - Constructor for class org.cometd.common.JacksonJSONContextClient

JacksonJSONContextServer - Class in org.cometd.server

JacksonJSONContextServer() - Constructor for class org.cometd.server.JacksonJSONContextServer

JettyHttpClientTransport - Class in org.cometd.client.http.jetty

JettyHttpClientTransport(String, Map<String, Object>, ScheduledExecutorService, HttpClient) - Constructor for class org.cometd.client.http.jetty.JettyHttpClientTransport

JettyHttpClientTransport(String, Map<String, Object>, HttpClient) - Constructor for class org.cometd.client.http.jetty.JettyHttpClientTransport

JettyHttpClientTransport(Map<String, Object>, HttpClient) - Constructor for class org.cometd.client.http.jetty.JettyHttpClientTransport

JettyHttpClientTransport.Factory - Class in org.cometd.client.http.jetty

JettyJSONContext<M extends Message.Mutable> - Class in org.cometd.common

JettyJSONContext() - Constructor for class org.cometd.common.JettyJSONContext

JettyJSONContext.AsyncJSONFactory - Class in org.cometd.common

JettyJSONContext.AsyncJSONParser - Class in org.cometd.common

JettyJSONContext.JSONGenerator - Class in org.cometd.common

JettyJSONContextClient - Class in org.cometd.common

JettyJSONContextClient() - Constructor for class org.cometd.common.JettyJSONContextClient

JettyJSONContextServer - Class in org.cometd.server

JettyJSONContextServer() - Constructor for class org.cometd.server.JettyJSONContextServer

JettyWebSocketDelegate() - Constructor for class org.cometd.client.websocket.jetty.JettyWebSocketTransport.JettyWebSocketDelegate

JettyWebSocketEndPoint - Class in org.cometd.server.websocket.jetty

JettyWebSocketEndPoint(JettyWebSocketTransport, BayeuxContext) - Constructor for class org.cometd.server.websocket.jetty.JettyWebSocketEndPoint

JettyWebSocketTransport - Class in org.cometd.client.websocket.jetty

JettyWebSocketTransport - Class in org.cometd.server.websocket.jetty

JettyWebSocketTransport(String, Map<String, Object>, ScheduledExecutorService, WebSocketClient) - Constructor for class org.cometd.client.websocket.jetty.JettyWebSocketTransport

JettyWebSocketTransport(Map<String, Object>, ScheduledExecutorService, WebSocketClient) - Constructor for class org.cometd.client.websocket.jetty.JettyWebSocketTransport

JettyWebSocketTransport(BayeuxServerImpl) - Constructor for class org.cometd.server.websocket.jetty.JettyWebSocketTransport

JettyWebSocketTransport.EndPoint - Class in org.cometd.server.websocket.jetty

JettyWebSocketTransport.Factory - Class in org.cometd.client.websocket.jetty

JettyWebSocketTransport.JettyWebSocketDelegate - Class in org.cometd.client.websocket.jetty

join(long) - Method in class org.cometd.oort.OortMulticastConfigurer

joinComets(Message) - Method in class org.cometd.oort.Oort

JSON_CONTEXT_OPTION - Static variable in class org.cometd.client.transport.ClientTransport

JSON_CONTEXT_OPTION - Static variable in class org.cometd.server.AbstractServerTransport

JSON_DEBUG_OPTION - Static variable in class org.cometd.server.http.AbstractHttpTransport

JSONContext<T extends Message.Mutable> - Interface in org.cometd.common

Abstraction for JSON parsing and generation.

JSONContext.AsyncParser - Interface in org.cometd.common

A non-blocking JSON parser.

JSONContext.Client - Interface in org.cometd.common

Client specific JSONContext that binds to Message.Mutable.

JSONContext.Generator - Interface in org.cometd.common

A JSON stringifier.

JSONContext.Parser - Interface in org.cometd.common

A blocking JSON parser.

JSONContextServer - Interface in org.cometd.server

Server specific JSONContext that binds to ServerMessage.Mutable.

JSONDataFilter - Class in org.cometd.server.filter

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).

JSONDataFilter() - Constructor for class org.cometd.server.filter.JSONDataFilter

JSONGenerator() - Constructor for class org.cometd.common.JettyJSONContext.JSONGenerator

JSONPTransport - Class in org.cometd.server.http

JSONPTransport(BayeuxServerImpl) - Constructor for class org.cometd.server.http.JSONPTransport

JSONTransport - Class in org.cometd.server.http

JSONTransport(BayeuxServerImpl) - Constructor for class org.cometd.server.http.JSONTransport

L

LAG_ATTRIBUTE - Static variable in class org.cometd.server.ext.TimesyncExtension

LAST - Static variable in class org.cometd.bayeux.BinaryData

leave(R) - Method in interface org.cometd.common.AsyncFoldLeft.Loop

Makes the loop exit (similarly to the break statement).

Linear() - Constructor for class org.cometd.client.BayeuxClient.BackOffStrategy.Linear

Linear(long, long) - Constructor for class org.cometd.client.BayeuxClient.BackOffStrategy.Linear

Listener - Annotation Type in org.cometd.annotation

For server-side services, identifies callback methods that are invoked when a message is processed on server-side.

listeners() - Method in class org.cometd.server.ServerChannelImpl

listUnion() - Static method in class org.cometd.oort.OortObjectMergers

ListUnionMerger() - Constructor for class org.cometd.oort.OortObjectMergers.ListUnionMerger

LocalChannel(ChannelId) - Constructor for class org.cometd.server.LocalSessionImpl.LocalChannel

LocalLocation(String, ServerSession) - Constructor for class org.cometd.oort.Seti.LocalLocation

LocalSession - Interface in org.cometd.bayeux.server

A LocalSession is a ClientSession within the server.

LocalSessionImpl - Class in org.cometd.server

A LocalSession implementation.

LocalSessionImpl(BayeuxServerImpl, String) - Constructor for class org.cometd.server.LocalSessionImpl

LocalSessionImpl.LocalChannel - Class in org.cometd.server

A channel scoped to this LocalSession.

locked(Runnable) - Method in class org.cometd.client.websocket.common.AbstractWebSocketTransport

locked(Supplier<T>) - Method in class org.cometd.client.websocket.common.AbstractWebSocketTransport

LongPollScheduler(AbstractHttpTransport.Context, Promise<Void>, ServerMessage.Mutable, long) - Constructor for class org.cometd.server.http.AbstractHttpTransport.LongPollScheduler

longSum() - Static method in class org.cometd.oort.OortObjectMergers

M

main(String[]) - Static method in class org.cometd.benchmark.client.CometDLoadClient

main(String[]) - Static method in class org.cometd.benchmark.server.CometDLoadServer

main(String[]) - Static method in class org.cometd.examples.CometDDemo

main(String[]) - Static method in class org.cometd.examples.ConsoleChatClient

mapUnion() - Static method in class org.cometd.oort.OortObjectMergers

markActive() - Method in class org.cometd.server.ext.ActivityExtension.SessionExtension

MarkedReference<T> - Class in org.cometd.bayeux

Immutable, non-volatile, non-atomic version of AtomicMarkableReference.

MarkedReference(T, boolean) - Constructor for class org.cometd.bayeux.MarkedReference

matches(ChannelId) - Method in class org.cometd.bayeux.ChannelId

Tests whether this ChannelId matches the given ChannelId.

MAX_BACKOFF_OPTION - Static variable in class org.cometd.client.BayeuxClient

MAX_CLOSE_REASON_LENGTH - Static variable in class org.cometd.client.websocket.common.AbstractWebSocketTransport

MAX_INTERVAL_FIELD - Static variable in interface org.cometd.bayeux.Message

MAX_INTERVAL_OPTION - Static variable in class org.cometd.server.AbstractServerTransport

MAX_LAZY_TIMEOUT_OPTION - Static variable in class org.cometd.server.AbstractServerTransport

MAX_MESSAGE_SIZE_OPTION - Static variable in class org.cometd.client.transport.ClientTransport

MAX_MESSAGE_SIZE_OPTION - Static variable in class org.cometd.server.AbstractServerTransport

MAX_NETWORK_DELAY - Static variable in class org.cometd.benchmark.Config

MAX_NETWORK_DELAY_OPTION - Static variable in class org.cometd.client.transport.ClientTransport

MAX_PROCESSING_OPTION - Static variable in class org.cometd.server.AbstractServerTransport

MAX_QUEUE_OPTION - Static variable in class org.cometd.server.AbstractServerTransport

MAX_SEND_BAYEUX_MESSAGE_SIZE_OPTION - Static variable in class org.cometd.client.transport.ClientTransport

MAX_SESSIONS_PER_BROWSER_OPTION - Static variable in class org.cometd.server.http.AbstractHttpTransport

merge(Collection<OortObject.Info<List<E>>>) - Method in class org.cometd.oort.OortObjectMergers.ListUnionMerger

merge(Collection<OortObject.Info<T>>) - Method in interface org.cometd.oort.OortObject.Merger

Merges the given OortObject.Infos.

merge(OortObject.Merger<T, R>) - Method in class org.cometd.oort.OortObject

Merges the objects of all the OortObject.Infos known to this oort object using the given strategy.

Message - Interface in org.cometd.bayeux

The Bayeux protocol exchange information by means of messages.

MESSAGE_PARAM - Static variable in class org.cometd.server.http.AbstractHttpTransport

Message.Mutable - Interface in org.cometd.bayeux

The mutable version of a Message

MessageClientTransport - Interface in org.cometd.client.transport

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.

messages - Variable in class org.cometd.server.http.AbstractHttpTransport.Context

MESSAGES_PER_FRAME_OPTION - Static variable in class org.cometd.server.websocket.common.AbstractWebSocketTransport

messagesFailure(Throwable, List<? extends Message>) - Method in class org.cometd.client.BayeuxClient

META - Static variable in class org.cometd.bayeux.BinaryData

META - Static variable in interface org.cometd.bayeux.Channel

Constant representing the meta prefix

META_CONNECT - Static variable in interface org.cometd.bayeux.Channel

Constant representing the connect meta channel

META_CONNECT_DELIVERY_OPTION - Static variable in class org.cometd.server.AbstractServerTransport

META_CONNECT_TIMEOUT - Static variable in class org.cometd.benchmark.Config

META_DISCONNECT - Static variable in interface org.cometd.bayeux.Channel

Constant representing the disconnect meta channel

META_HANDSHAKE - Static variable in interface org.cometd.bayeux.Channel

Constant representing the handshake meta channel.

META_SUBSCRIBE - Static variable in interface org.cometd.bayeux.Channel

Constant representing the subscribe meta channel

META_UNSUBSCRIBE - Static variable in interface org.cometd.bayeux.Channel

Constant representing the unsubscribe meta channel

metaConnectCycle - Variable in class org.cometd.server.http.AbstractHttpTransport.Context

MIN_VERSION_FIELD - Static variable in interface org.cometd.bayeux.Message

modifyHandshake(HandshakeRequest, HandshakeResponse) - Method in class org.cometd.server.websocket.javax.WebSocketTransport

modifyUpgrade(JettyServerUpgradeRequest, JettyServerUpgradeResponse) - Method in class org.cometd.server.websocket.jetty.JettyWebSocketTransport

Monitor() - Constructor for class org.cometd.examples.CometDDemoServlet.Monitor

MonitoringBlockingArrayQueue(int, int) - Constructor for class org.cometd.benchmark.MonitoringQueuedThreadPool.MonitoringBlockingArrayQueue

MonitoringQueuedThreadPool - Class in org.cometd.benchmark

MonitoringQueuedThreadPool(int) - Constructor for class org.cometd.benchmark.MonitoringQueuedThreadPool

MonitoringQueuedThreadPool.MonitoringBlockingArrayQueue - Class in org.cometd.benchmark

MonitoringThreadPoolExecutor - Class in org.cometd.benchmark

MonitoringThreadPoolExecutor(int, long, TimeUnit) - Constructor for class org.cometd.benchmark.MonitoringThreadPoolExecutor

MonitoringThreadPoolExecutor(int, long, TimeUnit, RejectedExecutionHandler) - Constructor for class org.cometd.benchmark.MonitoringThreadPoolExecutor

monitorMeta(ServerSession, ServerMessage) - Method in class org.cometd.examples.CometDDemoServlet.Monitor

monitorSubscribe(ServerSession, ServerMessage) - Method in class org.cometd.examples.CometDDemoServlet.Monitor

monitorUnsubscribe(ServerSession, ServerMessage) - Method in class org.cometd.examples.CometDDemoServlet.Monitor

MULTI_SESSION_INTERVAL_OPTION - Static variable in class org.cometd.server.http.AbstractHttpTransport

N

NAME - Static variable in class org.cometd.client.http.common.AbstractHttpClientTransport

NAME - Static variable in class org.cometd.client.websocket.common.AbstractWebSocketTransport

NAME - Static variable in class org.cometd.server.http.JSONPTransport

NAME - Static variable in class org.cometd.server.http.JSONTransport

NAME - Static variable in class org.cometd.server.websocket.common.AbstractWebSocketTransport

NAME_FIELD - Static variable in class org.cometd.oort.OortObject.Info

negotiate(Object[], String) - Method in class org.cometd.client.transport.TransportRegistry

newAsyncJSON() - Method in class org.cometd.common.JettyJSONContext.AsyncJSONFactory

newAsyncParser() - Method in class org.cometd.common.JacksonJSONContext

newAsyncParser() - Method in class org.cometd.common.JettyJSONContext

newAsyncParser() - Method in interface org.cometd.common.JSONContext

newAsyncParser() - Method in class org.cometd.server.JettyJSONContextServer

newBayeuxServer() - Method in class org.cometd.server.CometDServlet

newChannel(ChannelId) - Method in class org.cometd.client.BayeuxClient

newChannel(ChannelId) - Method in class org.cometd.common.AbstractClientSession

newChannel(ChannelId) - Method in class org.cometd.server.LocalSessionImpl

newChannelId(String) - Method in class org.cometd.client.BayeuxClient

newChannelId(String) - Method in class org.cometd.common.AbstractClientSession

newChannelId(String) - Method in class org.cometd.server.BayeuxServerImpl

newChannelId(String) - Method in class org.cometd.server.LocalSessionImpl

newClientTransport(String, Map<String, Object>) - Method in class org.cometd.client.http.jetty.JettyHttpClientTransport.Factory

newClientTransport(String, Map<String, Object>) - Method in class org.cometd.client.http.okhttp.OkHttpClientTransport.Factory

newClientTransport(String, Map<String, Object>) - Method in interface org.cometd.client.transport.ClientTransport.Factory

newClientTransport(String, Map<String, Object>) - Method in class org.cometd.client.websocket.javax.WebSocketTransport.Factory

newClientTransport(String, Map<String, Object>) - Method in class org.cometd.client.websocket.jetty.JettyWebSocketTransport.Factory

newClientTransport(String, Map<String, Object>) - Method in class org.cometd.client.websocket.okhttp.OkHttpWebSocketTransport.Factory

newDelegate() - Method in class org.cometd.client.websocket.javax.WebSocketTransport

newDelegate() - Method in class org.cometd.client.websocket.jetty.JettyWebSocketTransport

newDelegate() - Method in class org.cometd.client.websocket.okhttp.OkHttpWebSocketTransport

newHttpScheduler(AbstractHttpTransport.Context, Promise<Void>, ServerMessage.Mutable, long) - Method in class org.cometd.server.http.AbstractStreamHttpTransport

newHttpScheduler(AbstractHttpTransport.Context, Promise<Void>, ServerMessage.Mutable, long) - Method in class org.cometd.server.http.AsyncJSONTransport

newInfo(T) - Method in class org.cometd.oort.OortObject

newLocalSession(String) - Method in interface org.cometd.bayeux.server.BayeuxServer

Creates a new LocalSession.

newLocalSession(String) - Method in class org.cometd.server.BayeuxServerImpl

newMessage() - Method in interface org.cometd.bayeux.server.BayeuxServer

newMessage() - Method in class org.cometd.common.AbstractClientSession

newMessage() - Method in class org.cometd.server.BayeuxServerImpl

newMessage() - Method in class org.cometd.server.LocalSessionImpl

newMessage(ServerMessage) - Method in class org.cometd.server.BayeuxServerImpl

newMessageId() - Method in class org.cometd.common.AbstractClientSession

newMetaConnectCycle() - Method in class org.cometd.server.AbstractServerTransport

newObject(Object) - Method in interface org.cometd.oort.OortObject.Factory

Creates a new non-null object from the given representation.

newOort(BayeuxServer, String) - Method in class org.cometd.oort.OortConfigServlet

Creates and returns a new Oort instance.

newOortComet(String) - Method in class org.cometd.oort.Oort

newOortComet(String, ClientTransport, ClientTransport[]) - Method in class org.cometd.oort.Oort

newOortHandshakeFields(String, String) - Method in class org.cometd.oort.Oort

newRequestURI(List<Message.Mutable>) - Method in class org.cometd.client.http.common.AbstractHttpClientTransport

newRoot() - Method in class org.cometd.common.JettyJSONContext

newRoot() - Method in class org.cometd.common.JettyJSONContextClient

newRoot() - Method in class org.cometd.server.JettyJSONContextServer

newRootArray(int) - Method in class org.cometd.common.JettyJSONContext

newRootArray(int) - Method in class org.cometd.common.JettyJSONContextClient

newRootArray(int) - Method in class org.cometd.server.JettyJSONContextServer

newServerAnnotationProcessor(BayeuxServer) - Method in class org.cometd.annotation.server.AnnotationCometDServlet

newServerSession() - Method in class org.cometd.server.BayeuxServerImpl

newService(String) - Method in class org.cometd.annotation.server.AnnotationCometDServlet

newSessionExtension(ServerSession) - Method in class org.cometd.server.ext.AcknowledgedMessagesExtension

newSessionExtension(ServerSession, ServerMessage) - Method in class org.cometd.server.ext.ActivityExtension

Creates a new ServerSession.Extension that monitors the activity of the given ServerSession

newSeti(Oort) - Method in class org.cometd.oort.SetiServlet

newWebSocketEndPoint(BayeuxContext) - Method in class org.cometd.server.websocket.javax.WebSocketTransport

newWebSocketEndPoint(BayeuxContext) - Method in class org.cometd.server.websocket.jetty.JettyWebSocketTransport

next() - Method in class org.cometd.client.BayeuxClient.BackOffStrategy.Constant

next() - Method in class org.cometd.client.BayeuxClient.BackOffStrategy.Linear

next() - Method in interface org.cometd.client.BayeuxClient.BackOffStrategy

nextBatch() - Method in class org.cometd.server.ext.BatchArrayQueue

NoMarkupFilter - Class in org.cometd.server.filter

NoMarkupFilter() - Constructor for class org.cometd.server.filter.NoMarkupFilter

None(long) - Constructor for class org.cometd.server.AbstractServerTransport.Scheduler.None

nonFirstSubscribe(Message.Mutable, ClientSessionChannel.MessageListener, ClientSession.MessageListener) - Method in class org.cometd.client.BayeuxClient.BayeuxClientChannel

nonFirstSubscribe(Message.Mutable, ClientSessionChannel.MessageListener, ClientSession.MessageListener) - Method in class org.cometd.common.AbstractClientSession.AbstractSessionChannel

nonLastUnSubscribe(Message.Mutable, ClientSessionChannel.MessageListener, ClientSession.MessageListener) - Method in class org.cometd.client.BayeuxClient.BayeuxClientChannel

nonLastUnSubscribe(Message.Mutable, ClientSessionChannel.MessageListener, ClientSession.MessageListener) - Method in class org.cometd.common.AbstractClientSession.AbstractSessionChannel

noop() - Static method in interface org.cometd.bayeux.Promise

NOOP - Static variable in interface org.cometd.bayeux.client.ClientSession.MessageListener

NOOP - Static variable in interface org.cometd.bayeux.Promise

Shared instance whose methods are implemented empty,

NORMAL_CLOSE_CODE - Static variable in class org.cometd.client.websocket.common.AbstractWebSocketTransport

normalizeURLMapping(String) - Method in class org.cometd.server.websocket.common.AbstractWebSocketTransport

NoScriptsFilter - Class in org.cometd.server.filter

NoScriptsFilter() - Constructor for class org.cometd.server.filter.NoScriptsFilter

notifyCallback(ClientSession.MessageListener, Message.Mutable) - Method in class org.cometd.common.AbstractClientSession

notifyListeners(Message.Mutable) - Method in class org.cometd.common.AbstractClientSession

notifyMessageListeners(Message) - Method in class org.cometd.common.AbstractClientSession.AbstractSessionChannel

notifyOnMessage(ClientSessionChannel.MessageListener, Message) - Method in class org.cometd.common.AbstractClientSession.AbstractSessionChannel

notifyRemoved(OortObject.Info<T>) - Method in class org.cometd.oort.OortObject

notifyResumed(ServerMessage, boolean) - Method in class org.cometd.server.ServerSessionImpl

notifySuspended(ServerMessage, long) - Method in class org.cometd.server.ServerSessionImpl

notifyUpdated(OortObject.Info<T>, OortObject.Info<T>) - Method in class org.cometd.oort.OortObject

O

OBJECT_FIELD - Static variable in class org.cometd.oort.OortObject.Info

ObjectMapperGenerator() - Constructor for class org.cometd.common.JacksonJSONContext.ObjectMapperGenerator

observeChannel(String) - Method in class org.cometd.oort.Oort

Observes the given channel, registering to receive messages from the Oort comets connected to this Oort instance.

observeComet(String) - Method in class org.cometd.oort.Oort

Connects (if not already connected) and observes another Oort instance (identified by the given URL) via a OortComet instance.

offer(Runnable) - Method in class org.cometd.benchmark.MonitoringQueuedThreadPool.MonitoringBlockingArrayQueue

offer(T) - Method in class org.cometd.server.ext.BatchArrayQueue

OkHttpClientTransport - Class in org.cometd.client.http.okhttp

OkHttpClientTransport(String, Map<String, Object>, ScheduledExecutorService, OkHttpClient) - Constructor for class org.cometd.client.http.okhttp.OkHttpClientTransport

OkHttpClientTransport(String, Map<String, Object>, OkHttpClient) - Constructor for class org.cometd.client.http.okhttp.OkHttpClientTransport

OkHttpClientTransport(Map<String, Object>, OkHttpClient) - Constructor for class org.cometd.client.http.okhttp.OkHttpClientTransport

OkHttpClientTransport.Factory - Class in org.cometd.client.http.okhttp

OkHttpDelegate() - Constructor for class org.cometd.client.websocket.okhttp.OkHttpWebSocketTransport.OkHttpDelegate

OkHttpWebSocketTransport - Class in org.cometd.client.websocket.okhttp

OkHttpWebSocketTransport(String, Map<String, Object>, ScheduledExecutorService, OkHttpClient) - Constructor for class org.cometd.client.websocket.okhttp.OkHttpWebSocketTransport

OkHttpWebSocketTransport(Map<String, Object>, OkHttpClient) - Constructor for class org.cometd.client.websocket.okhttp.OkHttpWebSocketTransport

OkHttpWebSocketTransport.Factory - Class in org.cometd.client.websocket.okhttp

OkHttpWebSocketTransport.OkHttpDelegate - Class in org.cometd.client.websocket.okhttp

onAdded(OortObject.Info<List<E>>, List<E>) - Method in interface org.cometd.oort.OortList.ElementListener

Callback method invoked when elements are added to the entity list.

onAllDataRead() - Method in class org.cometd.server.http.AsyncJSONTransport.AbstractReader

onAllDataRead() - Method in class org.cometd.server.http.AsyncJSONTransport.CharsetReader

onAllDataRead() - Method in class org.cometd.server.http.AsyncJSONTransport.UTF8Reader

onBatchReceive(ServerSession, long) - Method in interface org.cometd.server.ext.AcknowledgedMessagesExtension.Listener

Callback method invoked when a client session confirms it has received the given batch of messages.

onBatchSend(ServerSession, List<ServerMessage>, long) - Method in interface org.cometd.server.ext.AcknowledgedMessagesExtension.Listener

Callback method invoked when a batch of message is about to be sent to a client session.

onClose(int, String) - Method in class org.cometd.client.websocket.common.AbstractWebSocketTransport.Delegate

onClose(int, String) - Method in class org.cometd.server.websocket.common.AbstractWebSocketEndPoint

onClose(int, String) - Method in class org.cometd.server.websocket.common.AbstractWebSocketTransport

onClose(Session, CloseReason) - Method in class org.cometd.client.websocket.javax.WebSocketTransport.WebSocketDelegate.WebSocketEndpoint

onClose(Session, CloseReason) - Method in class org.cometd.server.websocket.javax.WebSocketEndPoint

onComplete(AsyncEvent) - Method in class org.cometd.server.http.AbstractHttpTransport.LongPollScheduler

onData(String) - Method in class org.cometd.client.websocket.common.AbstractWebSocketTransport.Delegate

onDataAvailable() - Method in class org.cometd.server.http.AsyncJSONTransport.AbstractReader

onError(AsyncEvent) - Method in class org.cometd.server.http.AbstractHttpTransport.LongPollScheduler

onError(Session, Throwable) - Method in class org.cometd.client.websocket.javax.WebSocketTransport.WebSocketDelegate.WebSocketEndpoint

onError(Session, Throwable) - Method in class org.cometd.server.websocket.javax.WebSocketEndPoint

onError(Throwable) - Method in class org.cometd.server.http.AsyncJSONTransport.AbstractReader

onError(Throwable) - Method in class org.cometd.server.http.AsyncJSONTransport.Writer

onError(Throwable) - Method in class org.cometd.server.websocket.common.AbstractWebSocketEndPoint

onFailure(Throwable, List<? extends Message>) - Method in interface org.cometd.client.transport.TransportListener

Callback method invoked when a failure to send or receive messages occurs.

onForward(OortService.Request) - Method in class org.cometd.oort.OortPrimaryLong

onForward(OortService.Request) - Method in class org.cometd.oort.OortService

Subclasses must implement this method, that runs on the owner node, to implement the action functionality.

onForwardFailed(Object, C) - Method in class org.cometd.oort.OortService

Subclasses must implement this method, that runs on the requesting node, to complete the functionality after the action failed on the owner node.

onForwardFailed(Object, OortPrimaryLong.Context) - Method in class org.cometd.oort.OortPrimaryLong

onForwardMessage(Map<String, Object>, boolean) - Method in class org.cometd.oort.OortService

onForwardSucceeded(Long, OortPrimaryLong.Context) - Method in class org.cometd.oort.OortPrimaryLong

onForwardSucceeded(R, C) - Method in class org.cometd.oort.OortService

Subclasses must implement this method, that runs on the requesting node, to complete the functionality after the action has been successfully run on the owner node.

onHandshakeRequest(String, Request.Builder) - Method in class org.cometd.client.websocket.okhttp.OkHttpWebSocketTransport

onHandshakeRequest(Map<String, List<String>>) - Method in class org.cometd.client.websocket.javax.WebSocketTransport

onHandshakeRequest(HttpRequest) - Method in class org.cometd.client.websocket.jetty.JettyWebSocketTransport

onHandshakeResponse(HandshakeResponse) - Method in class org.cometd.client.websocket.javax.WebSocketTransport

onHandshakeResponse(Response) - Method in class org.cometd.client.websocket.okhttp.OkHttpWebSocketTransport

onHandshakeResponse(HttpRequest, HttpResponse) - Method in class org.cometd.client.websocket.jetty.JettyWebSocketTransport

onItem(OortObject.Info<ConcurrentMap<K, V>>, Map<String, Object>) - Method in class org.cometd.oort.OortMap

onItem(OortObject.Info<List<E>>, Map<String, Object>) - Method in class org.cometd.oort.OortList

onItem(OortObject.Info<T>, Map<String, Object>) - Method in class org.cometd.oort.OortContainer

onMessage(String) - Method in class org.cometd.client.websocket.javax.WebSocketTransport.WebSocketDelegate

onMessage(String) - Method in class org.cometd.server.websocket.javax.WebSocketEndPoint

onMessage(String, Promise<Void>) - Method in class org.cometd.server.websocket.common.AbstractWebSocketEndPoint

onMessage(ClientSessionChannel, Message) - Method in interface org.cometd.bayeux.client.ClientSessionChannel.MessageListener

Callback invoked when a message is received on the given channel.

onMessage(Message) - Method in interface org.cometd.bayeux.client.ClientSession.MessageListener

Callback invoked when a remote call response is received.

onMessage(ServerSession, ServerChannel, ServerMessage.Mutable) - Method in interface org.cometd.bayeux.server.ServerChannel.MessageListener

Blocking version of ServerChannel.MessageListener.onMessage(ServerSession, ServerChannel, ServerMessage.Mutable, Promise).

onMessage(ServerSession, ServerChannel, ServerMessage.Mutable) - Method in class org.cometd.oort.Oort.CloudListener

onMessage(ServerSession, ServerChannel, ServerMessage.Mutable) - Method in class org.cometd.oort.OortService

onMessage(ServerSession, ServerChannel, ServerMessage.Mutable) - Method in class org.cometd.server.filter.DataFilterMessageListener

onMessage(ServerSession, ServerChannel, ServerMessage.Mutable, Promise<Boolean>) - Method in interface org.cometd.bayeux.server.ServerChannel.MessageListener

Callback invoked when a message is being published.

onMessage(ServerSession, ServerSession, ServerMessage) - Method in interface org.cometd.bayeux.server.ServerSession.MessageListener

Blocking version of ServerSession.MessageListener.onMessage(ServerSession, ServerSession, ServerMessage, Promise).

onMessage(ServerSession, ServerSession, ServerMessage, Promise<Boolean>) - Method in interface org.cometd.bayeux.server.ServerSession.MessageListener

Callback invoked when a message is sent.

onMessages(List<Message.Mutable>) - Method in interface org.cometd.client.transport.TransportListener

Callback method invoked when a batch of message is received.

onMessages(List<Message.Mutable>) - Method in class org.cometd.client.websocket.common.AbstractWebSocketTransport.Delegate

onObject(Map<String, Object>) - Method in class org.cometd.oort.OortContainer

onObject(Map<String, Object>) - Method in class org.cometd.oort.OortObject

onOpen(Session, EndpointConfig) - Method in class org.cometd.client.websocket.javax.WebSocketTransport.WebSocketDelegate.WebSocketEndpoint

onOpen(Session, EndpointConfig) - Method in class org.cometd.server.websocket.javax.WebSocketEndPoint

onPut(OortObject.Info<ConcurrentMap<K, V>>, OortMap.Entry<K, V>) - Method in interface org.cometd.oort.OortMap.EntryListener

Callback method invoked after an entry is put into the entity map.

onRemoved(OortObject.Info<ConcurrentMap<K, V>>) - Method in class org.cometd.oort.OortMap.DeltaListener

onRemoved(OortObject.Info<ConcurrentMap<K, V>>, OortMap.Entry<K, V>) - Method in interface org.cometd.oort.OortMap.EntryListener

Callback method invoked after an entry is removed from the entity map.

onRemoved(OortObject.Info<List<E>>) - Method in class org.cometd.oort.OortList.DeltaListener

onRemoved(OortObject.Info<List<E>>, List<E>) - Method in interface org.cometd.oort.OortList.ElementListener

Callback method invoked when elements are removed from the entity list.

onRemoved(OortObject.Info<T>) - Method in interface org.cometd.oort.OortObject.Listener

Callback method invoked when the object value is removed, for example because the correspondent node has been shut down or crashed.

onResult(D) - Method in class org.cometd.oort.OortObject.Result.Deferred

onResult(R) - Method in interface org.cometd.oort.OortObject.Result

Callback method invoked when the result is available.

onResultMessage(Map<String, Object>) - Method in class org.cometd.oort.OortService

onResumed(ServerSession, ServerMessage, boolean) - Method in interface org.cometd.bayeux.server.ServerSession.HeartBeatListener

Callback invoked to notify that a /meta/connect message has been resumed.

onSending(List<? extends Message>) - Method in interface org.cometd.client.transport.TransportListener

Callback method invoked when the batch of messages is being sent.

onStartAsync(AsyncEvent) - Method in class org.cometd.server.http.AbstractHttpTransport.LongPollScheduler

onSuspended(ServerSession, ServerMessage, long) - Method in interface org.cometd.bayeux.server.ServerSession.HeartBeatListener

Callback invoked to notify that a /meta/connect message has been suspended.

onTimeout(AsyncEvent) - Method in class org.cometd.server.http.AbstractHttpTransport.LongPollScheduler

onTimeout(List<? extends Message>, Promise<Long>) - Method in interface org.cometd.client.transport.TransportListener

Callback method invoked when the send of a batch of messages expires before receiving a response from the server, controlled by the maxNetworkDelay option.

onTransportFailure(String, String, Throwable) - Method in class org.cometd.client.BayeuxClient

onTransportFailure(Message, ClientTransport.FailureInfo, ClientTransport.FailureHandler) - Method in class org.cometd.client.BayeuxClient

onUpdated(OortObject.Info<ConcurrentMap<K, V>>, OortObject.Info<ConcurrentMap<K, V>>) - Method in class org.cometd.oort.OortMap.DeltaListener

onUpdated(OortObject.Info<List<E>>, OortObject.Info<List<E>>) - Method in class org.cometd.oort.OortList.DeltaListener

onUpdated(OortObject.Info<T>, OortObject.Info<T>) - Method in interface org.cometd.oort.OortObject.Listener

Callback method invoked when the object value is updated.

onWebSocketBinary(byte[], int, int) - Method in class org.cometd.client.websocket.jetty.JettyWebSocketTransport.JettyWebSocketDelegate

onWebSocketBinary(byte[], int, int) - Method in class org.cometd.server.websocket.jetty.JettyWebSocketEndPoint

onWebSocketClose(int, String) - Method in class org.cometd.client.websocket.jetty.JettyWebSocketTransport.JettyWebSocketDelegate

onWebSocketClose(int, String) - Method in class org.cometd.server.websocket.jetty.JettyWebSocketEndPoint

onWebSocketConnect(Session) - Method in class org.cometd.client.websocket.jetty.JettyWebSocketTransport.JettyWebSocketDelegate

onWebSocketConnect(Session) - Method in class org.cometd.server.websocket.jetty.JettyWebSocketEndPoint

onWebSocketError(Throwable) - Method in class org.cometd.client.websocket.jetty.JettyWebSocketTransport.JettyWebSocketDelegate

onWebSocketError(Throwable) - Method in class org.cometd.server.websocket.jetty.JettyWebSocketEndPoint

onWebSocketText(String) - Method in class org.cometd.client.websocket.jetty.JettyWebSocketTransport.JettyWebSocketDelegate

onWebSocketText(String) - Method in class org.cometd.server.websocket.jetty.JettyWebSocketEndPoint

onWritePossible() - Method in class org.cometd.server.http.AsyncJSONTransport.Writer

Oort - Class in org.cometd.oort

Oort is the cluster manager that links one CometD server to a set of other CometD servers.

Oort(BayeuxServer, String) - Constructor for class org.cometd.oort.Oort

OORT_ATTRIBUTE - Static variable in class org.cometd.oort.Oort

OORT_CHANNELS_PARAM - Static variable in class org.cometd.oort.OortConfigServlet

OORT_CLIENT_TRANSPORT_FACTORIES_PARAM - Static variable in class org.cometd.oort.OortConfigServlet

OORT_CLOUD_CHANNEL - Static variable in class org.cometd.oort.Oort

OORT_CLOUD_PARAM - Static variable in class org.cometd.oort.OortStaticConfigServlet

OORT_ENABLE_ACK_EXTENSION_PARAM - Static variable in class org.cometd.oort.OortConfigServlet

OORT_ENABLE_BINARY_EXTENSION_PARAM - Static variable in class org.cometd.oort.OortConfigServlet

OORT_JSON_CONTEXT_PARAM - Static variable in class org.cometd.oort.OortConfigServlet

OORT_MULTICAST_ADVERTISE_INTERVAL_PARAM - Static variable in class org.cometd.oort.OortMulticastConfigServlet

OORT_MULTICAST_BIND_ADDRESS_PARAM - Static variable in class org.cometd.oort.OortMulticastConfigServlet

OORT_MULTICAST_CONNECT_TIMEOUT_PARAM - Static variable in class org.cometd.oort.OortMulticastConfigServlet

OORT_MULTICAST_GROUP_ADDRESS_PARAM - Static variable in class org.cometd.oort.OortMulticastConfigServlet

OORT_MULTICAST_GROUP_INTERFACES_PARAM - Static variable in class org.cometd.oort.OortMulticastConfigServlet

OORT_MULTICAST_GROUP_PORT_PARAM - Static variable in class org.cometd.oort.OortMulticastConfigServlet

OORT_MULTICAST_MAX_TRANSMISSION_LENGTH_PARAM - Static variable in class org.cometd.oort.OortMulticastConfigServlet

OORT_MULTICAST_TIME_TO_LIVE_PARAM - Static variable in class org.cometd.oort.OortMulticastConfigServlet

OORT_OBJECTS_CHANNEL - Static variable in class org.cometd.oort.OortObject

OORT_SECRET_PARAM - Static variable in class org.cometd.oort.OortConfigServlet

OORT_SERVICE_CHANNEL - Static variable in class org.cometd.oort.Oort

OORT_URL_FIELD - Static variable in class org.cometd.oort.OortObject.Info

OORT_URL_PARAM - Static variable in class org.cometd.oort.OortConfigServlet

Oort.CloudListener - Class in org.cometd.oort

This listener handles messages sent to /oort/cloud that contains the list of comets connected to the Oort that just joined the cloud.

Oort.CometListener - Interface in org.cometd.oort

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 - Class in org.cometd.oort

Comet event object delivered to Oort.CometListener methods.

OortComet - Class in org.cometd.oort

The Oort comet client connects a local Oort comet server to a remote Oort comet server.

OortComet(Oort, String, ScheduledExecutorService, ClientTransport, ClientTransport...) - Constructor for class org.cometd.oort.OortComet

OortConfigServlet - Class in org.cometd.oort

This servlet serves as a base class for initializing and configuring an instance of the Oort CometD cluster manager.

OortConfigServlet() - Constructor for class org.cometd.oort.OortConfigServlet

OortContainer<T> - Class in org.cometd.oort

OortContainer(Oort, String, OortObject.Factory<T>) - Constructor for class org.cometd.oort.OortContainer

OortList<E> - Class in org.cometd.oort

A specialized oort object whose entity is a List.

OortList(Oort, String, OortObject.Factory<List<E>>) - Constructor for class org.cometd.oort.OortList

OortList.DeltaListener<E> - Class in org.cometd.oort

An implementation of OortObject.Listener that converts whole list events into OortList.ElementListener events.

OortList.ElementListener<E> - Interface in org.cometd.oort

Listener for element events that update the entity list, either locally or remotely.

OortLong - Class in org.cometd.oort

A shared atomic long made of an internal AtomicLong and of an internal OortObject<Long>.

OortLong(Oort, String) - Constructor for class org.cometd.oort.OortLong

OortLong(Oort, String, long) - Constructor for class org.cometd.oort.OortLong

OortLongMap<V> - Class in org.cometd.oort

The equivalent of an OortMap<Long,V>.

OortLongMap(Oort, String, OortObject.Factory<ConcurrentMap<Long, V>>) - Constructor for class org.cometd.oort.OortLongMap

OortMap<K,V> - Class in org.cometd.oort

A specialized oort object whose entity is a ConcurrentMap.

OortMap(Oort, String, OortObject.Factory<ConcurrentMap<K, V>>) - Constructor for class org.cometd.oort.OortMap

OortMap.DeltaListener<K,V> - Class in org.cometd.oort

An implementation of OortObject.Listener that converts whole map events into OortMap.EntryListener events.

OortMap.Entry<K,V> - Class in org.cometd.oort

A triple that holds the key, the previous value and the new value, used to notify entry updates:

OortMap.EntryListener<K,V> - Interface in org.cometd.oort

Listener for entry events that update the entity map, either locally or remotely.

OortMBean - Class in org.cometd.oort.jmx

OortMBean(Object) - Constructor for class org.cometd.oort.jmx.OortMBean

OortMulticastConfigServlet - Class in org.cometd.oort

This servlet initializes and configures an instance of the Oort CometD cluster manager via autodiscovery of other Oort comets using UDP multicast.

OortMulticastConfigServlet() - Constructor for class org.cometd.oort.OortMulticastConfigServlet

OortMulticastConfigurer - Class in org.cometd.oort

OortMulticastConfigurer(Oort) - Constructor for class org.cometd.oort.OortMulticastConfigurer

OortObject<T> - Class in org.cometd.oort

An OortObject represents a named composite entity that is distributed in an Oort cluster.

OortObject(Oort, String, OortObject.Factory<T>) - Constructor for class org.cometd.oort.OortObject

OortObject.Data<T> - Class in org.cometd.oort

OortObject.Factory<T> - Interface in org.cometd.oort

Factory that creates objects stored by OortObjects.

OortObject.Info<T> - Class in org.cometd.oort

The oort object part holding the object and the metadata associated with it.

OortObject.Listener<T> - Interface in org.cometd.oort

Listener for events that update the value of a OortObject.Info, either local or remote.

OortObject.Merger<T,R> - Interface in org.cometd.oort

A merge strategy for object values.

OortObject.Result<R> - Interface in org.cometd.oort

An asynchronous result.

OortObject.Result.Deferred<D> - Class in org.cometd.oort

Implementation of OortObject.Result that allows applications to block, waiting for the result, via OortObject.Result.Deferred.get(long, TimeUnit).

OortObjectFactories - Class in org.cometd.oort

OortObjectMergers - Class in org.cometd.oort

OortObjectMergers.ListUnionMerger<E> - Class in org.cometd.oort

OortPrimaryLong - Class in org.cometd.oort

A distributed counter service to be deployed on a Oort cluster that modifies a long value hosted in a "primary" node.

OortPrimaryLong(Oort, String, boolean) - Constructor for class org.cometd.oort.OortPrimaryLong

OortPrimaryLong(Oort, String, boolean, long) - Constructor for class org.cometd.oort.OortPrimaryLong

OortPrimaryLong.Callback - Interface in org.cometd.oort

Callback invoked when the result of the operation on the counter is available, or when the operation failed.

OortPrimaryLong.Context - Class in org.cometd.oort

OortPrimaryService<R,C> - Class in org.cometd.oort

OortPrimaryService extends OortService to allow applications to perform actions on entities that always live in a "primary" node.

OortPrimaryService(Oort, String, boolean) - Constructor for class org.cometd.oort.OortPrimaryService

OortService<R,C> - Class in org.cometd.oort

An OortService allows applications to forward actions to Oort nodes that own the entity onto which the action should be applied.

OortService(Oort, String) - Constructor for class org.cometd.oort.OortService

Creates an OortService with the given name.

OortService.Request - Class in org.cometd.oort

Encapsulates a forwarded request.

OortService.Result<U> - Class in org.cometd.oort

Encapsulates the result of a forwarded request returned by OortService.onForward(Request).

OortService.ServerContext - Class in org.cometd.oort

Utility context that stores the ServerSession and the ServerMessage.

OortStaticConfigServlet - Class in org.cometd.oort

This servlet initializes and configures an instance of the Oort CometD cluster manager with a static list of other Oort comet URLs.

OortStaticConfigServlet() - Constructor for class org.cometd.oort.OortStaticConfigServlet

OortStringMap<V> - Class in org.cometd.oort

The equivalent of an OortMap<String,V>.

OortStringMap(Oort, String, OortObject.Factory<ConcurrentMap<String, V>>) - Constructor for class org.cometd.oort.OortStringMap

org.cometd.annotation - package org.cometd.annotation

org.cometd.annotation.client - package org.cometd.annotation.client

org.cometd.annotation.server - package org.cometd.annotation.server

org.cometd.bayeux - package org.cometd.bayeux

org.cometd.bayeux.client - package org.cometd.bayeux.client

org.cometd.bayeux.server - package org.cometd.bayeux.server

org.cometd.benchmark - package org.cometd.benchmark

org.cometd.benchmark.client - package org.cometd.benchmark.client

org.cometd.benchmark.server - package org.cometd.benchmark.server

org.cometd.client - package org.cometd.client

org.cometd.client.ext - package org.cometd.client.ext

org.cometd.client.http.common - package org.cometd.client.http.common

org.cometd.client.http.jetty - package org.cometd.client.http.jetty

org.cometd.client.http.okhttp - package org.cometd.client.http.okhttp

org.cometd.client.transport - package org.cometd.client.transport

org.cometd.client.websocket.common - package org.cometd.client.websocket.common

org.cometd.client.websocket.javax - package org.cometd.client.websocket.javax

org.cometd.client.websocket.jetty - package org.cometd.client.websocket.jetty

org.cometd.client.websocket.okhttp - package org.cometd.client.websocket.okhttp

org.cometd.common - package org.cometd.common

org.cometd.examples - package org.cometd.examples

org.cometd.oort - package org.cometd.oort

org.cometd.oort.jmx - package org.cometd.oort.jmx

org.cometd.server - package org.cometd.server

org.cometd.server.authorizer - package org.cometd.server.authorizer

org.cometd.server.ext - package org.cometd.server.ext

org.cometd.server.filter - package org.cometd.server.filter

org.cometd.server.http - package org.cometd.server.http

org.cometd.server.jmx - package org.cometd.server.jmx

org.cometd.server.websocket.common - package org.cometd.server.websocket.common

org.cometd.server.websocket.javax - package org.cometd.server.websocket.javax

org.cometd.server.websocket.jetty - package org.cometd.server.websocket.jetty

outgoing(ClientSession, Message.Mutable, Promise<Boolean>) - Method in interface org.cometd.bayeux.client.ClientSession.Extension

Callback method invoked every time a message is outgoing.

outgoing(ServerSession, ServerSession, ServerMessage.Mutable, Promise<Boolean>) - Method in interface org.cometd.bayeux.server.BayeuxServer.Extension

Callback method invoked every time a message is outgoing.

outgoing(ServerSession, ServerSession, ServerMessage.Mutable, Promise<ServerMessage.Mutable>) - Method in interface org.cometd.bayeux.server.ServerSession.Extension

Callback method invoked every time a message is outgoing.

P

Param - Annotation Type in org.cometd.annotation

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.

parse(byte[], int, int) - Method in class org.cometd.common.BufferingJSONAsyncParser

parse(byte[], int, int) - Method in interface org.cometd.common.JSONContext.AsyncParser

parse(Reader) - Method in class org.cometd.common.JacksonJSONContext

parse(Reader) - Method in class org.cometd.common.JettyJSONContext

parse(Reader) - Method in interface org.cometd.common.JSONContext

Parses an array of messages from the given reader.

parse(Reader, Class<R>) - Method in interface org.cometd.common.JSONContext.Parser

Parses a JSON string from the given reader.

parse(String) - Method in class org.cometd.common.JacksonJSONContext

parse(String) - Method in class org.cometd.common.JettyJSONContext

parse(String) - Method in interface org.cometd.common.JSONContext

Parses an array of messages from the given string.

parse(String) - Static method in class org.cometd.server.websocket.common.CookieParser

parse(ByteBuffer) - Method in class org.cometd.common.BufferingJSONAsyncParser

parse(ByteBuffer) - Method in class org.cometd.common.JettyJSONContext.AsyncJSONParser

parse(ByteBuffer) - Method in interface org.cometd.common.JSONContext.AsyncParser

parseMessages(HttpServletRequest) - Method in class org.cometd.server.http.AbstractStreamHttpTransport

parseMessages(HttpServletRequest) - Method in class org.cometd.server.http.JSONPTransport

parseMessages(HttpServletRequest) - Method in class org.cometd.server.http.JSONTransport

parseMessages(BufferedReader, boolean) - Method in class org.cometd.server.AbstractServerTransport

parseMessages(String) - Method in class org.cometd.client.transport.ClientTransport

parseMessages(String) - Method in class org.cometd.server.AbstractServerTransport

parseMessages(String[]) - Method in class org.cometd.server.http.AbstractStreamHttpTransport

peek() - Method in class org.cometd.server.ext.BatchArrayQueue

PEER_FIELD - Static variable in class org.cometd.oort.OortObject.Info

PERMESSAGE_DEFLATE_OPTION - Static variable in class org.cometd.client.websocket.common.AbstractWebSocketTransport

Persistent() - Constructor for class org.cometd.bayeux.server.ConfigurableServerChannel.Initializer.Persistent

poll() - Method in class org.cometd.benchmark.MonitoringQueuedThreadPool.MonitoringBlockingArrayQueue

poll() - Method in class org.cometd.server.ext.BatchArrayQueue

poll(long, TimeUnit) - Method in class org.cometd.benchmark.MonitoringQueuedThreadPool.MonitoringBlockingArrayQueue

PREFIX - Static variable in class org.cometd.client.http.common.AbstractHttpClientTransport

PREFIX - Static variable in class org.cometd.client.websocket.common.AbstractWebSocketTransport

PREFIX - Static variable in class org.cometd.server.http.AbstractHttpTransport

PREFIX - Static variable in class org.cometd.server.http.JSONPTransport

PREFIX - Static variable in class org.cometd.server.http.JSONTransport

PREFIX - Static variable in class org.cometd.server.websocket.common.AbstractWebSocketTransport

presenceAdded(Seti.PresenceListener.Event) - Method in interface org.cometd.oort.Seti.PresenceListener

Callback method invoked when a presence is added to a remote Seti

presenceRemoved(Seti.PresenceListener.Event) - Method in interface org.cometd.oort.Seti.PresenceListener

Callback method invoked when a presence is removed from a remote Seti

printThreadPool(String, MonitoringQueuedThreadPool) - Static method in class org.cometd.benchmark.Config

privateChat(ServerSession, ServerMessage) - Method in class org.cometd.examples.ChatService

proceed(R) - Method in interface org.cometd.common.AsyncFoldLeft.Loop

Makes the loop proceed to the next element (or the end of the loop).

process(Object) - Method in class org.cometd.annotation.client.ClientAnnotationProcessor

Processes dependencies annotated with Session, callbacks annotated with Listener and Subscription and lifecycle methods annotated with PostConstruct.

process(Object) - Method in class org.cometd.annotation.server.ServerAnnotationProcessor

Processes dependencies annotated with Inject and Session, configuration methods annotated with Configure, callback methods annotated with Listener, Subscription and RemoteCall, and lifecycle methods annotated with PostConstruct.

process(String, AbstractHttpTransport.Context, Promise<Void>) - Method in class org.cometd.server.http.AsyncJSONTransport

process(AbstractHttpTransport.Context, Promise<Void>) - Method in class org.cometd.server.http.AbstractStreamHttpTransport

processBatch(long) - Method in class org.cometd.server.ext.AcknowledgedMessagesSessionExtension

processCallbacks(Object) - Method in class org.cometd.annotation.server.ServerAnnotationProcessor

Processes the callbacks annotated with Listener, Subscription and RemoteCall.

processConfigurations(Object) - Method in class org.cometd.annotation.server.ServerAnnotationProcessor

Processes the methods annotated with Configure.

processConnect(Message.Mutable) - Method in class org.cometd.client.BayeuxClient

processDependencies(Object) - Method in class org.cometd.annotation.server.ServerAnnotationProcessor

Processes the dependencies annotated with Inject and Session.

processDisconnect(Message.Mutable) - Method in class org.cometd.client.BayeuxClient

processHandshake(Message.Mutable) - Method in class org.cometd.client.BayeuxClient

processInjectable(Object, Object) - Method in class org.cometd.annotation.AnnotationProcessor

processInjectables(Object, List<Object>) - Method in class org.cometd.annotation.AnnotationProcessor

processMessage(Message.Mutable) - Method in class org.cometd.client.BayeuxClient

processMessages(AbstractHttpTransport.Context, List<ServerMessage.Mutable>, Promise<Void>) - Method in class org.cometd.server.http.AbstractHttpTransport

processParameters(Method) - Method in class org.cometd.annotation.AnnotationProcessor

processPostConstruct(Object) - Method in class org.cometd.annotation.AnnotationProcessor

processPostConstruct(Object) - Method in class org.cometd.annotation.client.ClientAnnotationProcessor

Processes lifecycle methods annotated with PostConstruct.

processPostConstruct(Object) - Method in class org.cometd.annotation.server.ServerAnnotationProcessor

Processes lifecycle methods annotated with PostConstruct.

processPreDestroy(Object) - Method in class org.cometd.annotation.AnnotationProcessor

processPreDestroy(Object) - Method in class org.cometd.annotation.client.ClientAnnotationProcessor

Processes lifecycle methods annotated with PreDestroy.

processPreDestroy(Object) - Method in class org.cometd.annotation.server.ServerAnnotationProcessor

Processes lifecycle methods annotated with PreDestroy.

processReply(ServerSessionImpl, ServerMessage.Mutable, Promise<ServerMessage.Mutable>) - Method in class org.cometd.server.AbstractServerTransport

processResponseContent(TransportListener, List<Message.Mutable>, String) - Method in class org.cometd.client.http.common.AbstractHttpClientTransport

processResponseMessages(TransportListener, List<Message.Mutable>) - Method in class org.cometd.client.http.common.AbstractHttpClientTransport

processService(ServerAnnotationProcessor, String) - Method in class org.cometd.annotation.server.AnnotationCometDServlet

processWrongResponseCode(TransportListener, List<Message.Mutable>, int) - Method in class org.cometd.client.http.common.AbstractHttpClientTransport

Promise<C> - Interface in org.cometd.bayeux

The future result of an operation, either a value if the operation succeeded, or a failure if the operation failed.

Promise.Completable<S> - Class in org.cometd.bayeux

A CompletableFuture that is also a Promise.

protectOortChannels(BayeuxServer) - Method in class org.cometd.oort.Oort

protectSetiChannels(BayeuxServer) - Method in class org.cometd.oort.Seti

PROTOCOL_OPTION - Static variable in class org.cometd.client.websocket.common.AbstractWebSocketTransport

PROTOCOL_OPTION - Static variable in class org.cometd.server.websocket.common.AbstractWebSocketTransport

provideOortURL() - Method in class org.cometd.oort.OortConfigServlet

Retrieves the oort.url parameter from this servlet init parameters.

publish(Object) - Method in interface org.cometd.bayeux.client.ClientSessionChannel

Publishes the given data onto this channel.

publish(Object, ClientSession.MessageListener) - Method in interface org.cometd.bayeux.client.ClientSessionChannel

Publishes the given data onto this channel, notifying the given callback of the publish result, whether successful or unsuccessful.

publish(Object, ClientSession.MessageListener) - Method in class org.cometd.common.AbstractClientSession.AbstractSessionChannel

publish(Message.Mutable, ClientSession.MessageListener) - Method in interface org.cometd.bayeux.client.ClientSessionChannel

Publishes the given message onto this channel, notifying the given callback of the publish result.

publish(Message.Mutable, ClientSession.MessageListener) - Method in class org.cometd.common.AbstractClientSession.AbstractSessionChannel

publish(Session, Object, Promise<Boolean>) - Method in interface org.cometd.bayeux.server.ServerChannel

Publishes the given information to this channel.

publish(Session, Object, Promise<Boolean>) - Method in class org.cometd.server.ServerChannelImpl

publish(Session, ServerMessage.Mutable, Promise<Boolean>) - Method in interface org.cometd.bayeux.server.ServerChannel

Publishes the given message to this channel, delivering the message to all the ServerSessions subscribed to this channel.

publish(Session, ServerMessage.Mutable, Promise<Boolean>) - Method in class org.cometd.server.ServerChannelImpl

publish(ServerSessionImpl, ServerChannelImpl, ServerMessage.Mutable, boolean, Promise<Boolean>) - Method in class org.cometd.server.BayeuxServerImpl

PUBLISH - org.cometd.bayeux.server.Authorizer.Operation

The operation to publish messages to a channel

pullInfo(String) - Method in class org.cometd.oort.OortObject

pushInfo(String, Map<String, Object>) - Method in class org.cometd.oort.OortObject

put(String, Object) - Method in class org.cometd.server.ServerMessageImpl

putAndShare(K, V, OortObject.Result<V>) - Method in class org.cometd.oort.OortMap

Updates a single entry of the local entity map with the given key and value, and broadcasts the operation to all nodes in the cluster.

putConvertor(String, JSON.Convertor) - Method in class org.cometd.common.JettyJSONContext

putCookie(HttpCookie) - Method in class org.cometd.client.BayeuxClient

putIfAbsentAndShare(K, V, OortObject.Result<V>) - Method in class org.cometd.oort.OortMap

Updates a single entry of the local entity map with the given key and value if it does not exist yet, and broadcasts the operation to all nodes in the cluster.

Q

queued(ServerSession, ServerMessage) - Method in interface org.cometd.bayeux.server.ServerSession.QueueListener

Callback invoked when a message is queued in the session queue.

queued(ServerSession, ServerMessage) - Method in class org.cometd.server.ext.AcknowledgedMessagesSessionExtension

queueMaxed(ServerSession, Queue<ServerMessage>, ServerSession, ServerMessage) - Method in interface org.cometd.bayeux.server.ServerSession.QueueMaxedListener

Callback invoked to notify when the message queue is exceeding the value configured for the transport with the option "maxQueue".

R

randomLong() - Method in class org.cometd.server.BayeuxServerImpl

rcv(ClientSession, Message.Mutable) - Method in interface org.cometd.bayeux.client.ClientSession.Extension

Callback method invoked every time a normal message is received.

rcv(ClientSession, Message.Mutable) - Method in class org.cometd.client.ext.BinaryExtension

rcv(ServerSession, ServerMessage.Mutable) - Method in interface org.cometd.bayeux.server.BayeuxServer.Extension

Blocking version of BayeuxServer.Extension.incoming(ServerSession, ServerMessage.Mutable, Promise) for non-meta messages.

rcv(ServerSession, ServerMessage.Mutable) - Method in interface org.cometd.bayeux.server.ServerSession.Extension

Blocking version of ServerSession.Extension.incoming(ServerSession, ServerMessage.Mutable, Promise) for non-meta messages.

rcv(ServerSession, ServerMessage.Mutable) - Method in class org.cometd.server.ext.AcknowledgedMessagesSessionExtension

rcv(ServerSession, ServerMessage.Mutable) - Method in class org.cometd.server.ext.ActivityExtension.SessionExtension

rcv(ServerSession, ServerMessage.Mutable) - Method in class org.cometd.server.ext.BinaryExtension

rcv(ServerSession, ServerMessage.Mutable) - Method in class org.cometd.server.ext.BinarySessionExtension

rcvMeta(ClientSession, Message.Mutable) - Method in interface org.cometd.bayeux.client.ClientSession.Extension

Callback method invoked every time a meta message is received.

rcvMeta(ClientSession, Message.Mutable) - Method in class org.cometd.client.ext.AckExtension

rcvMeta(ClientSession, Message.Mutable) - Method in class org.cometd.client.ext.TimesyncClientExtension

rcvMeta(ServerSession, ServerMessage.Mutable) - Method in interface org.cometd.bayeux.server.BayeuxServer.Extension

Blocking version of BayeuxServer.Extension.incoming(ServerSession, ServerMessage.Mutable, Promise) for meta messages.

rcvMeta(ServerSession, ServerMessage.Mutable) - Method in interface org.cometd.bayeux.server.ServerSession.Extension

Blocking version of ServerSession.Extension.incoming(ServerSession, ServerMessage.Mutable, Promise) for meta messages.

rcvMeta(ServerSession, ServerMessage.Mutable) - Method in class org.cometd.server.ext.AcknowledgedMessagesExtension

rcvMeta(ServerSession, ServerMessage.Mutable) - Method in class org.cometd.server.ext.AcknowledgedMessagesSessionExtension

rcvMeta(ServerSession, ServerMessage.Mutable) - Method in class org.cometd.server.ext.ActivityExtension

rcvMeta(ServerSession, ServerMessage.Mutable) - Method in class org.cometd.server.ext.ActivityExtension.SessionExtension

rcvMeta(ServerSession, ServerMessage.Mutable) - Method in class org.cometd.server.ext.TimesyncExtension

reAdvise() - Method in class org.cometd.server.ServerSessionImpl

receive(String) - Method in class org.cometd.oort.OortMulticastConfigurer

receive(String, String, Object) - Method in class org.cometd.oort.Seti.LocalLocation

receive(String, String, Object) - Method in interface org.cometd.oort.Seti.Location

receive(String, String, Object) - Method in class org.cometd.oort.Seti.SetiLocation

receive(Message.Mutable, Promise<Void>) - Method in class org.cometd.common.AbstractClientSession

Receives a message (from the server) and process it.

receive(Message.Mutable, Promise<Void>) - Method in class org.cometd.server.LocalSessionImpl

receiveBroadcast(Message) - Method in class org.cometd.oort.Seti

Receives messages broadcast by other Setis in the cloud.

receiveDirect(Message) - Method in class org.cometd.oort.Seti

Receives messages directly from other Setis in the cloud, containing messages to be delivered to sessions connected to this comet.

receiveLocalPresence(Map<String, Object>) - Method in class org.cometd.oort.Seti

receiveMessage(Map<String, Object>) - Method in class org.cometd.oort.Seti

Receives a seti message.

receiveOwnPublishes() - Method in annotation type org.cometd.annotation.Listener

receivePresence(Map<String, Object>) - Method in class org.cometd.oort.Seti

Receives a presence message.

receiveRemotePresence(Map<String, Object>) - Method in class org.cometd.oort.Seti

RECONNECT_FIELD - Static variable in interface org.cometd.bayeux.Message

RECONNECT_HANDSHAKE_VALUE - Static variable in interface org.cometd.bayeux.Message

RECONNECT_NONE_VALUE - Static variable in interface org.cometd.bayeux.Message

RECONNECT_RETRY_VALUE - Static variable in interface org.cometd.bayeux.Message

RegexFilter - Class in org.cometd.server.filter

RegexFilter() - Constructor for class org.cometd.server.filter.RegexFilter

registerCallback(String, ClientSession.MessageListener) - Method in class org.cometd.common.AbstractClientSession

registerMessages(TransportListener, List<Message.Mutable>) - Method in class org.cometd.client.websocket.common.AbstractWebSocketTransport.Delegate

registerService(Object) - Method in class org.cometd.annotation.server.AnnotationCometDServlet

registerSubscriber(String, ClientSessionChannel.MessageListener) - Method in class org.cometd.common.AbstractClientSession

REHANDSHAKING - org.cometd.client.BayeuxClient.State

State assumed when a first handshake failed and the handshake is retried, or when the Bayeux server requests a re-handshake

release() - Method in interface org.cometd.bayeux.client.ClientSessionChannel

Releases this channel from its ClientSession.

release() - Method in class org.cometd.common.AbstractClientSession.AbstractSessionChannel

remoteCall(String, Object, ClientSession.MessageListener) - Method in interface org.cometd.bayeux.client.ClientSession

Performs a remote call to the server, to the specified target, and with the given data as payload.

remoteCall(String, Object, ClientSession.MessageListener) - Method in class org.cometd.common.AbstractClientSession

RemoteCall - Annotation Type in org.cometd.annotation.server

Identifies callback methods on server-side services that are invoked when the client is performing a remote call.

RemoteCall.Caller - Interface in org.cometd.annotation.server

Objects implementing this interface represent remote clients that performed remote calls.

remove() - Method in interface org.cometd.bayeux.server.ServerChannel

Removes this channel, and all the children channels.

remove() - Method in class org.cometd.server.ext.BatchArrayQueue

remove() - Method in class org.cometd.server.ServerChannelImpl

remove(Object) - Method in class org.cometd.server.ext.BatchArrayQueue

removeAll(Collection<?>) - Method in class org.cometd.server.ext.BatchArrayQueue

removeAndShare(K, OortObject.Result<V>) - Method in class org.cometd.oort.OortMap

Removes the given key from the local entity map, and broadcasts the operation to all nodes in the cluster.

removeAndShare(OortObject.Result<Boolean>, E...) - Method in class org.cometd.oort.OortList

Removes the given elements to the local entity list, and then broadcasts the removal to all nodes in the cluster.

removeAssociationsAndPresences() - Method in class org.cometd.oort.Seti

removeAttribute(String) - Method in interface org.cometd.bayeux.Channel

Removes a named channel attribute.

removeAttribute(String) - Method in interface org.cometd.bayeux.Session

Removes a named session attribute.

removeAttribute(String) - Method in class org.cometd.common.AbstractClientSession.AbstractSessionChannel

removeAttribute(String) - Method in class org.cometd.common.AbstractClientSession

removeAttribute(String) - Method in class org.cometd.server.ServerChannelImpl

removeAttribute(String) - Method in class org.cometd.server.ServerSessionImpl

removeAuthorizer(Authorizer) - Method in interface org.cometd.bayeux.server.ConfigurableServerChannel

Removes the given Authorizer.

removeAuthorizer(Authorizer) - Method in class org.cometd.server.ServerChannelImpl

removeCometListener(Oort.CometListener) - Method in class org.cometd.oort.Oort

Deregisters the given listener from being notified of comet events.

removeCometListeners() - Method in class org.cometd.oort.Oort

Deregisters all comet listeners.

removed(ServerMessage, boolean) - Method in class org.cometd.server.ServerSessionImpl

removed(ServerSession, ServerMessage, boolean) - Method in interface org.cometd.bayeux.server.ServerSession.RemovedListener

Callback invoked when the session is removed.

removed(ServerSession, ServerMessage, boolean) - Method in class org.cometd.oort.Seti.LocalLocation

removeElementListener(OortList.ElementListener<E>) - Method in class org.cometd.oort.OortList

removeElementListeners() - Method in class org.cometd.oort.OortList

removeEntryListener(OortMap.EntryListener<K, V>) - Method in class org.cometd.oort.OortMap

removeEntryListeners() - Method in class org.cometd.oort.OortMap

removeExtension(ClientSession.Extension) - Method in interface org.cometd.bayeux.client.ClientSession

Removes an extension from this session.

removeExtension(ClientSession.Extension) - Method in class org.cometd.common.AbstractClientSession

removeExtension(BayeuxServer.Extension) - Method in interface org.cometd.bayeux.server.BayeuxServer

Removes the given extension from this Bayeux object.

removeExtension(BayeuxServer.Extension) - Method in class org.cometd.server.BayeuxServerImpl

removeExtension(ServerSession.Extension) - Method in interface org.cometd.bayeux.server.ServerSession

Removes the given extension from this session.

removeExtension(ServerSession.Extension) - Method in class org.cometd.server.ServerSessionImpl

removeListener(ClientSessionChannel.ClientSessionChannelListener) - Method in interface org.cometd.bayeux.client.ClientSessionChannel

Removes the given listener from this channel.

removeListener(ClientSessionChannel.ClientSessionChannelListener) - Method in class org.cometd.common.AbstractClientSession.AbstractSessionChannel

removeListener(BayeuxServer.BayeuxServerListener) - Method in interface org.cometd.bayeux.server.BayeuxServer

Removes a listener from this Bayeux object.

removeListener(BayeuxServer.BayeuxServerListener) - Method in class org.cometd.server.BayeuxServerImpl

removeListener(ConfigurableServerChannel.ServerChannelListener) - Method in interface org.cometd.bayeux.server.ConfigurableServerChannel

removeListener(ConfigurableServerChannel.ServerChannelListener) - Method in class org.cometd.server.ServerChannelImpl

removeListener(ServerSession.ServerSessionListener) - Method in interface org.cometd.bayeux.server.ServerSession

Removes the given listener from this session.

removeListener(ServerSession.ServerSessionListener) - Method in class org.cometd.server.ServerSessionImpl

removeListener(OortObject.Listener<Long>) - Method in class org.cometd.oort.OortLong

removeListener(OortObject.Listener<T>) - Method in class org.cometd.oort.OortObject

removeListener(AcknowledgedMessagesExtension.Listener) - Method in class org.cometd.server.ext.AcknowledgedMessagesExtension

removeListener(AcknowledgedMessagesExtension.Listener) - Method in class org.cometd.server.ext.AcknowledgedMessagesSessionExtension

removeListeners() - Method in class org.cometd.oort.OortLong

Removes all listeners.

removeListeners() - Method in class org.cometd.oort.OortObject

Removes all listeners.

removePresenceListener(Seti.PresenceListener) - Method in class org.cometd.oort.Seti

removePresenceListeners() - Method in class org.cometd.oort.Seti

removePresences(String) - Method in class org.cometd.oort.Seti

removeServerChannel(ServerChannelImpl) - Method in class org.cometd.server.BayeuxServerImpl

removeServerSession(ServerSession, boolean) - Method in class org.cometd.server.BayeuxServerImpl

removeService(String) - Method in class org.cometd.server.AbstractService

Unmaps all the methods that have been mapped to the given channel.

removeService(String, String) - Method in class org.cometd.server.AbstractService

Unmaps the method with the given name that has been mapped to the given channel.

removeSession(ServerSession) - Method in interface org.cometd.bayeux.server.BayeuxServer

Removes the given session from this BayeuxServer.

removeSession(ServerSession) - Method in class org.cometd.server.BayeuxServerImpl

removeTransportListener(TransportListener) - Method in class org.cometd.client.BayeuxClient

replacePunctuation(String, char) - Static method in class org.cometd.oort.Oort

replies - Variable in class org.cometd.server.http.AbstractHttpTransport.Context

request - Variable in class org.cometd.server.http.AbstractHttpTransport.Context

REQUIRE_HANDSHAKE_PER_CONNECTION_OPTION - Static variable in class org.cometd.server.websocket.common.AbstractWebSocketTransport

reset() - Method in class org.cometd.benchmark.MonitoringQueuedThreadPool.MonitoringBlockingArrayQueue

reset() - Method in class org.cometd.benchmark.MonitoringQueuedThreadPool

reset() - Method in class org.cometd.benchmark.MonitoringThreadPoolExecutor

reset() - Method in class org.cometd.client.BayeuxClient.BackOffStrategy.Constant

reset() - Method in class org.cometd.client.BayeuxClient.BackOffStrategy.Linear

reset() - Method in interface org.cometd.client.BayeuxClient.BackOffStrategy

Resets the wait time.

resetSubscriptions() - Method in class org.cometd.common.AbstractClientSession.AbstractSessionChannel

resetSubscriptions() - Method in class org.cometd.common.AbstractClientSession

resolveLoop(AsyncFoldLeft.Loop<Boolean>) - Method in class org.cometd.server.BayeuxServerImpl

response - Variable in class org.cometd.server.http.AbstractHttpTransport.Context

result(Object) - Method in interface org.cometd.annotation.server.RemoteCall.Caller

Returns the given result to the remote caller.

Result() - Constructor for class org.cometd.bayeux.server.Authorizer.Result

resume(AbstractHttpTransport.Context, ServerMessage.Mutable, Promise<Void>) - Method in class org.cometd.server.http.AbstractHttpTransport

retainAll(Collection<?>) - Method in class org.cometd.server.ext.BatchArrayQueue

reverseRun(List<T>, R, AsyncFoldLeft.Operation<T, R>, Promise<R>) - Static method in class org.cometd.common.AsyncFoldLeft

Processes, in reverse order, the given sequence of elements.

rootArrayClass() - Method in class org.cometd.common.JacksonJSONContext

rootArrayClass() - Method in class org.cometd.common.JacksonJSONContextClient

rootArrayClass() - Method in class org.cometd.server.JacksonJSONContextServer

run() - Method in class org.cometd.benchmark.client.CometDLoadClient

run() - Method in class org.cometd.benchmark.server.CometDLoadServer

run() - Method in class org.cometd.server.http.AbstractHttpTransport.LongPollScheduler

run(Iterable<T>, R, AsyncFoldLeft.Operation<T, R>, Promise<R>) - Static method in class org.cometd.common.AsyncFoldLeft

Processes the given sequence of elements.

run(T[], R, AsyncFoldLeft.Operation<T, R>, Promise<R>) - Static method in class org.cometd.common.AsyncFoldLeft

Processes the given array of elements.

S

schedule() - Method in interface org.cometd.server.AbstractServerTransport.Scheduler

Invoked when the transport wants to send queued messages, and possibly a /meta/connect reply.

schedule() - Method in class org.cometd.server.http.AbstractHttpTransport.LongPollScheduler

schedule(Runnable, long) - Method in class org.cometd.server.BayeuxServerImpl

Entry point to schedule tasks in CometD.

scheduleConnect(long, long) - Method in class org.cometd.client.BayeuxClient

scheduleExpiration - Variable in class org.cometd.server.http.AbstractHttpTransport.Context

scheduleExpiration(long, long, long) - Method in class org.cometd.server.ServerSessionImpl

scheduleExpiration(ServerSessionImpl, long) - Method in class org.cometd.server.AbstractServerTransport

scheduleHandshake(long, long) - Method in class org.cometd.client.BayeuxClient

scheduler - Variable in class org.cometd.server.http.AbstractHttpTransport.Context

Scheduler(int) - Constructor for class org.cometd.client.BayeuxClient.Scheduler

SCHEDULER_OPTION - Static variable in class org.cometd.client.transport.ClientTransport

SCHEDULER_THREADS - Static variable in class org.cometd.server.BayeuxServerImpl

SecurityPolicy - Interface in org.cometd.bayeux.server

A SecurityPolicy defines the broad authorization constraints that must be enforced by a BayeuxServer.

send(String) - Method in class org.cometd.client.websocket.common.AbstractWebSocketTransport.Delegate

send(String) - Method in class org.cometd.client.websocket.javax.WebSocketTransport.WebSocketDelegate

send(String) - Method in class org.cometd.client.websocket.jetty.JettyWebSocketTransport.JettyWebSocketDelegate

send(String) - Method in class org.cometd.client.websocket.okhttp.OkHttpWebSocketTransport.OkHttpDelegate

send(String, String, Object) - Method in class org.cometd.oort.Seti.LocalLocation

send(String, String, Object) - Method in interface org.cometd.oort.Seti.Location

send(String, String, Object) - Method in class org.cometd.oort.Seti.SetiLocation

send(ClientSession, Message.Mutable) - Method in interface org.cometd.bayeux.client.ClientSession.Extension

Callback method invoked every time a normal message is being sent.

send(ClientSession, Message.Mutable) - Method in class org.cometd.client.ext.BinaryExtension

send(ClientSession, Message.Mutable) - Method in class org.cometd.client.ext.TimestampClientExtension

send(Message.Mutable) - Method in class org.cometd.client.BayeuxClient

send(Message.Mutable) - Method in class org.cometd.common.AbstractClientSession

send(Message.Mutable) - Method in class org.cometd.server.LocalSessionImpl

send(ServerSession, String, Object) - Method in class org.cometd.server.AbstractService

Sends data to an individual remote client.

send(ServerSession, String, Callback) - Method in class org.cometd.server.websocket.common.AbstractWebSocketEndPoint

send(ServerSession, String, Callback) - Method in class org.cometd.server.websocket.jetty.JettyWebSocketEndPoint

send(ServerSession, ServerSession, ServerMessage) - Method in interface org.cometd.bayeux.server.ServerSession.Extension

Blocking version of ServerSession.Extension.outgoing(ServerSession, ServerSession, ServerMessage.Mutable, Promise) for non-meta messages.

send(ServerSession, ServerSession, ServerMessage) - Method in class org.cometd.server.ext.AcknowledgedMessagesSessionExtension

send(ServerSession, ServerSession, ServerMessage) - Method in class org.cometd.server.ext.ActivityExtension.SessionExtension

send(ServerSession, ServerSession, ServerMessage) - Method in class org.cometd.server.ext.BinarySessionExtension

send(ServerSession, ServerSession, ServerMessage.Mutable) - Method in interface org.cometd.bayeux.server.BayeuxServer.Extension

Blocking version of BayeuxServer.Extension.outgoing(ServerSession, ServerSession, ServerMessage.Mutable, Promise) for non-meta messages.

send(ServerSession, ServerSession, ServerMessage.Mutable) - Method in class org.cometd.server.ext.BinaryExtension

send(ServerSession, ServerSession, ServerMessage.Mutable) - Method in class org.cometd.server.ext.TimestampExtension

send(TransportListener, List<Message.Mutable>) - Method in class org.cometd.client.http.jetty.JettyHttpClientTransport

send(TransportListener, List<Message.Mutable>) - Method in class org.cometd.client.http.okhttp.OkHttpClientTransport

send(TransportListener, List<Message.Mutable>) - Method in class org.cometd.client.transport.ClientTransport

send(TransportListener, List<Message.Mutable>) - Method in class org.cometd.client.websocket.common.AbstractWebSocketTransport

send(ServerSessionImpl, ServerMessage.Mutable) - Method in class org.cometd.server.LocalSessionImpl

Enqueues or sends a message to the server.

sendBatch() - Method in class org.cometd.client.BayeuxClient

sendBatch() - Method in class org.cometd.common.AbstractClientSession

sendBatch() - Method in class org.cometd.server.LocalSessionImpl

sendConnect() - Method in class org.cometd.client.BayeuxClient

sendError(HttpServletRequest, HttpServletResponse, int, Throwable) - Method in class org.cometd.server.http.AbstractHttpTransport

sendHandshake() - Method in class org.cometd.client.BayeuxClient

sendMessage(String, String, Object) - Method in class org.cometd.oort.Seti

Sends a message to the given userId in the Oort cloud.

sendMessage(Collection<String>, String, Object) - Method in class org.cometd.oort.Seti

Sends a message to multiple userIds in the Oort cloud.

sendMessages(List<Message.Mutable>, Promise<Boolean>) - Method in class org.cometd.client.BayeuxClient

sendMeta(ClientSession, Message.Mutable) - Method in interface org.cometd.bayeux.client.ClientSession.Extension

Callback method invoked every time a meta message is being sent.

sendMeta(ClientSession, Message.Mutable) - Method in class org.cometd.client.ext.AckExtension

sendMeta(ClientSession, Message.Mutable) - Method in class org.cometd.client.ext.TimestampClientExtension

sendMeta(ClientSession, Message.Mutable) - Method in class org.cometd.client.ext.TimesyncClientExtension

sendMeta(ServerSession, ServerMessage.Mutable) - Method in interface org.cometd.bayeux.server.BayeuxServer.Extension

Blocking version of BayeuxServer.Extension.outgoing(ServerSession, ServerSession, ServerMessage.Mutable, Promise) for meta messages.

sendMeta(ServerSession, ServerMessage.Mutable) - Method in class org.cometd.server.ext.TimestampExtension

sendMeta(ServerSession, ServerMessage.Mutable) - Method in class org.cometd.server.ext.TimesyncExtension

sendMeta(ServerSession, ServerSession, ServerMessage.Mutable) - Method in interface org.cometd.bayeux.server.ServerSession.Extension

Blocking version of ServerSession.Extension.outgoing(ServerSession, ServerSession, ServerMessage.Mutable, Promise) for meta messages.

sendMeta(ServerSession, ServerSession, ServerMessage.Mutable) - Method in class org.cometd.server.ext.AcknowledgedMessagesSessionExtension

sendMeta(ServerSession, ServerSession, ServerMessage.Mutable) - Method in class org.cometd.server.ext.ActivityExtension.SessionExtension

sendQueue - Variable in class org.cometd.server.http.AbstractHttpTransport.Context

sendSubscribe(Message.Mutable, ClientSessionChannel.MessageListener, ClientSession.MessageListener) - Method in class org.cometd.common.AbstractClientSession.AbstractSessionChannel

sendUnSubscribe(Message.Mutable, ClientSession.MessageListener) - Method in class org.cometd.common.AbstractClientSession.AbstractSessionChannel

Deprecated.

sendUnSubscribe(Message.Mutable, ClientSessionChannel.MessageListener, ClientSession.MessageListener) - Method in class org.cometd.common.AbstractClientSession.AbstractSessionChannel

serialize(T) - Method in class org.cometd.oort.OortObject

ServerAnnotationProcessor - Class in org.cometd.annotation.server

Processes annotations in server-side service objects.

ServerAnnotationProcessor(BayeuxServer) - Constructor for class org.cometd.annotation.server.ServerAnnotationProcessor

ServerAnnotationProcessor(BayeuxServer, Object...) - Constructor for class org.cometd.annotation.server.ServerAnnotationProcessor

ServerChannel - Interface in org.cometd.bayeux.server

Server side representation of a Bayeux channel.

ServerChannel.MessageListener - Interface in org.cometd.bayeux.server

Listeners objects that implement this interface will be notified of message publish.

ServerChannel.SubscriptionListener - Interface in org.cometd.bayeux.server

Listener objects that implement this interface will be notified of subscription events.

ServerChannelImpl - Class in org.cometd.server

ServerChannelImpl(BayeuxServerImpl, ChannelId) - Constructor for class org.cometd.server.ServerChannelImpl

ServerContext(ServerSession, ServerMessage) - Constructor for class org.cometd.oort.OortService.ServerContext

ServerMessage - Interface in org.cometd.bayeux.server

Representation of a server side message.

ServerMessage.Mutable - Interface in org.cometd.bayeux.server

The mutable version of a ServerMessage

ServerMessageImpl - Class in org.cometd.server

ServerMessageImpl() - Constructor for class org.cometd.server.ServerMessageImpl

ServerSession - Interface in org.cometd.bayeux.server

Objects implementing this interface are the server-side representation of remote Bayeux clients.

ServerSession.AddedListener - Interface in org.cometd.bayeux.server

Listener objects that implement this interface will be notified of session addition.

ServerSession.DeQueueListener - Interface in org.cometd.bayeux.server

Listeners objects that implement this interface will be notified when the session queue is being drained to actually deliver the messages.

ServerSession.Extension - Interface in org.cometd.bayeux.server

Extension API for ServerSession.

ServerSession.HeartBeatListener - Interface in org.cometd.bayeux.server

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 - Interface in org.cometd.bayeux.server

Listeners objects that implement this interface will be notified of message sending.

ServerSession.QueueListener - Interface in org.cometd.bayeux.server

Listener objects that implement this interface will be notified when a message is queued in the session queue.

ServerSession.QueueMaxedListener - Interface in org.cometd.bayeux.server

Listeners objects that implement this interface will be notified when the session queue is full.

ServerSession.RemovedListener - Interface in org.cometd.bayeux.server

Listeners objects that implement this interface will be notified of session removal.

ServerSession.ServerSessionListener - Interface in org.cometd.bayeux.server

Common interface for ServerSession listeners.

ServerSessionImpl - Class in org.cometd.server

ServerSessionImpl(BayeuxServerImpl) - Constructor for class org.cometd.server.ServerSessionImpl

ServerSessionImpl(BayeuxServerImpl, LocalSessionImpl, String) - Constructor for class org.cometd.server.ServerSessionImpl

ServerTransport - Interface in org.cometd.bayeux.server

Server side extension of a Bayeux transport.

service(HttpServletRequest, HttpServletResponse) - Method in class org.cometd.server.CometDServlet

service(ServletRequest, ServletResponse) - Method in class org.cometd.examples.CometDDemoServlet

Service - Annotation Type in org.cometd.annotation

Identifies classes whose instances are services that interact with the Bayeux API.

SERVICE - Static variable in interface org.cometd.bayeux.Channel

Constant representing the service prefix

serviceOptions(HttpServletRequest, HttpServletResponse) - Method in class org.cometd.server.CometDServlet

SERVLET_PATH - Static variable in class org.cometd.benchmark.Config

session - Variable in class org.cometd.server.http.AbstractHttpTransport.Context

Session - Interface in org.cometd.bayeux

A Bayeux session represents a connection between a bayeux client and a bayeux server.

Session - Annotation Type in org.cometd.annotation

Identifies fields and methods that can be injected with org.cometd.bayeux.Session sessions objects scoped to the service instance.

sessionAdded(ServerSession, ServerMessage) - Method in interface org.cometd.bayeux.server.BayeuxServer.SessionListener

Callback invoked when a ServerSession has been added to a BayeuxServer object.

SessionExtension(ActivityExtension.Activity, long) - Constructor for class org.cometd.server.ext.ActivityExtension.SessionExtension

sessionRemoved(ServerSession, ServerMessage, boolean) - Method in interface org.cometd.bayeux.server.BayeuxServer.SessionListener

Callback invoked when a ServerSession has been removed from a BayeuxServer object.

setAccuracyTarget(int) - Method in class org.cometd.server.ext.TimesyncExtension

timesync responses are not set if the measured accuracy is less than the accuracyTarget.

setAckExtensionEnabled(boolean) - Method in class org.cometd.oort.Oort

setAdvertiseInterval(long) - Method in class org.cometd.oort.OortMulticastConfigurer

setAdvice(Map<String, Object>) - Method in class org.cometd.client.http.common.AbstractHttpClientTransport

setAllowedTransports(String...) - Method in class org.cometd.server.BayeuxServerImpl

setAllowedTransports(List<String>) - Method in class org.cometd.server.BayeuxServerImpl

setAllowMessageDeliveryDuringHandshake(boolean) - Method in class org.cometd.server.AbstractServerTransport

setAllowMessageDeliveryDuringHandshake(boolean) - Method in class org.cometd.server.ServerSessionImpl

setAndShare(T, OortObject.Result<T>) - Method in class org.cometd.oort.OortObject

Sets the given new object on this oort object, and then broadcast the new object to all nodes in the cluster.

setAssociated(ServerMessage.Mutable) - Method in interface org.cometd.bayeux.server.ServerMessage.Mutable

setAssociated(ServerMessage.Mutable) - Method in class org.cometd.server.ServerMessageImpl

setAttribute(String, Object) - Method in interface org.cometd.bayeux.Channel

Sets a named channel attribute value.

setAttribute(String, Object) - Method in interface org.cometd.bayeux.Session

Sets a named session attribute value.

setAttribute(String, Object) - Method in class org.cometd.common.AbstractClientSession.AbstractSessionChannel

setAttribute(String, Object) - Method in class org.cometd.common.AbstractClientSession

setAttribute(String, Object) - Method in class org.cometd.server.ServerChannelImpl

setAttribute(String, Object) - Method in class org.cometd.server.ServerSessionImpl

setBackOffStrategy(BayeuxClient.BackOffStrategy) - Method in class org.cometd.client.BayeuxClient

setBayeuxContext(BayeuxContext) - Method in class org.cometd.server.ServerMessageImpl

setBinaryExtensionEnabled(boolean) - Method in class org.cometd.oort.Oort

setBindAddress(InetAddress) - Method in class org.cometd.oort.OortMulticastConfigurer

setBroadcastToPublisher(boolean) - Method in interface org.cometd.bayeux.server.ConfigurableServerChannel

Sets whether a publisher that is also a subscriber to the channel will receive the messages it publishes on that channel.

setBroadcastToPublisher(boolean) - Method in interface org.cometd.bayeux.server.ServerSession

Sets whether this session sends messages back to itself.

setBroadcastToPublisher(boolean) - Method in class org.cometd.server.ServerChannelImpl

setBroadcastToPublisher(boolean) - Method in class org.cometd.server.ServerSessionImpl

setBrowserId(String) - Method in class org.cometd.server.ServerSessionImpl

Sets a remote client identifier, typically a browser.

setBrowserId(AbstractHttpTransport.Context) - Method in class org.cometd.server.http.AbstractHttpTransport

setChannel(String) - Method in interface org.cometd.bayeux.Message.Mutable

setChannel(String) - Method in class org.cometd.common.HashMapMessage

setClientId(String) - Method in interface org.cometd.bayeux.Message.Mutable

setClientId(String) - Method in class org.cometd.common.HashMapMessage

setClientTransportFactories(List<ClientTransport.Factory>) - Method in class org.cometd.oort.Oort

setConnectTimeout(long) - Method in class org.cometd.oort.OortMulticastConfigurer

setCookieStore(CookieStore) - Method in class org.cometd.client.transport.HttpClientTransport

setData(Object) - Method in interface org.cometd.bayeux.Message.Mutable

setData(Object) - Method in class org.cometd.common.HashMapMessage

setDetailedDump(boolean) - Method in class org.cometd.server.BayeuxServerImpl

setExecutor(Executor) - Method in class org.cometd.server.BayeuxServerImpl

setField(Object, Field, Object) - Method in class org.cometd.annotation.AnnotationProcessor

setGroupAddress(InetAddress) - Method in class org.cometd.oort.OortMulticastConfigurer

setGroupInterfaces(List<NetworkInterface>) - Method in class org.cometd.oort.OortMulticastConfigurer

setGroupPort(int) - Method in class org.cometd.oort.OortMulticastConfigurer

setHandled(boolean) - Method in class org.cometd.server.ServerMessageImpl

setHandshakeReconnect(boolean) - Method in class org.cometd.server.AbstractServerTransport

setHttpSessionAttribute(String, Object) - Method in interface org.cometd.bayeux.server.BayeuxContext

Access the HTTP Session (if any) attributes.

setHttpSessionAttribute(String, Object) - Method in class org.cometd.server.websocket.common.AbstractBayeuxContext

Seti - Class in org.cometd.oort

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(Oort) - Constructor for class org.cometd.oort.Seti

SETI_ATTRIBUTE - Static variable in class org.cometd.oort.Seti

Seti.LocalLocation - Class in org.cometd.oort

A Location that represent a user connected to a local comet.

Seti.Location - Interface in org.cometd.oort

The representation of where a user is.

Seti.PresenceListener - Interface in org.cometd.oort

Listener interface that gets notified of remote Seti presence events.

Seti.PresenceListener.Event - Class in org.cometd.oort

Seti presence event object, delivered to Seti.PresenceListener methods.

Seti.SetiLocation - Class in org.cometd.oort

A Location that represent a user connected to a remote comet.

setId(String) - Method in interface org.cometd.bayeux.Message.Mutable

setId(String) - Method in class org.cometd.common.HashMapMessage

SetiLocation(String, String) - Constructor for class org.cometd.oort.Seti.SetiLocation

setInterval(long) - Method in interface org.cometd.bayeux.server.ServerSession

setInterval(long) - Method in class org.cometd.server.AbstractServerTransport

setInterval(long) - Method in class org.cometd.server.ServerSessionImpl

SetiServlet - Class in org.cometd.oort

This servlet initializes and configures and instance of the Seti user mapper.

SetiServlet() - Constructor for class org.cometd.oort.SetiServlet

setJSONContextClient(JSONContext.Client) - Method in class org.cometd.oort.Oort

setLazy(boolean) - Method in interface org.cometd.bayeux.server.ConfigurableServerChannel

A lazy channel marks all messages published to it as lazy.

setLazy(boolean) - Method in interface org.cometd.bayeux.server.ServerMessage.Mutable

A lazy message does not provoke immediately delivery to the client but it will be delivered at first occasion or after a timeout expires

setLazy(boolean) - Method in class org.cometd.server.ServerChannelImpl

setLazy(boolean) - Method in class org.cometd.server.ServerMessageImpl

setLazyTimeout(long) - Method in interface org.cometd.bayeux.server.ConfigurableServerChannel

Sets the lazy timeout for this channel.

setLazyTimeout(long) - Method in class org.cometd.server.ServerChannelImpl

setMaxInterval(long) - Method in interface org.cometd.bayeux.server.ServerSession

setMaxInterval(long) - Method in class org.cometd.server.AbstractServerTransport

setMaxInterval(long) - Method in class org.cometd.server.ServerSessionImpl

setMaxLazyTimeout(long) - Method in class org.cometd.server.AbstractServerTransport

setMaxMessageSize(int) - Method in class org.cometd.server.AbstractServerTransport

setMaxNetworkDelay(long) - Method in class org.cometd.client.transport.ClientTransport

setMaxTransmissionLength(int) - Method in class org.cometd.oort.OortMulticastConfigurer

setMessageTransportListener(TransportListener) - Method in interface org.cometd.client.transport.MessageClientTransport

setMessageTransportListener(TransportListener) - Method in class org.cometd.client.websocket.common.AbstractWebSocketTransport

setMetaConnectDeliveryOnly(boolean) - Method in interface org.cometd.bayeux.server.ServerSession

Sets whether delivery of messages only happen via the /meta/connect channel.

setMetaConnectDeliveryOnly(boolean) - Method in class org.cometd.server.AbstractServerTransport

setMetaConnectDeliveryOnly(boolean) - Method in class org.cometd.server.ServerSessionImpl

setOption(String, Object) - Method in interface org.cometd.bayeux.Bayeux

setOption(String, Object) - Method in class org.cometd.client.BayeuxClient

setOption(String, Object) - Method in class org.cometd.common.AbstractTransport

Sets the option value with the given name.

setOption(String, Object) - Method in class org.cometd.server.BayeuxServerImpl

setOptionPrefix(String) - Method in class org.cometd.common.AbstractTransport

Set the option name prefix segment.

setOptions(Map<String, Object>) - Method in class org.cometd.server.BayeuxServerImpl

setPersistent(boolean) - Method in interface org.cometd.bayeux.server.ConfigurableServerChannel

A persistent channel is not removed when the last subscription is removed

setPersistent(boolean) - Method in class org.cometd.server.ServerChannelImpl

setResult(T) - Method in class org.cometd.oort.OortObject.Data

setScheduler(AbstractServerTransport.Scheduler) - Method in class org.cometd.server.ServerSessionImpl

setScheduler(Scheduler) - Method in class org.cometd.server.BayeuxServerImpl

setSecret(String) - Method in class org.cometd.oort.Oort

setSecurityPolicy(SecurityPolicy) - Method in interface org.cometd.bayeux.server.BayeuxServer

setSecurityPolicy(SecurityPolicy) - Method in class org.cometd.server.BayeuxServerImpl

setSeeOwnPublishes(boolean) - Method in class org.cometd.server.AbstractService

setServerTransport(ServerTransport) - Method in class org.cometd.server.ServerMessageImpl

setServerTransport(ServerTransport) - Method in class org.cometd.server.ServerSessionImpl

setSuccessful(boolean) - Method in interface org.cometd.bayeux.Message.Mutable

setSuccessful(boolean) - Method in class org.cometd.common.HashMapMessage

setSweepPeriod(long) - Method in class org.cometd.server.BayeuxServerImpl

setSweepThreads(int) - Method in class org.cometd.server.BayeuxServerImpl

setThreadPool(ThreadPool) - Method in class org.cometd.server.AbstractService

Sets the thread pool associated to this CometD service.

setTimeout(long) - Method in interface org.cometd.bayeux.server.ServerSession

setTimeout(long) - Method in class org.cometd.oort.OortService

setTimeout(long) - Method in class org.cometd.server.AbstractServerTransport

setTimeout(long) - Method in class org.cometd.server.ServerSessionImpl

setTimeToLive(int) - Method in class org.cometd.oort.OortMulticastConfigurer

setTransports(List<ServerTransport>) - Method in class org.cometd.server.BayeuxServerImpl

setTransports(ServerTransport...) - Method in class org.cometd.server.BayeuxServerImpl

setURL(String) - Method in class org.cometd.client.transport.ClientTransport

setURL(String) - Method in class org.cometd.client.websocket.common.AbstractWebSocketTransport

setUserAgent(String) - Method in class org.cometd.server.ServerSessionImpl

shouldSchedule() - Method in class org.cometd.server.ServerSessionImpl

shutdown(String) - Method in class org.cometd.client.websocket.common.AbstractWebSocketTransport.Delegate

shutdown(String) - Method in class org.cometd.client.websocket.javax.WebSocketTransport.WebSocketDelegate

shutdown(String) - Method in class org.cometd.client.websocket.jetty.JettyWebSocketTransport.JettyWebSocketDelegate

shutdown(String) - Method in class org.cometd.client.websocket.okhttp.OkHttpWebSocketTransport.OkHttpDelegate

shutdownScheduler() - Method in class org.cometd.client.transport.ClientTransport

size() - Method in class org.cometd.server.ext.BatchArrayQueue

startBatch() - Method in interface org.cometd.bayeux.Session

Starts a batch, to be ended with Session.endBatch().

startBatch() - Method in class org.cometd.common.AbstractClientSession

startBatch() - Method in class org.cometd.server.ServerSessionImpl

startStatistics(ServerSession, ServerMessage) - Method in class org.cometd.benchmark.server.CometDLoadServer.StatisticsService

STICKY_RECONNECT_OPTION - Static variable in class org.cometd.client.websocket.common.AbstractWebSocketTransport

stopStatistics(ServerSession, ServerMessage) - Method in class org.cometd.benchmark.server.CometDLoadServer.StatisticsService

storeCookies(URI, Map<String, List<String>>) - Method in class org.cometd.client.transport.HttpClientTransport

subscribe(Set<String>) - Method in class org.cometd.oort.OortComet

subscribe(ClientSessionChannel.MessageListener) - Method in interface org.cometd.bayeux.client.ClientSessionChannel

Equivalent to subscribe(listener, null).

subscribe(ClientSessionChannel.MessageListener, ClientSession.MessageListener) - Method in interface org.cometd.bayeux.client.ClientSessionChannel

Equivalent to subscribe(null, listener, callback).

subscribe(Message.Mutable, ClientSessionChannel.MessageListener, ClientSession.MessageListener) - Method in interface org.cometd.bayeux.client.ClientSessionChannel

Subscribes the given listener to receive messages sent to this channel.

subscribe(Message.Mutable, ClientSessionChannel.MessageListener, ClientSession.MessageListener) - Method in class org.cometd.common.AbstractClientSession.AbstractSessionChannel

subscribe(ServerSession) - Method in interface org.cometd.bayeux.server.ServerChannel

Subscribes the given session to this channel.

subscribe(ServerSession) - Method in class org.cometd.server.ServerChannelImpl

subscribe(ServerChannelImpl) - Method in class org.cometd.server.ServerSessionImpl

subscribe(ServerSessionImpl, ServerMessage) - Method in class org.cometd.server.ServerChannelImpl

SUBSCRIBE - org.cometd.bayeux.server.Authorizer.Operation

The operation to subscribe to a channel to receive messages published to it

subscribed(ServerSession, ServerChannel, ServerMessage) - Method in interface org.cometd.bayeux.server.BayeuxServer.SubscriptionListener

Callback invoked when a ServerSession subscribes to a ServerChannel.

subscribed(ServerSession, ServerChannel, ServerMessage) - Method in interface org.cometd.bayeux.server.ServerChannel.SubscriptionListener

Callback invoked when the given ServerSession subscribes to the given ServerChannel.

subscribers() - Method in class org.cometd.server.ServerChannelImpl

Subscription - Annotation Type in org.cometd.annotation

For server-side services, identifies callback methods that are invoked when a message is processed on local-side.

SUBSCRIPTION_FIELD - Static variable in interface org.cometd.bayeux.Message

succeed(C) - Method in interface org.cometd.bayeux.Promise

Callback to invoke when the operation succeeds.

succeed(S) - Method in class org.cometd.bayeux.Promise.Completable

succeeded(Long) - Method in interface org.cometd.oort.OortPrimaryLong.Callback

Callback method invoked when the operation on the counter succeeded.

success(S) - Static method in class org.cometd.oort.OortService.Result

Returns a successful OortService.Result containing the given result object.

SUCCESSFUL_FIELD - Static variable in interface org.cometd.bayeux.Message

sum() - Method in class org.cometd.oort.OortLong

SUPPORTED_CONNECTION_TYPES_FIELD - Static variable in interface org.cometd.bayeux.Message

suspend(AbstractHttpTransport.Context, Promise<Void>, ServerMessage.Mutable, long) - Method in class org.cometd.server.http.AbstractHttpTransport

suspend(AbstractHttpTransport.Context, Promise<Void>, ServerMessage.Mutable, long) - Method in class org.cometd.server.http.AbstractStreamHttpTransport

suspend(AbstractHttpTransport.Context, Promise<Void>, ServerMessage.Mutable, long) - Method in class org.cometd.server.http.AsyncJSONTransport

sweep() - Method in class org.cometd.server.AbstractServerTransport

Housekeeping sweep, called a regular intervals

sweep() - Method in class org.cometd.server.BayeuxServerImpl

sweep() - Method in class org.cometd.server.http.AbstractHttpTransport

Sweeps the transport for old Browser IDs

sweep() - Method in class org.cometd.server.ServerChannelImpl

sweep(long) - Method in class org.cometd.server.ServerSessionImpl

SWEEP_PERIOD_OPTION - Static variable in class org.cometd.server.BayeuxServerImpl

SWEEP_THREADS_OPTION - Static variable in class org.cometd.server.BayeuxServerImpl

T

take() - Method in class org.cometd.benchmark.MonitoringQueuedThreadPool.MonitoringBlockingArrayQueue

takeAdvice(ServerTransport) - Method in class org.cometd.server.ServerSessionImpl

takeQueue(List<ServerMessage.Mutable>) - Method in class org.cometd.server.ServerSessionImpl

terminate() - Method in class org.cometd.client.http.common.AbstractHttpClientTransport

terminate() - Method in class org.cometd.client.transport.ClientTransport

Terminates this transport, usually by closing network connections opened directly by this transport.

terminate() - Method in class org.cometd.client.websocket.common.AbstractWebSocketTransport

terminate(Throwable) - Method in class org.cometd.client.BayeuxClient

TERMINATING - org.cometd.client.BayeuxClient.State

State assumed when the disconnect is received but terminal actions must be performed

throwIfReleased() - Method in class org.cometd.common.AbstractClientSession.AbstractSessionChannel

TIMEOUT_FIELD - Static variable in interface org.cometd.bayeux.Message

TIMEOUT_OPTION - Static variable in class org.cometd.server.AbstractServerTransport

TIMESTAMP_FIELD - Static variable in interface org.cometd.bayeux.Message

TimestampClientExtension - Class in org.cometd.client.ext

TimestampClientExtension() - Constructor for class org.cometd.client.ext.TimestampClientExtension

TimestampExtension - Class in org.cometd.server.ext

TimestampExtension() - Constructor for class org.cometd.server.ext.TimestampExtension

TimestampExtension(String) - Constructor for class org.cometd.server.ext.TimestampExtension

TimestampExtension(String, TimeZone) - Constructor for class org.cometd.server.ext.TimestampExtension

TimesyncClientExtension - Class in org.cometd.client.ext

TimesyncClientExtension() - Constructor for class org.cometd.client.ext.TimesyncClientExtension

TimesyncExtension - Class in org.cometd.server.ext

Timesync extension (server side).

TimesyncExtension() - Constructor for class org.cometd.server.ext.TimesyncExtension

toArray() - Method in class org.cometd.server.ext.BatchArrayQueue

toArray(E[]) - Method in class org.cometd.server.ext.BatchArrayQueue

toJSON(ServerMessage) - Method in class org.cometd.server.AbstractServerTransport

toJSON(ServerMessage) - Method in class org.cometd.server.websocket.common.AbstractWebSocketTransport

toJSONBytes(ServerMessage) - Method in class org.cometd.server.http.AbstractHttpTransport

toString() - Method in class org.cometd.bayeux.ChannelId

toString() - Method in class org.cometd.bayeux.server.Authorizer.Result.Denied

toString() - Method in class org.cometd.bayeux.server.Authorizer.Result

toString() - Method in class org.cometd.client.BayeuxClient

toString() - Method in class org.cometd.client.transport.ClientTransport.FailureInfo

toString() - Method in class org.cometd.common.AbstractClientSession.AbstractSessionChannel

toString() - Method in class org.cometd.oort.Oort

toString() - Method in class org.cometd.oort.OortComet

toString() - Method in class org.cometd.oort.OortMap.Entry

toString() - Method in class org.cometd.oort.OortObject.Info

toString() - Method in class org.cometd.oort.OortObject

toString() - Method in class org.cometd.oort.OortService.Result

toString() - Method in class org.cometd.oort.OortService

toString() - Method in class org.cometd.oort.Seti.LocalLocation

toString() - Method in class org.cometd.oort.Seti.PresenceListener.Event

toString() - Method in class org.cometd.oort.Seti.SetiLocation

toString() - Method in class org.cometd.oort.Seti

toString() - Method in class org.cometd.server.AbstractServerTransport.Scheduler.None

toString() - Method in class org.cometd.server.AbstractServerTransport

toString() - Method in class org.cometd.server.authorizer.GrantAuthorizer

toString() - Method in class org.cometd.server.http.AbstractHttpTransport.LongPollScheduler

toString() - Method in class org.cometd.server.LocalSessionImpl

toString() - Method in class org.cometd.server.ServerChannelImpl

toString() - Method in class org.cometd.server.ServerSessionImpl

toString() - Method in class org.cometd.server.websocket.common.AbstractWebSocketEndPoint

toString() - Method in class org.cometd.server.websocket.javax.WebSocketEndPoint

toString() - Method in class org.cometd.server.websocket.jetty.JettyWebSocketEndPoint

transport - Variable in class org.cometd.client.transport.ClientTransport.FailureInfo

Transport - Interface in org.cometd.bayeux

A transport abstract the details of the protocol used to send Bayeux messages over the network, for example using HTTP or using WebSocket.

TRANSPORT_FIELD - Static variable in interface org.cometd.bayeux.Message

TransportException - Exception in org.cometd.common

TransportException(Throwable, Map<String, Object>) - Constructor for exception org.cometd.common.TransportException

TransportException(Map<String, Object>) - Constructor for exception org.cometd.common.TransportException

TransportListener - Interface in org.cometd.client.transport

Abstracts the communication between BayeuxClient and ClientTransport.

TransportRegistry - Class in org.cometd.client.transport

TransportRegistry() - Constructor for class org.cometd.client.transport.TransportRegistry

TRANSPORTS_OPTION - Static variable in class org.cometd.server.BayeuxServerImpl

trimCloseReason(String) - Method in class org.cometd.client.websocket.common.AbstractWebSocketTransport.Delegate

TRUST_CLIENT_SESSION_OPTION - Static variable in class org.cometd.server.http.AbstractHttpTransport

tryExecute(Runnable) - Method in class org.cometd.benchmark.MonitoringQueuedThreadPool

TYPE_FIELD - Static variable in class org.cometd.oort.OortObject.Info

U

UNCONNECTED - org.cometd.client.BayeuxClient.State

State assumed after the handshake when the connection is broken

unknownSession(ServerMessage.Mutable) - Method in class org.cometd.server.BayeuxServerImpl

unprotectOortChannels(BayeuxServer) - Method in class org.cometd.oort.Oort

unprotectSetiChannels(BayeuxServer) - Method in class org.cometd.oort.Seti

unregisterCallback(String) - Method in class org.cometd.common.AbstractClientSession

unregisterSubscriber(String) - Method in class org.cometd.common.AbstractClientSession

unsubscribe() - Method in interface org.cometd.bayeux.client.ClientSessionChannel

Unsubscribes all subscribers registered on this channel.

unsubscribe() - Method in class org.cometd.common.AbstractClientSession.AbstractSessionChannel

unsubscribe(String) - Method in class org.cometd.oort.OortComet

unsubscribe(ClientSessionChannel.MessageListener) - Method in interface org.cometd.bayeux.client.ClientSessionChannel

Equivalent to unsubscribe(listener, null).

unsubscribe(ClientSessionChannel.MessageListener, ClientSession.MessageListener) - Method in interface org.cometd.bayeux.client.ClientSessionChannel

Equivalent to unsubscribe(null, listener, callback).

unsubscribe(Message.Mutable, ClientSessionChannel.MessageListener, ClientSession.MessageListener) - Method in interface org.cometd.bayeux.client.ClientSessionChannel

Unsubscribes the given listener from receiving messages sent to this channel.

unsubscribe(Message.Mutable, ClientSessionChannel.MessageListener, ClientSession.MessageListener) - Method in class org.cometd.common.AbstractClientSession.AbstractSessionChannel

unsubscribe(ServerSession) - Method in interface org.cometd.bayeux.server.ServerChannel

Unsubscribes the given session from this channel.

unsubscribe(ServerSession) - Method in class org.cometd.server.ServerChannelImpl

unsubscribe(ServerSessionImpl, ServerMessage) - Method in class org.cometd.server.ServerChannelImpl

unsubscribed(ServerSession, ServerChannel, ServerMessage) - Method in interface org.cometd.bayeux.server.BayeuxServer.SubscriptionListener

Callback invoked when a ServerSession unsubscribes from a ServerChannel.

unsubscribed(ServerSession, ServerChannel, ServerMessage) - Method in interface org.cometd.bayeux.server.ServerChannel.SubscriptionListener

Callback invoked when the given ServerSession unsubscribes from the given ServerChannel.

unsubscribedFrom(ServerChannelImpl) - Method in class org.cometd.server.ServerSessionImpl

updateMax(AtomicInteger, int) - Static method in class org.cometd.benchmark.Atomics

updateMax(AtomicLong, long) - Static method in class org.cometd.benchmark.Atomics

updateMax(AtomicStampedReference<T>, T, int) - Static method in class org.cometd.benchmark.Atomics

updateMin(AtomicInteger, int) - Static method in class org.cometd.benchmark.Atomics

updateMin(AtomicLong, long) - Static method in class org.cometd.benchmark.Atomics

updateServerEndPoint(Object) - Method in class org.cometd.server.ServerSessionImpl

updateTransientInterval(long) - Method in class org.cometd.server.ServerSessionImpl

Updates the transient interval with the given value.

updateTransientTimeout(long) - Method in class org.cometd.server.ServerSessionImpl

Updates the transient timeout with the given value.

url - Variable in class org.cometd.client.transport.ClientTransport.FailureInfo

URL_OPTION - Static variable in class org.cometd.client.transport.ClientTransport

UTF8Reader(AbstractHttpTransport.Context, Promise<Void>) - Constructor for class org.cometd.server.http.AsyncJSONTransport.UTF8Reader

V

VALIDATE_MESSAGE_FIELDS_OPTION - Static variable in class org.cometd.server.BayeuxServerImpl

validateMessage(ServerMessage.Mutable) - Method in class org.cometd.server.BayeuxServerImpl

Validator() - Constructor for class org.cometd.bayeux.Bayeux.Validator

value() - Method in annotation type org.cometd.annotation.Listener

value() - Method in annotation type org.cometd.annotation.Param

value() - Method in annotation type org.cometd.annotation.server.Configure

value() - Method in annotation type org.cometd.annotation.server.RemoteCall

Returns the list of remote call target strings used by clients to identify the target of remote calls.

value() - Method in annotation type org.cometd.annotation.Service

value() - Method in annotation type org.cometd.annotation.Subscription

valueOf(String) - Static method in enum org.cometd.bayeux.server.Authorizer.Operation

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.cometd.client.BayeuxClient.State

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.cometd.server.ext.ActivityExtension.Activity

Returns the enum constant of this type with the specified name.

values() - Static method in enum org.cometd.bayeux.server.Authorizer.Operation

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.cometd.client.BayeuxClient.State

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.cometd.server.ext.ActivityExtension.Activity

Returns an array containing the constants of this enum type, in the order they are declared.

VERSION_FIELD - Static variable in interface org.cometd.bayeux.Message

VERSION_FIELD - Static variable in class org.cometd.oort.OortObject.Info

W

waitFor(long, BayeuxClient.State, BayeuxClient.State...) - Method in class org.cometd.client.BayeuxClient

Waits for this BayeuxClient to reach the given state(s) within the given time.

WebSocketDelegate() - Constructor for class org.cometd.client.websocket.javax.WebSocketTransport.WebSocketDelegate

WebSocketEndpoint() - Constructor for class org.cometd.client.websocket.javax.WebSocketTransport.WebSocketDelegate.WebSocketEndpoint

WebSocketEndPoint - Class in org.cometd.server.websocket.javax

WebSocketEndPoint(AbstractWebSocketTransport, BayeuxContext) - Constructor for class org.cometd.server.websocket.javax.WebSocketEndPoint

WebSocketTransport - Class in org.cometd.client.websocket.javax

WebSocketTransport - Class in org.cometd.server.websocket.javax

WebSocketTransport(String, Map<String, Object>, ScheduledExecutorService, WebSocketContainer) - Constructor for class org.cometd.client.websocket.javax.WebSocketTransport

WebSocketTransport(Map<String, Object>, ScheduledExecutorService, WebSocketContainer) - Constructor for class org.cometd.client.websocket.javax.WebSocketTransport

WebSocketTransport(BayeuxServerImpl) - Constructor for class org.cometd.server.websocket.javax.WebSocketTransport

WebSocketTransport.EndPoint - Class in org.cometd.server.websocket.javax

WebSocketTransport.Factory - Class in org.cometd.client.websocket.javax

WebSocketTransport.WebSocketDelegate - Class in org.cometd.client.websocket.javax

WebSocketTransport.WebSocketDelegate.WebSocketEndpoint - Class in org.cometd.client.websocket.javax

WILD - Static variable in class org.cometd.bayeux.ChannelId

write(AbstractHttpTransport.Context, List<ServerMessage>, Promise<Void>) - Method in class org.cometd.server.http.AbstractHttpTransport

write(AbstractHttpTransport.Context, List<ServerMessage>, Promise<Void>) - Method in class org.cometd.server.http.AbstractStreamHttpTransport

write(AbstractHttpTransport.Context, List<ServerMessage>, Promise<Void>) - Method in class org.cometd.server.http.AsyncJSONTransport

writeComplete(AbstractHttpTransport.Context, List<ServerMessage>) - Method in class org.cometd.server.http.AbstractStreamHttpTransport

writeComplete(AbstractHttpTransport.Context, List<ServerMessage>) - Method in class org.cometd.server.http.AsyncJSONTransport

writeComplete(AbstractWebSocketEndPoint.Context, List<ServerMessage>) - Method in class org.cometd.server.websocket.common.AbstractWebSocketEndPoint

writeComplete(AbstractWebSocketEndPoint.Context, List<ServerMessage>) - Method in class org.cometd.server.websocket.common.AbstractWebSocketTransport

writeComplete(AbstractWebSocketEndPoint.Context, List<ServerMessage>) - Method in class org.cometd.server.websocket.javax.WebSocketEndPoint

writeComplete(AbstractWebSocketEndPoint.Context, List<ServerMessage>) - Method in class org.cometd.server.websocket.javax.WebSocketTransport.EndPoint

writeComplete(AbstractWebSocketEndPoint.Context, List<ServerMessage>) - Method in class org.cometd.server.websocket.jetty.JettyWebSocketTransport.EndPoint

writeMessage(HttpServletResponse, ServletOutputStream, ServerSessionImpl, ServerMessage) - Method in class org.cometd.server.http.AbstractStreamHttpTransport

writeMessage(AbstractHttpTransport.Context, ServletOutputStream, ServerMessage) - Method in class org.cometd.server.http.AbstractStreamHttpTransport

Writer(AbstractHttpTransport.Context, List<ServerMessage>, Promise<Void>) - Constructor for class org.cometd.server.http.AsyncJSONTransport.Writer

Z

Z85 - Class in org.cometd.common

An implementation of Z85, a format for representing binary data as printable text defined at ZeroMQ Z85.

Z85.Decoder - Class in org.cometd.common

Z85.Encoder - Class in org.cometd.common

_

_patterns - Variable in class org.cometd.server.filter.RegexFilter

_replaces - Variable in class org.cometd.server.filter.RegexFilter

_templates - Variable in class org.cometd.server.filter.RegexFilter

A B C D E F G H I J L M N O P Q R S T U V W Z _
All Classes All Packages