Uses of Interface
org.cometd.bayeux.server.ServerSession

Packages that use ServerSession

Package	Description
org.cometd.annotation.server
org.cometd.bayeux.server
org.cometd.oort
org.cometd.server
org.cometd.server.authorizer
org.cometd.server.ext
org.cometd.server.filter
org.cometd.server.websocket.common
org.cometd.server.websocket.jetty

Uses of ServerSession in org.cometd.annotation.server

Methods in org.cometd.annotation.server that return ServerSession

Modifier and Type	Method	Description
ServerSession	RemoteCall.Caller.getServerSession()

Uses of ServerSession in org.cometd.bayeux.server

Methods in org.cometd.bayeux.server that return ServerSession

Modifier and Type	Method	Description
ServerSession	LocalSession.getServerSession()
ServerSession	BayeuxServer.getSession(String clientId)

Methods in org.cometd.bayeux.server that return types with arguments of type ServerSession

Modifier and Type	Method	Description
List<ServerSession>	BayeuxServer.getSessions()
Set<ServerSession>	ServerChannel.getSubscribers()

Methods in org.cometd.bayeux.server with parameters of type ServerSession

Modifier and Type	Method	Description
void	ServerSession.AddedListener.added(ServerSession session, ServerMessage message)	Callback method invoked when the session is added to a BayeuxServer.
Authorizer.Result	Authorizer.authorize(Authorizer.Operation operation, ChannelId channel, ServerSession session, ServerMessage message)	Blocking version of Authorizer.authorize(Operation, ChannelId, ServerSession, ServerMessage, Promise).
default void	Authorizer.authorize(Authorizer.Operation operation, ChannelId channel, ServerSession session, ServerMessage message, Promise<Authorizer.Result> promise)	Callback invoked to authorize the given operation on the given channel.
default boolean	SecurityPolicy.canCreate(BayeuxServer server, ServerSession session, String channelId, ServerMessage message)	Blocking version of SecurityPolicy.canCreate(BayeuxServer, ServerSession, String, ServerMessage, Promise).
default void	SecurityPolicy.canCreate(BayeuxServer server, ServerSession session, String channelId, ServerMessage message, Promise<Boolean> promise)	Checks if a message should be allowed to create a new channel.
default boolean	SecurityPolicy.canHandshake(BayeuxServer server, ServerSession session, ServerMessage message)	Blocking version of SecurityPolicy.canHandshake(BayeuxServer, ServerSession, ServerMessage, Promise).
default void	SecurityPolicy.canHandshake(BayeuxServer server, ServerSession session, ServerMessage message, Promise<Boolean> promise)	Checks if a handshake message should be accepted.
default boolean	SecurityPolicy.canPublish(BayeuxServer server, ServerSession session, ServerChannel channel, ServerMessage message)	Blocking version of SecurityPolicy.canPublish(BayeuxServer, ServerSession, ServerChannel, ServerMessage, Promise).
default void	SecurityPolicy.canPublish(BayeuxServer server, ServerSession session, ServerChannel channel, ServerMessage message, Promise<Boolean> promise)	Checks if a client can publish a message to a channel.
default boolean	SecurityPolicy.canSubscribe(BayeuxServer server, ServerSession session, ServerChannel channel, ServerMessage message)	Blocking version of SecurityPolicy.canSubscribe(BayeuxServer, ServerSession, ServerChannel, ServerMessage, Promise).
default void	SecurityPolicy.canSubscribe(BayeuxServer server, ServerSession session, ServerChannel channel, ServerMessage message, Promise<Boolean> promise)	Checks if a subscribe message from a client is allowed to subscribe to a channel.
void	ServerSession.DeQueueListener.deQueue(ServerSession session, Queue<ServerMessage> queue)	Callback invoked to notify that the queue of messages is about to be sent to the remote client.
default void	ServerSession.DeQueueListener.deQueue(ServerSession session, Queue<ServerMessage> queue, List<ServerMessage.Mutable> replies)	Callback invoked to notify that the queue of messages and the message replies are about to be sent to the remote client.
default void	BayeuxServer.Extension.incoming(ServerSession from, ServerMessage.Mutable message, Promise<Boolean> promise)	Callback method invoked every time a message is incoming.
default void	ServerSession.Extension.incoming(ServerSession session, ServerMessage.Mutable message, Promise<Boolean> promise)	Callback method invoked every time a message is incoming.
default boolean	ServerChannel.MessageListener.onMessage(ServerSession sender, ServerChannel channel, ServerMessage.Mutable message)	Blocking version of ServerChannel.MessageListener.onMessage(ServerSession, ServerChannel, ServerMessage.Mutable, Promise).
default void	ServerChannel.MessageListener.onMessage(ServerSession sender, ServerChannel channel, ServerMessage.Mutable message, Promise<Boolean> promise)	Callback invoked when a message is being published.
default boolean	ServerSession.MessageListener.onMessage(ServerSession session, ServerSession sender, ServerMessage message)	Blocking version of ServerSession.MessageListener.onMessage(ServerSession, ServerSession, ServerMessage, Promise).
default void	ServerSession.MessageListener.onMessage(ServerSession session, ServerSession sender, ServerMessage message, Promise<Boolean> promise)	Callback invoked when a message is sent.
default void	ServerSession.HeartBeatListener.onResumed(ServerSession session, ServerMessage message, boolean timeout)	Callback invoked to notify that a /meta/connect message has been resumed.
default void	ServerSession.HeartBeatListener.onSuspended(ServerSession session, ServerMessage message, long timeout)	Callback invoked to notify that a /meta/connect message has been suspended.
default void	BayeuxServer.Extension.outgoing(ServerSession from, ServerSession to, ServerMessage.Mutable message, Promise<Boolean> promise)	Callback method invoked every time a message is outgoing.
default void	ServerSession.Extension.outgoing(ServerSession sender, ServerSession session, ServerMessage.Mutable message, Promise<ServerMessage.Mutable> promise)	Callback method invoked every time a message is outgoing.
void	ServerSession.QueueListener.queued(ServerSession sender, ServerMessage message)	Callback invoked when a message is queued in the session queue.
boolean	ServerSession.QueueMaxedListener.queueMaxed(ServerSession session, Queue<ServerMessage> queue, ServerSession sender, ServerMessage message)	Callback invoked to notify when the message queue is exceeding the value configured for the transport with the option "maxQueue".
default boolean	BayeuxServer.Extension.rcv(ServerSession from, ServerMessage.Mutable message)	Blocking version of BayeuxServer.Extension.incoming(ServerSession, ServerMessage.Mutable, Promise) for non-meta messages.
default boolean	ServerSession.Extension.rcv(ServerSession session, ServerMessage.Mutable message)	Blocking version of ServerSession.Extension.incoming(ServerSession, ServerMessage.Mutable, Promise) for non-meta messages.
default boolean	BayeuxServer.Extension.rcvMeta(ServerSession from, ServerMessage.Mutable message)	Blocking version of BayeuxServer.Extension.incoming(ServerSession, ServerMessage.Mutable, Promise) for meta messages.
default boolean	ServerSession.Extension.rcvMeta(ServerSession session, ServerMessage.Mutable message)	Blocking version of ServerSession.Extension.incoming(ServerSession, ServerMessage.Mutable, Promise) for meta messages.
void	ServerSession.RemovedListener.removed(ServerSession session, ServerMessage message, boolean timeout)	Callback invoked when the session is removed.
boolean	BayeuxServer.removeSession(ServerSession session)	Removes the given session from this BayeuxServer.
default boolean	BayeuxServer.Extension.send(ServerSession from, ServerSession to, ServerMessage.Mutable message)	Blocking version of BayeuxServer.Extension.outgoing(ServerSession, ServerSession, ServerMessage.Mutable, Promise) for non-meta messages.
default ServerMessage	ServerSession.Extension.send(ServerSession sender, ServerSession session, ServerMessage message)	Blocking version of ServerSession.Extension.outgoing(ServerSession, ServerSession, ServerMessage.Mutable, Promise) for non-meta messages.
default boolean	BayeuxServer.Extension.sendMeta(ServerSession to, ServerMessage.Mutable message)	Blocking version of BayeuxServer.Extension.outgoing(ServerSession, ServerSession, ServerMessage.Mutable, Promise) for meta messages.
default boolean	ServerSession.Extension.sendMeta(ServerSession sender, ServerSession session, ServerMessage.Mutable message)	Blocking version of ServerSession.Extension.outgoing(ServerSession, ServerSession, ServerMessage.Mutable, Promise) for meta messages.
default void	BayeuxServer.SessionListener.sessionAdded(ServerSession session, ServerMessage message)	Callback invoked when a ServerSession has been added to a BayeuxServer object.
default void	BayeuxServer.SessionListener.sessionRemoved(ServerSession session, ServerMessage message, boolean timeout)	Callback invoked when a ServerSession has been removed from a BayeuxServer object.
boolean	ServerChannel.subscribe(ServerSession session)	Subscribes the given session to this channel.
default void	BayeuxServer.SubscriptionListener.subscribed(ServerSession session, ServerChannel channel, ServerMessage message)	Callback invoked when a ServerSession subscribes to a ServerChannel.
default void	ServerChannel.SubscriptionListener.subscribed(ServerSession session, ServerChannel channel, ServerMessage message)	Callback invoked when the given ServerSession subscribes to the given ServerChannel.
boolean	ServerChannel.unsubscribe(ServerSession session)	Unsubscribes the given session from this channel.
default void	BayeuxServer.SubscriptionListener.unsubscribed(ServerSession session, ServerChannel channel, ServerMessage message)	Callback invoked when a ServerSession unsubscribes from a ServerChannel.
default void	ServerChannel.SubscriptionListener.unsubscribed(ServerSession session, ServerChannel channel, ServerMessage message)	Callback invoked when the given ServerSession unsubscribes from the given ServerChannel.

