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

Packages that use ServerMessage

Package	Description
org.cometd.bayeux.server
org.cometd.benchmark.server
org.cometd.examples
org.cometd.oort
org.cometd.server
org.cometd.server.authorizer
org.cometd.server.ext
org.cometd.server.transport
org.cometd.websocket.server
org.cometd.websocket.server.common

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 session, ServerMessage message)	Blocking version of ServerSession.Extension.outgoing(ServerSession, ServerMessage.Mutable, Promise) for non-meta messages.

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

Modifier and Type	Method	Description
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.
default ServerMessage	ServerSession.Extension.send(ServerSession session, ServerMessage message)	Blocking version of ServerSession.Extension.outgoing(ServerSession, ServerMessage.Mutable, Promise) for non-meta messages.
void	BayeuxServer.SessionListener.sessionAdded(ServerSession session, ServerMessage message)	Callback invoked when a ServerSession has been added to a BayeuxServer object.
void	BayeuxServer.SubscriptionListener.subscribed(ServerSession session, ServerChannel channel, ServerMessage message)	Callback invoked when a ServerSession subscribes to a ServerChannel.
void	ServerChannel.SubscriptionListener.subscribed(ServerSession session, ServerChannel channel, ServerMessage message)	Callback invoked when the given ServerSession subscribes to the given ServerChannel.
void	BayeuxServer.SubscriptionListener.unsubscribed(ServerSession session, ServerChannel channel, ServerMessage message)	Callback invoked when a ServerSession unsubscribes from a ServerChannel.
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.MaxQueueListener.queueMaxed(ServerSession session, Queue<ServerMessage> queue, ServerSession sender, Message 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.benchmark.server

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

Modifier and Type	Method	Description
void	CometDLoadServer.StatisticsService.exit(ServerSession remote, ServerMessage message)
void	CometDLoadServer.StatisticsService.startStatistics(ServerSession remote, ServerMessage message)
void	CometDLoadServer.StatisticsService.stopStatistics(ServerSession remote, ServerMessage message)

Uses of ServerMessage in org.cometd.examples

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

Modifier and Type	Method	Description
void	ChatService.handleMembership(ServerSession client, ServerMessage message)
void	CometDDemoServlet.Monitor.monitorMeta(ServerSession session, ServerMessage message)
void	CometDDemoServlet.Monitor.monitorSubscribe(ServerSession session, ServerMessage message)
void	CometDDemoServlet.Monitor.monitorUnsubscribe(ServerSession session, ServerMessage message)
void	ChatService.privateChat(ServerSession client, ServerMessage message)

Uses of ServerMessage in org.cometd.oort

Methods in org.cometd.oort that return ServerMessage

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

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

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)
protected 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	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 session, ServerMessage message)
ServerMessage	ActivityExtension.SessionExtension.send(ServerSession session, ServerMessage message)
ServerMessage	BinarySessionExtension.send(ServerSession session, ServerMessage message)

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 session, ServerMessage message)
ServerMessage	ActivityExtension.SessionExtension.send(ServerSession session, ServerMessage message)
ServerMessage	BinarySessionExtension.send(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)

Uses of ServerMessage in org.cometd.server.transport

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

Modifier and Type	Method	Description
protected byte[]	AbstractHttpTransport.toJSONBytes(ServerMessage msg)
protected void	AbstractStreamHttpTransport.writeMessage(javax.servlet.http.HttpServletResponse response, javax.servlet.ServletOutputStream output, ServerSessionImpl session, ServerMessage message)

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

Modifier and Type	Method	Description
protected abstract void	AbstractHttpTransport.write(AbstractHttpTransport.Context context, List<ServerMessage> messages, Promise<Void> promise)
protected void	AbstractStreamHttpTransport.write(AbstractHttpTransport.Context context, List<ServerMessage> messages, Promise<Void> promise)
protected void	AsyncJSONTransport.write(AbstractHttpTransport.Context context, List<ServerMessage> messages, Promise<Void> promise)
protected void	AbstractStreamHttpTransport.writeComplete(AbstractHttpTransport.Context context, List<ServerMessage> messages)
protected void	AsyncJSONTransport.writeComplete(AbstractHttpTransport.Context context, List<ServerMessage> messages)

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

Constructor	Description
Writer(AbstractHttpTransport.Context context, List<ServerMessage> messages, Promise<Void> promise)

Uses of ServerMessage in org.cometd.websocket.server

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

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

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

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

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

Method parameters in org.cometd.websocket.server.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)