Index

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 and Interfaces|All Packages|Constant Field Values|Serialized Form

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 class org.cometd.server.filter.DataFilter.AbortException

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

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

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

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

AbstractBayeuxContext(String, String, String, Map<String, List<String>>, Map<String, List<String>>, Principal, SocketAddress, SocketAddress, 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

AbstractHttpScheduler - Class in org.cometd.server.http

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

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.HttpScheduler - Interface in org.cometd.server.http

A AbstractServerTransport.Scheduler for HTTP-based transports.

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

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

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(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.jakarta.WebSocketTransport

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

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

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

accept(CometDRequest) - Method in class org.cometd.server.http.JSONHttpTransport

accept(CometDRequest) - Method in class org.cometd.server.http.JSONPHttpTransport

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

addFailureHandler(Consumer<Throwable>) - Method in interface org.cometd.server.CometDRequest

Adds the given handler function to be invoked when a failure is detected for this request.

addHeader(String, String) - Method in interface org.cometd.server.CometDResponse

Adds an HTTP header to this response.

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.jakarta

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.jakarta.AnnotationCometDServlet

AnnotationProcessor - Class in org.cometd.annotation

Base class for common functionality in annotation processors

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

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

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

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

The states that a BayeuxClient may assume.

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

bayeuxContext() - Method in class org.cometd.server.http.TransportContext

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

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

byteBuffer() - Method in interface org.cometd.server.CometDRequest.Input.Chunk

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.JSONPHttpTransport

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

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.AbstractHttpScheduler

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

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.

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

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

checkOrigin(ServerUpgradeRequest, 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.server.ext.BatchArrayQueue

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

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

CLIENT - Enum constant in enum class 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 - Enum constant in enum class 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.jakarta.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

CometDHandler - Class in org.cometd.server.http.jetty

CometDHandler maps HTTP requests to the HTTP server transports of a BayeuxServer instance.

CometDHandler() - Constructor for class org.cometd.server.http.jetty.CometDHandler

CometDHandler(Invocable.InvocationType) - Constructor for class org.cometd.server.http.jetty.CometDHandler

CometDRequest - Interface in org.cometd.server

An abstraction over HTTP requests.

CometDRequest.Input - Interface in org.cometd.server

The source of the request body.

CometDRequest.Input.Chunk - Interface in org.cometd.server

Request content bytes with the indication of whether they are the last.

CometDResponse - Interface in org.cometd.server

An abstraction over HTTP responses.

CometDResponse.Output - Interface in org.cometd.server

The sink of the response body.

CometDServlet - Class in org.cometd.server.http.jakarta

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

CometDServlet() - Constructor for class org.cometd.server.http.jakarta.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

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 Interface 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.

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

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

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

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

configureIfExists() - Element in annotation interface org.cometd.annotation.server.Configure

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

Configures the Oort instance with servlet init parameters.

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

connect(WebSocketContainer, ClientEndpointConfig, String) - Method in class org.cometd.client.websocket.jakarta.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.jakarta.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 - Enum constant in enum class org.cometd.client.BayeuxClient.State

State assumed when this BayeuxClient is connected to the Bayeux server

CONNECTING - Enum constant in enum class 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

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_ATTRIBUTE_NAME_OPTION - Static variable in class org.cometd.server.BayeuxServerImpl

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 - Enum constant in enum class 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 Class 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

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

demand(Runnable) - Method in interface org.cometd.server.CometDRequest.Input

Demands to invoke the given callback when request content bytes are available.

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, 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.jakarta.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.jakarta.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.jakarta.AnnotationCometDServlet

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

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

destroy() - Method in class org.cometd.oort.jakarta.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.http.AbstractHttpScheduler

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

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

DISCONNECTED - Enum constant in enum class org.cometd.client.BayeuxClient.State

State assumed before the handshake and when the disconnect is completed

DISCONNECTING - Enum constant in enum class org.cometd.client.BayeuxClient.State

State assumed when the disconnect is being sent

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

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

doStart() - Method in class org.cometd.server.http.jetty.CometDHandler

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

doStop() - Method in class org.cometd.server.http.jetty.CometDHandler

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

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

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.jakarta.WebSocketTransport.EndPoint

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

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

EOF - Static variable in interface org.cometd.server.CometDRequest.Input.Chunk

A convenient CometDRequest.Input.Chunk constant indicating end-of-file.

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() - Element in annotation interface 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.server.BayeuxServerImpl

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

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.jakarta.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 class org.cometd.bayeux.Promise.Wrapper

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

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

fail(Throwable) - Method in class org.cometd.server.http.AbstractHttpTransport.Writer

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.

find(BayeuxServer, CometDRequest) - Static method in class org.cometd.server.http.AbstractHttpTransport

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

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

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

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

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

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

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

flush(TransportContext) - 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(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

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 interface org.cometd.server.CometDRequest

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

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

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

getBatchArrayQueue() - Method in class org.cometd.server.ext.AcknowledgedMessagesSessionExtension

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

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.AbstractServerTransport

getBayeuxServer() - Method in class org.cometd.server.http.jakarta.CometDServlet

getBayeuxServer() - Method in class org.cometd.server.http.jetty.CometDHandler

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

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

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

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

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

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

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

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

getCallbackMaxLength() - Method in class org.cometd.server.http.JSONPHttpTransport

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

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

getCharacterEncoding() - Method in interface org.cometd.server.CometDRequest

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

getCode() - Method in exception class org.cometd.server.HttpException

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.AbstractHttpScheduler

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

getContextAttribute(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

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

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

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

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

getCookies(URI) - 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 class 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

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

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

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

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

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

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

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

getInput() - Method in interface org.cometd.server.CometDRequest

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

getIntervalNanoTime() - 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

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

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.AbstractHttpScheduler

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.AbstractHttpScheduler

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

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

getMethod() - Method in interface org.cometd.server.CometDRequest

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

getOptions() - Method in class org.cometd.server.http.jetty.CometDHandler

getOutput() - Method in interface org.cometd.server.CometDResponse

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

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

getParameterValues(String) - Method in interface org.cometd.server.CometDRequest

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.AbstractHttpScheduler

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

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

getProtocol() - Method in interface org.cometd.server.CometDRequest

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

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.jakarta.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

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

Returns an HTTP session attribute value.

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

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

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

Returns the HTTP session id, or null if there is no HTTP session.

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

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

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 interface org.cometd.bayeux.server.BayeuxServer

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

getWrapped() - Method in class org.cometd.bayeux.Promise.Wrapper

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(BayeuxContext, CometDRequest, CometDResponse, Promise<Void>) - Method in class org.cometd.server.http.AbstractHttpTransport

handle(ClientTransport.FailureInfo) - Method in interface org.cometd.client.transport.ClientTransport.FailureHandler

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

handle(TransportContext) - Method in class org.cometd.server.http.JSONHttpTransport

handle(TransportContext) - Method in class org.cometd.server.http.JSONPHttpTransport

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

handle(Request, Response, Callback) - Method in class org.cometd.server.http.jetty.CometDHandler

handleMessage(TransportContext, 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

HANDSHAKEN - Enum constant in enum class org.cometd.client.BayeuxClient.State

State assumed when the handshake is received, but before connecting

HANDSHAKING - Enum constant in enum class 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(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

HttpException - Exception Class in org.cometd.server

HttpException(int, Throwable) - Constructor for exception class org.cometd.server.HttpException

I

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

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.jakarta.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.jakarta.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.server.AbstractServerTransport

Initializes the transport, resolving default and direct options.

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

init() - Method in class org.cometd.server.http.jakarta.CometDServlet

init() - Method in class org.cometd.server.http.JSONPHttpTransport

init() - Method in class org.cometd.server.websocket.common.AbstractWebSocketTransport

init() - Method in class org.cometd.server.websocket.jakarta.WebSocketTransport

init() - Method in class org.cometd.server.websocket.jetty.JettyWebSocketTransport

init(ServletConfig) - Method in class org.cometd.oort.jakarta.OortConfigServlet

init(ServletConfig) - Method in class org.cometd.oort.jakarta.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

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

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

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

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

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(CometDRequest) - 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

isLast() - Method in interface org.cometd.server.CometDRequest.Input.Chunk

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.jakarta.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,I> - 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> - 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> - 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

JSONHttpTransport - Class in org.cometd.server.http

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

JSONPHttpTransport - Class in org.cometd.server.http

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

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

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

M

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

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

messageClass() - Method in class org.cometd.common.JacksonJSONContextClient

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

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() - Method in class org.cometd.server.http.TransportContext

messages(List<ServerMessage.Mutable>) - Method in class org.cometd.server.http.TransportContext

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_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() - Method in class org.cometd.server.http.TransportContext

metaConnectCycle(long) - Method in class org.cometd.server.http.TransportContext

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

modifyHandshake(HandshakeRequest, HandshakeResponse) - Method in class org.cometd.server.websocket.jakarta.WebSocketTransport

modifyUpgrade(ServerUpgradeRequest, ServerUpgradeResponse) - Method in class org.cometd.server.websocket.jetty.JettyWebSocketTransport

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.JSONHttpTransport

NAME - Static variable in class org.cometd.server.http.JSONPHttpTransport

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.http.jakarta.CometDServlet

newBayeuxServer() - Method in class org.cometd.server.http.jetty.CometDHandler

newBrowserCookie(StringBuilder, String, String, boolean) - Method in class org.cometd.server.http.AbstractHttpTransport

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.jakarta.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.jakarta.WebSocketTransport

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

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

newHttpScheduler(TransportContext, Promise<Void>, ServerMessage.Mutable, long) - Method in class org.cometd.server.http.AbstractHttpTransport

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.common.JettyJSONContext

newMessage() - Method in class org.cometd.common.JettyJSONContextClient

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

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

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.jakarta.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

newServerAnnotationProcessor(BayeuxServer) - Method in class org.cometd.annotation.server.jakarta.AnnotationCometDServlet

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

newService(String) - Method in class org.cometd.annotation.server.jakarta.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.jakarta.SetiServlet

newWebSocketEndPoint(BayeuxContext) - Method in class org.cometd.server.websocket.jakarta.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(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.

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.jakarta.WebSocketTransport.WebSocketDelegate.WebSocketEndpoint

onClose(Session, CloseReason) - Method in class org.cometd.server.websocket.jakarta.WebSocketEndPoint

onCompleteFailure(Throwable) - Method in class org.cometd.server.http.AbstractHttpTransport.Writer

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

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

onError(Session, Throwable) - Method in class org.cometd.client.websocket.jakarta.WebSocketTransport.WebSocketDelegate.WebSocketEndpoint

onError(Session, Throwable) - Method in class org.cometd.server.websocket.jakarta.WebSocketEndPoint

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.jakarta.WebSocketTransport

onHandshakeRequest(Request) - Method in class org.cometd.client.websocket.jetty.JettyWebSocketTransport

onHandshakeResponse(HandshakeResponse) - Method in class org.cometd.client.websocket.jakarta.WebSocketTransport

onHandshakeResponse(Response) - Method in class org.cometd.client.websocket.okhttp.OkHttpWebSocketTransport

onHandshakeResponse(Request, Response) - 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.jakarta.WebSocketTransport.WebSocketDelegate

onMessage(String) - Method in class org.cometd.server.websocket.jakarta.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.jakarta.WebSocketTransport.WebSocketDelegate.WebSocketEndpoint

onOpen(Session, EndpointConfig) - Method in class org.cometd.server.websocket.jakarta.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.

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(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.

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

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

onWebSocketError(Throwable) - Method in class org.cometd.server.websocket.jetty.JettyWebSocketEndPoint

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

onWebSocketOpen(Session) - 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

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.jakarta.OortConfigServlet

OORT_CLIENT_TRANSPORT_FACTORIES_PARAM - Static variable in class org.cometd.oort.jakarta.OortConfigServlet

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

OORT_CLOUD_PARAM - Static variable in class org.cometd.oort.jakarta.OortStaticConfigServlet

OORT_CONTEXT_ATTRIBUTE_NAME_PARAM - Static variable in class org.cometd.oort.jakarta.OortConfigServlet

OORT_ENABLE_ACK_EXTENSION_PARAM - Static variable in class org.cometd.oort.jakarta.OortConfigServlet

OORT_ENABLE_BINARY_EXTENSION_PARAM - Static variable in class org.cometd.oort.jakarta.OortConfigServlet

OORT_JSON_CONTEXT_PARAM - Static variable in class org.cometd.oort.jakarta.OortConfigServlet

OORT_MULTICAST_ADVERTISE_INTERVAL_PARAM - Static variable in class org.cometd.oort.jakarta.OortMulticastConfigServlet

OORT_MULTICAST_BIND_ADDRESS_PARAM - Static variable in class org.cometd.oort.jakarta.OortMulticastConfigServlet

OORT_MULTICAST_CONNECT_TIMEOUT_PARAM - Static variable in class org.cometd.oort.jakarta.OortMulticastConfigServlet

OORT_MULTICAST_GROUP_ADDRESS_PARAM - Static variable in class org.cometd.oort.jakarta.OortMulticastConfigServlet

OORT_MULTICAST_GROUP_INTERFACES_PARAM - Static variable in class org.cometd.oort.jakarta.OortMulticastConfigServlet

OORT_MULTICAST_GROUP_PORT_PARAM - Static variable in class org.cometd.oort.jakarta.OortMulticastConfigServlet

OORT_MULTICAST_MAX_TRANSMISSION_LENGTH_PARAM - Static variable in class org.cometd.oort.jakarta.OortMulticastConfigServlet

OORT_MULTICAST_TIME_TO_LIVE_PARAM - Static variable in class org.cometd.oort.jakarta.OortMulticastConfigServlet

OORT_OBJECTS_CHANNEL - Static variable in class org.cometd.oort.OortObject

OORT_SECRET_PARAM - Static variable in class org.cometd.oort.jakarta.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.jakarta.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.jakarta

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.jakarta.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.jakarta

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.jakarta.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.jakarta

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.jakarta.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 - module org.cometd.annotation

org.cometd.annotation - package org.cometd.annotation

org.cometd.annotation.client - module org.cometd.annotation.client

org.cometd.annotation.client - package org.cometd.annotation.client

org.cometd.annotation.server - module org.cometd.annotation.server

org.cometd.annotation.server - package org.cometd.annotation.server

org.cometd.annotation.server.jakarta - module org.cometd.annotation.server.jakarta

org.cometd.annotation.server.jakarta - package org.cometd.annotation.server.jakarta

org.cometd.api - module org.cometd.api

org.cometd.api.client - module org.cometd.api.client

org.cometd.api.server - module org.cometd.api.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.client - module org.cometd.client

org.cometd.client - package org.cometd.client

org.cometd.client.ext - package org.cometd.client.ext

org.cometd.client.http.common - module org.cometd.client.http.common

org.cometd.client.http.common - package org.cometd.client.http.common

org.cometd.client.http.jetty - module org.cometd.client.http.jetty

org.cometd.client.http.jetty - package org.cometd.client.http.jetty

org.cometd.client.http.okhttp - module org.cometd.client.http.okhttp

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 - module org.cometd.client.websocket.common

org.cometd.client.websocket.common - package org.cometd.client.websocket.common

org.cometd.client.websocket.jakarta - module org.cometd.client.websocket.jakarta

org.cometd.client.websocket.jakarta - package org.cometd.client.websocket.jakarta

org.cometd.client.websocket.jetty - module org.cometd.client.websocket.jetty

org.cometd.client.websocket.jetty - package org.cometd.client.websocket.jetty

org.cometd.client.websocket.okhttp - module org.cometd.client.websocket.okhttp

org.cometd.client.websocket.okhttp - package org.cometd.client.websocket.okhttp

org.cometd.common - module org.cometd.common

org.cometd.common - package org.cometd.common

org.cometd.oort - module org.cometd.oort

org.cometd.oort - package org.cometd.oort

org.cometd.oort.jakarta - module org.cometd.oort.jakarta

org.cometd.oort.jakarta - package org.cometd.oort.jakarta

org.cometd.oort.jmx - package org.cometd.oort.jmx

org.cometd.server - module org.cometd.server

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.http.jakarta - module org.cometd.server.http.jakarta

org.cometd.server.http.jakarta - package org.cometd.server.http.jakarta

org.cometd.server.http.jetty - module org.cometd.server.http.jetty

org.cometd.server.http.jetty - package org.cometd.server.http.jetty

org.cometd.server.jmx - package org.cometd.server.jmx

org.cometd.server.websocket.common - module org.cometd.server.websocket.common

org.cometd.server.websocket.common - package org.cometd.server.websocket.common

org.cometd.server.websocket.jakarta - module org.cometd.server.websocket.jakarta

org.cometd.server.websocket.jakarta - package org.cometd.server.websocket.jakarta

org.cometd.server.websocket.jetty - module org.cometd.server.websocket.jetty

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 Interface 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(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(String) - Method in class org.cometd.client.transport.ClientTransport

parseMessages(String) - Method in class org.cometd.server.AbstractServerTransport

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.server.ext.BatchArrayQueue

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

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() - Method in class org.cometd.server.http.AbstractHttpTransport.Writer

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, 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.

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, 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(TransportContext, List<ServerMessage.Mutable>) - 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.jakarta.AnnotationCometDServlet

processWrongResponseCode(TransportListener, List<Message.Mutable>, int) - Method in class org.cometd.client.http.common.AbstractHttpClientTransport

promise() - Method in class org.cometd.server.http.TransportContext

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.

Promise.Wrapper<W> - Class in org.cometd.bayeux

A wrapper for Promise instances.

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.jakarta.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 - Enum constant in enum class 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

read() - Method in interface org.cometd.server.CometDRequest.Input

Reads request content bytes into a CometDRequest.Input.Chunk.

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() - Element in annotation interface 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.jakarta.AnnotationCometDServlet

registerSubscriber(String, ClientSessionChannel.MessageListener) - Method in class org.cometd.common.AbstractClientSession

REHANDSHAKING - Enum constant in enum class 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

release() - Method in interface org.cometd.server.CometDRequest.Input.Chunk

Releases this CometDRequest.Input.Chunk so its CometDRequest.Input.Chunk.byteBuffer() can be recycled.

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 Interface 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() - Method in class org.cometd.server.http.TransportContext

request() - Method in class org.cometd.server.http.TransportContext

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

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() - Method in class org.cometd.server.http.TransportContext

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(TransportContext, 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.

run() - Method in class org.cometd.server.http.AbstractHttpScheduler

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.AbstractHttpScheduler

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() - Method in class org.cometd.server.http.TransportContext

scheduleExpiration(boolean) - Method in class org.cometd.server.http.TransportContext

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() - Method in class org.cometd.server.http.TransportContext

scheduler(AbstractHttpTransport.HttpScheduler) - Method in class org.cometd.server.http.TransportContext

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.jakarta.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, Promise<Void>) - Method in class org.cometd.server.websocket.common.AbstractWebSocketEndPoint

send(ServerSession, String, Promise<Void>) - 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.jakarta.CometDServlet

sendError(Request, Response, Callback, int, Throwable) - Method in class org.cometd.server.http.jetty.CometDHandler

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() - Method in class org.cometd.server.http.TransportContext

sendQueue(boolean) - Method in class org.cometd.server.http.TransportContext

sendSubscribe(Message.Mutable, ClientSessionChannel.MessageListener, ClientSession.MessageListener) - Method in class org.cometd.common.AbstractClientSession.AbstractSessionChannel

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.http.jakarta.CometDServlet

Service - Annotation Interface 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.http.jakarta.CometDServlet

serviceOptions(Request, Response, Callback) - Method in class org.cometd.server.http.jetty.CometDHandler

session() - Method in class org.cometd.server.http.TransportContext

session(ServerSessionImpl) - Method in class org.cometd.server.http.TransportContext

Session - Interface in org.cometd.bayeux

A Bayeux session represents a connection between a bayeux client and a bayeux server.

Session - Annotation Interface 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 interface org.cometd.server.CometDRequest

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(TransportContext) - 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

setContentType(String) - Method in interface org.cometd.server.CometDResponse

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

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

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_CONTEXT_ATTRIBUTE_NAME_PARAM - Static variable in class org.cometd.oort.jakarta.SetiServlet

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.jakarta

This servlet initializes and configures and instance of the Seti user mapper.

SetiServlet() - Constructor for class org.cometd.oort.jakarta.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

setOptions(Map<String, String>) - Method in class org.cometd.server.http.jetty.CometDHandler

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.jakarta.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

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

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 - Enum constant in enum class 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 Interface 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(Void) - Method in class org.cometd.server.http.AbstractHttpTransport.Writer

succeed(S) - Method in class org.cometd.bayeux.Promise.Completable

succeed(W) - Method in class org.cometd.bayeux.Promise.Wrapper

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(TransportContext, Promise<Void>, ServerMessage.Mutable, long) - Method in class org.cometd.server.http.AbstractHttpTransport

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

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 - Enum constant in enum class 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.AbstractHttpScheduler

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.jakarta.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

TransportContext - Class in org.cometd.server.http

TransportContext(BayeuxContext, CometDRequest, CometDResponse, Promise<Void>) - Constructor for class org.cometd.server.http.TransportContext

TransportException - Exception Class in org.cometd.common

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

TransportException(Map<String, Object>) - Constructor for exception class 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

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

U

UNCONNECTED - Enum constant in enum class 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

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

V

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

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

value() - Element in annotation interface org.cometd.annotation.Listener

value() - Element in annotation interface org.cometd.annotation.Param

value() - Element in annotation interface org.cometd.annotation.server.Configure

value() - Element in annotation interface org.cometd.annotation.server.RemoteCall

Returns the list of remote call target strings used by clients to identify the target of remote calls.

value() - Element in annotation interface org.cometd.annotation.Service

value() - Element in annotation interface org.cometd.annotation.Subscription

valueOf(String) - Static method in enum class org.cometd.bayeux.server.Authorizer.Operation

Returns the enum constant of this class with the specified name.

valueOf(String) - Static method in enum class org.cometd.client.BayeuxClient.State

Returns the enum constant of this class with the specified name.

valueOf(String) - Static method in enum class org.cometd.server.ext.ActivityExtension.Activity

Returns the enum constant of this class with the specified name.

values() - Static method in enum class org.cometd.bayeux.server.Authorizer.Operation

Returns an array containing the constants of this enum class, in the order they are declared.

values() - Static method in enum class org.cometd.client.BayeuxClient.State

Returns an array containing the constants of this enum class, in the order they are declared.

values() - Static method in enum class org.cometd.server.ext.ActivityExtension.Activity

Returns an array containing the constants of this enum class, 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.jakarta.WebSocketTransport.WebSocketDelegate

WebSocketEndpoint() - Constructor for class org.cometd.client.websocket.jakarta.WebSocketTransport.WebSocketDelegate.WebSocketEndpoint

WebSocketEndPoint - Class in org.cometd.server.websocket.jakarta

WebSocketEndPoint(AbstractWebSocketTransport, BayeuxContext) - Constructor for class org.cometd.server.websocket.jakarta.WebSocketEndPoint

WebSocketTransport - Class in org.cometd.client.websocket.jakarta

WebSocketTransport - Class in org.cometd.server.websocket.jakarta

WebSocketTransport(String, Map<String, Object>, ScheduledExecutorService, WebSocketContainer) - Constructor for class org.cometd.client.websocket.jakarta.WebSocketTransport

WebSocketTransport(Map<String, Object>, ScheduledExecutorService, WebSocketContainer) - Constructor for class org.cometd.client.websocket.jakarta.WebSocketTransport

WebSocketTransport(BayeuxServerImpl) - Constructor for class org.cometd.server.websocket.jakarta.WebSocketTransport

WebSocketTransport.EndPoint - Class in org.cometd.server.websocket.jakarta

WebSocketTransport.Factory - Class in org.cometd.client.websocket.jakarta

WebSocketTransport.WebSocketDelegate - Class in org.cometd.client.websocket.jakarta

WebSocketTransport.WebSocketDelegate.WebSocketEndpoint - Class in org.cometd.client.websocket.jakarta

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

Wrapper(Promise<W>) - Constructor for class org.cometd.bayeux.Promise.Wrapper

write(boolean, byte[], Promise<Void>) - Method in interface org.cometd.server.CometDResponse.Output

Writes the given response bytes, notifying the given promise when the write operation is complete.

write(TransportContext, List<ServerMessage>) - Method in class org.cometd.server.http.AbstractHttpTransport

writeBegin(CometDResponse.Output, Promise<Void>) - Method in class org.cometd.server.http.AbstractHttpTransport

writeBegin(CometDResponse.Output, Promise<Void>) - Method in class org.cometd.server.http.JSONPHttpTransport

writeComplete(TransportContext, List<ServerMessage>) - Method in class org.cometd.server.http.AbstractHttpTransport

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.jakarta.WebSocketEndPoint

writeComplete(AbstractWebSocketEndPoint.Context, List<ServerMessage>) - Method in class org.cometd.server.websocket.jakarta.WebSocketTransport.EndPoint

writeComplete(AbstractWebSocketEndPoint.Context, List<ServerMessage>) - Method in class org.cometd.server.websocket.jetty.JettyWebSocketTransport.EndPoint

writeEnd(CometDResponse.Output, Promise<Void>) - Method in class org.cometd.server.http.AbstractHttpTransport

writeEnd(CometDResponse.Output, Promise<Void>) - Method in class org.cometd.server.http.JSONPHttpTransport

writeMessage(CometDResponse.Output, ServerMessage, Promise<Void>) - Method in class org.cometd.server.http.AbstractHttpTransport

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

writePrepare(TransportContext, Promise<Void>) - Method in class org.cometd.server.http.JSONPHttpTransport

Writer(TransportContext, List<ServerMessage>) - Constructor for class org.cometd.server.http.AbstractHttpTransport.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 and Interfaces|All Packages|Constant Field Values|Serialized Form