Uses of ServerSession in org.cometd.oort

Methods in org.cometd.oort that return ServerSession

Modifier and Type	Method	Description
ServerSession	OortService.ServerContext.getServerSession()

Methods in org.cometd.oort that return types with arguments of type ServerSession

Modifier and Type	Method	Description
Set<ServerSession>	Seti.disassociate(String userId)	Disassociates the given userId from all sessions.

Methods in org.cometd.oort with parameters of type ServerSession

Modifier and Type	Method	Description
boolean	Seti.associate(String userId, ServerSession session)	Associates the given userId to the given session.
boolean	Seti.disassociate(String userId, ServerSession session)	Disassociates the given userId from the given session.
boolean	Oort.isOort(ServerSession session)
boolean	Oort.CloudListener.onMessage(ServerSession from, ServerChannel channel, ServerMessage.Mutable message)
boolean	OortService.onMessage(ServerSession from, ServerChannel channel, ServerMessage.Mutable message)
void	Seti.LocalLocation.removed(ServerSession session, ServerMessage message, boolean timeout)

Constructors in org.cometd.oort with parameters of type ServerSession

Modifier	Constructor	Description
protected	LocalLocation(String userId, ServerSession session)
	ServerContext(ServerSession session, ServerMessage message)

Uses of ServerSession in org.cometd.server

