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

Packages that use ServerMessage

Package	Description
org.cometd.bayeux.server
org.cometd.oort
org.cometd.server
org.cometd.server.authorizer
org.cometd.server.ext
org.cometd.server.http
org.cometd.server.websocket.common
org.cometd.server.websocket.jakarta
org.cometd.server.websocket.jetty

Uses of ServerMessage in org.cometd.bayeux.server

Subinterfaces of ServerMessage in org.cometd.bayeux.server

Modifier and Type	Interface	Description
static interface	ServerMessage.Mutable	The mutable version of a ServerMessage

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

Modifier and Type	Method	Description
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.

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

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.
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.
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".
void	ServerSession.RemovedListener.removed(ServerSession session, ServerMessage message, boolean timeout)	Callback invoked when the session is removed.
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 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.
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.
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.

Method parameters in org.cometd.bayeux.server with type arguments of type ServerMessage

Modifier and Type	Method	Description
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.
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".

Uses of ServerMessage in org.cometd.oort

Methods in org.cometd.oort that return ServerMessage

Modifier and Type	Method	Description
ServerMessage	OortService.ServerContext.getServerMessage()

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

Modifier and Type	Method	Description
void	Seti.LocalLocation.removed(ServerSession session, ServerMessage message, boolean timeout)

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

Modifier	Constructor	Description
	ServerContext(ServerSession session, ServerMessage message)

Uses of ServerMessage in org.cometd.server

Classes in org.cometd.server that implement ServerMessage

Modifier and Type	Class	Description
class	ServerMessageImpl

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

Modifier and Type	Method	Description
Queue<ServerMessage>	ServerSessionImpl.getQueue()
List<ServerMessage>	ServerSessionImpl.takeQueue(List<ServerMessage.Mutable> replies)

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

Modifier and Type	Method	Description
protected void	ServerSessionImpl.addMessage(ServerMessage message)
void	BayeuxServerImpl.addServerSession(ServerSessionImpl session, ServerMessage message)
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	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.
ServerMessage.Mutable	BayeuxServerImpl.newMessage(ServerMessage original)
void	ServerSessionImpl.notifyResumed(ServerMessage message, boolean timeout)
void	ServerSessionImpl.notifySuspended(ServerMessage message, long timeout)
protected boolean	ServerSessionImpl.removed(ServerMessage message, boolean timeout)
protected boolean	ServerChannelImpl.subscribe(ServerSessionImpl session, ServerMessage message)
protected String	AbstractServerTransport.toJSON(ServerMessage msg)
protected boolean	ServerChannelImpl.unsubscribe(ServerSessionImpl session, ServerMessage message)

Uses of ServerMessage in org.cometd.server.authorizer

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

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

Uses of ServerMessage in org.cometd.server.ext

Methods in org.cometd.server.ext that return ServerMessage

Modifier and Type	Method	Description
ServerMessage	AcknowledgedMessagesSessionExtension.send(ServerSession sender, ServerSession session, ServerMessage message)
ServerMessage	ActivityExtension.SessionExtension.send(ServerSession sender, ServerSession session, ServerMessage message)
ServerMessage	BinarySessionExtension.send(ServerSession sender, ServerSession session, ServerMessage message)

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

Modifier and Type	Method	Description
BatchArrayQueue<ServerMessage>	AcknowledgedMessagesSessionExtension.getBatchArrayQueue()

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

Modifier and Type	Method	Description
protected ServerSession.Extension	ActivityExtension.newSessionExtension(ServerSession session, ServerMessage handshake)	Creates a new ServerSession.Extension that monitors the activity of the given ServerSession
void	AcknowledgedMessagesSessionExtension.queued(ServerSession sender, ServerMessage message)
ServerMessage	AcknowledgedMessagesSessionExtension.send(ServerSession sender, ServerSession session, ServerMessage message)
ServerMessage	ActivityExtension.SessionExtension.send(ServerSession sender, ServerSession session, ServerMessage message)
ServerMessage	BinarySessionExtension.send(ServerSession sender, ServerSession session, ServerMessage message)

Method parameters in org.cometd.server.ext with type arguments of type ServerMessage

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

Uses of ServerMessage in org.cometd.server.http

Methods in org.cometd.server.http with parameters of type ServerMessage

Modifier and Type	Method	Description
protected byte[]	AbstractHttpTransport.toJSONBytes(ServerMessage msg)
protected void	AbstractHttpTransport.writeMessage(CometDResponse.Output output, ServerMessage message, Promise<Void> promise)

Method parameters in org.cometd.server.http with type arguments of type ServerMessage

Modifier and Type	Method	Description
protected void	AbstractHttpTransport.write(TransportContext context, List<ServerMessage> messages)
protected void	AbstractHttpTransport.writeComplete(TransportContext context, List<ServerMessage> messages)

Constructor parameters in org.cometd.server.http with type arguments of type ServerMessage

Modifier	Constructor	Description
protected	Writer(TransportContext context, List<ServerMessage> messages)

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

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

Modifier and Type	Method	Description
protected String	AbstractWebSocketTransport.toJSON(ServerMessage message)

Method parameters in org.cometd.server.websocket.common with type arguments of type ServerMessage

Modifier and Type	Method	Description
protected void	AbstractWebSocketEndPoint.writeComplete(AbstractWebSocketEndPoint.Context context, List<ServerMessage> messages)
protected void	AbstractWebSocketTransport.writeComplete(AbstractWebSocketEndPoint.Context context, List<ServerMessage> messages)

Uses of ServerMessage in org.cometd.server.websocket.jakarta

Method parameters in org.cometd.server.websocket.jakarta with type arguments of type ServerMessage

Modifier and Type	Method	Description
protected void	WebSocketEndPoint.writeComplete(AbstractWebSocketEndPoint.Context context, List<ServerMessage> messages)
protected void	WebSocketTransport.EndPoint.writeComplete(AbstractWebSocketEndPoint.Context context, List<ServerMessage> messages)

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

Method parameters in org.cometd.server.websocket.jetty with type arguments of type ServerMessage

Modifier and Type	Method	Description
protected void	JettyWebSocketTransport.EndPoint.writeComplete(AbstractWebSocketEndPoint.Context context, List<ServerMessage> messages)