Classes in org.cometd.server that implement ServerSession

Modifier and Type	Class	Description
class	ServerSessionImpl

Methods in org.cometd.server that return ServerSession

Modifier and Type	Method	Description
ServerSession	AbstractService.getServerSession()
ServerSession	LocalSessionImpl.getServerSession()
ServerSession	BayeuxServerImpl.getSession(String clientId)

Methods in org.cometd.server that return types with arguments of type ServerSession

Modifier and Type	Method	Description
List<ServerSession>	BayeuxServerImpl.getSessions()
Set<ServerSession>	ServerChannelImpl.getSubscribers()
Set<ServerSession>	ServerChannelImpl.subscribers()

Methods in org.cometd.server with parameters of type ServerSession

Modifier and Type	Method	Description
boolean	DefaultSecurityPolicy.canCreate(BayeuxServer server, ServerSession session, String channelId, ServerMessage message)
boolean	DefaultSecurityPolicy.canHandshake(BayeuxServer server, ServerSession session, ServerMessage message)
boolean	DefaultSecurityPolicy.canPublish(BayeuxServer server, ServerSession session, ServerChannel channel, ServerMessage message)
boolean	DefaultSecurityPolicy.canSubscribe(BayeuxServer server, ServerSession session, ServerChannel channel, ServerMessage message)
protected void	ServerSessionImpl.deliver1(ServerSession sender, ServerMessage.Mutable mutable, Promise<Boolean> promise)
protected void	AbstractService.doInvoke(Method method, ServerSession session, ServerMessage message)
protected void	AbstractService.exception(String method, ServerSession session, LocalSession local, ServerMessage message, Throwable x)	Handles exceptions during the invocation of a mapped method.
protected void	BayeuxServerImpl.extendOutgoing(ServerSession sender, ServerSession session, ServerMessage.Mutable message, Promise<Boolean> promise)
protected void	ServerSessionImpl.extendOutgoing(ServerSession sender, ServerMessage.Mutable message, Promise<ServerMessage.Mutable> promise)
boolean	BayeuxServerImpl.removeServerSession(ServerSession session, boolean timeout)
boolean	BayeuxServerImpl.removeSession(ServerSession session)
protected void	AbstractService.send(ServerSession toClient, String onChannel, Object data)	Sends data to an individual remote client.
boolean	ServerChannelImpl.subscribe(ServerSession session)
boolean	ServerChannelImpl.unsubscribe(ServerSession session)

Uses of ServerSession in org.cometd.server.authorizer

Methods in org.cometd.server.authorizer with parameters of type ServerSession

Modifier and Type	Method	Description
Authorizer.Result	GrantAuthorizer.authorize(Authorizer.Operation operation, ChannelId channel, ServerSession session, ServerMessage message)

Uses of ServerSession in org.cometd.server.ext

Methods in org.cometd.server.ext with parameters of type ServerSession

Modifier and Type	Method	Description
void	AcknowledgedMessagesSessionExtension.deQueue(ServerSession session, Queue<ServerMessage> queue)
void	AcknowledgedMessagesSessionExtension.deQueue(ServerSession session, Queue<ServerMessage> queue, List<ServerMessage.Mutable> replies)
protected void	ActivityExtension.SessionExtension.disconnect(ServerSession session)
protected AcknowledgedMessagesSessionExtension	AcknowledgedMessagesExtension.newSessionExtension(ServerSession session)
protected ServerSession.Extension	ActivityExtension.newSessionExtension(ServerSession session, ServerMessage handshake)	Creates a new ServerSession.Extension that monitors the activity of the given ServerSession
default void	AcknowledgedMessagesExtension.Listener.onBatchReceive(ServerSession session, long batch)	Callback method invoked when a client session confirms it has received the given batch of messages.
default void	AcknowledgedMessagesExtension.Listener.onBatchSend(ServerSession session, List<ServerMessage> messages, long batch)	Callback method invoked when a batch of message is about to be sent to a client session.
void	AcknowledgedMessagesSessionExtension.queued(ServerSession sender, ServerMessage message)
boolean	AcknowledgedMessagesSessionExtension.rcv(ServerSession from, ServerMessage.Mutable message)
boolean	ActivityExtension.SessionExtension.rcv(ServerSession session, ServerMessage.Mutable message)
boolean	BinaryExtension.rcv(ServerSession from, ServerMessage.Mutable message)
boolean	BinarySessionExtension.rcv(ServerSession session, ServerMessage.Mutable message)
boolean	AcknowledgedMessagesExtension.rcvMeta(ServerSession remote, ServerMessage.Mutable message)
boolean	AcknowledgedMessagesSessionExtension.rcvMeta(ServerSession session, ServerMessage.Mutable message)
boolean	ActivityExtension.rcvMeta(ServerSession session, ServerMessage.Mutable message)
boolean	ActivityExtension.SessionExtension.rcvMeta(ServerSession session, ServerMessage.Mutable message)
boolean	TimesyncExtension.rcvMeta(ServerSession from, ServerMessage.Mutable message)
ServerMessage	AcknowledgedMessagesSessionExtension.send(ServerSession sender, ServerSession session, ServerMessage message)
ServerMessage	ActivityExtension.SessionExtension.send(ServerSession sender, ServerSession session, ServerMessage message)
boolean	BinaryExtension.send(ServerSession from, ServerSession to, ServerMessage.Mutable message)
ServerMessage	BinarySessionExtension.send(ServerSession sender, ServerSession session, ServerMessage message)
boolean	TimestampExtension.send(ServerSession from, ServerSession to, ServerMessage.Mutable message)
boolean	AcknowledgedMessagesSessionExtension.sendMeta(ServerSession sender, ServerSession to, ServerMessage.Mutable message)
boolean	ActivityExtension.SessionExtension.sendMeta(ServerSession sender, ServerSession session, ServerMessage.Mutable message)
boolean	TimestampExtension.sendMeta(ServerSession to, ServerMessage.Mutable message)
boolean	TimesyncExtension.sendMeta(ServerSession session, ServerMessage.Mutable message)

Constructors in org.cometd.server.ext with parameters of type ServerSession

Modifier	Constructor	Description
	AcknowledgedMessagesSessionExtension(ServerSession session)

Uses of ServerSession in org.cometd.server.filter

Methods in org.cometd.server.filter with parameters of type ServerSession

Modifier and Type	Method	Description
Object	DataFilter.filter(ServerSession session, ServerChannel channel, Object data)	Modifies the given message data.
Object	JSONDataFilter.filter(ServerSession session, ServerChannel channel, Object data)
protected Object	JSONDataFilter.filterArray(ServerSession session, ServerChannel channel, Object array)
protected Object	JSONDataFilter.filterBoolean(ServerSession session, ServerChannel channel, Boolean bool)
protected Object	JSONDataFilter.filterCollection(ServerSession session, ServerChannel channel, Collection<Object> collection)
protected Object	JSONDataFilter.filterList(ServerSession session, ServerChannel channel, List<Object> list)
protected Object	JSONDataFilter.filterMap(ServerSession session, ServerChannel channel, Map<String,Object> map)
protected Object	JSONDataFilter.filterNumber(ServerSession session, ServerChannel channel, Number number)
protected Object	JSONDataFilter.filterObject(ServerSession session, ServerChannel channel, Object data)
protected Object	JSONDataFilter.filterString(ServerSession session, ServerChannel channel, String string)
protected Object	NoMarkupFilter.filterString(ServerSession session, ServerChannel channel, String string)
protected Object	NoScriptsFilter.filterString(ServerSession session, ServerChannel channel, String string)
protected Object	RegexFilter.filterString(ServerSession session, ServerChannel channel, String string)
boolean	DataFilterMessageListener.onMessage(ServerSession from, ServerChannel channel, ServerMessage.Mutable message)

Uses of ServerSession in org.cometd.server.websocket.common

Methods in org.cometd.server.websocket.common with parameters of type ServerSession

Modifier and Type	Method	Description
protected abstract void	AbstractWebSocketEndPoint.send(ServerSession session, String data, Promise<Void> promise)

Uses of ServerSession in org.cometd.server.websocket.jetty

Methods in org.cometd.server.websocket.jetty with parameters of type ServerSession

Modifier and Type	Method	Description
protected void	JettyWebSocketEndPoint.send(ServerSession session, String data, Promise<Void> promise)