Uses of Interface
org.cometd.bayeux.server.ServerMessage
-
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 aServerMessage
Methods in org.cometd.bayeux.server that return ServerMessage Modifier and Type Method Description ServerMessage
ServerSession.Extension.Adapter. send(ServerSession session, ServerMessage message)
ServerMessage
ServerSession.Extension. send(ServerSession session, ServerMessage message)
Callback method invoked every time a normal message is outgoing.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)
Callback invoked to authorize the givenoperation
on the givenchannel
.boolean
SecurityPolicy. canCreate(BayeuxServer server, ServerSession session, String channelId, ServerMessage message)
Checks if a message should be allowed to create a new channel.boolean
SecurityPolicy. canHandshake(BayeuxServer server, ServerSession session, ServerMessage message)
Checks if a handshake message should be accepted.boolean
SecurityPolicy. canPublish(BayeuxServer server, ServerSession session, ServerChannel channel, ServerMessage message)
Checks if a client can publish a message to a channel.boolean
SecurityPolicy. canSubscribe(BayeuxServer server, ServerSession session, ServerChannel channel, ServerMessage message)
Checks if a subscribe message from a client is allowed to subscribe to a channel.boolean
ServerSession.MessageListener. onMessage(ServerSession session, ServerSession sender, ServerMessage message)
Callback invoked when a message is sent.void
ServerSession.QueueListener. queued(ServerSession sender, ServerMessage message)
Callback invoked when a message is queued in the session queue.ServerMessage
ServerSession.Extension.Adapter. send(ServerSession session, ServerMessage message)
ServerMessage
ServerSession.Extension. send(ServerSession session, ServerMessage message)
Callback method invoked every time a normal message is outgoing.void
BayeuxServer.SessionListener. sessionAdded(ServerSession session, ServerMessage message)
Callback invoked when aServerSession
has been added to aBayeuxServer
object.void
BayeuxServer.SubscriptionListener. subscribed(ServerSession session, ServerChannel channel, ServerMessage message)
Callback invoked when aServerSession
subscribes to aServerChannel
.void
ServerChannel.SubscriptionListener. subscribed(ServerSession session, ServerChannel channel, ServerMessage message)
Callback invoked when the givenServerSession
subscribes to the givenServerChannel
.void
BayeuxServer.SubscriptionListener. unsubscribed(ServerSession session, ServerChannel channel, ServerMessage message)
Callback invoked when aServerSession
unsubscribes from aServerChannel
.void
ServerChannel.SubscriptionListener. unsubscribed(ServerSession session, ServerChannel channel, ServerMessage message)
Callback invoked when the givenServerSession
unsubscribes from the givenServerChannel
.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.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()
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 tocopy)
protected boolean
ServerChannelImpl. subscribe(ServerSessionImpl session, ServerMessage message)
protected byte[]
AbstractServerTransport. toJSONBytes(ServerMessage message, String encoding)
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 newServerSession.Extension
that monitors the activity of the givenServerSession
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)
-
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 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(javax.servlet.http.HttpServletRequest request, javax.servlet.http.HttpServletResponse response, ServerSessionImpl session, boolean scheduleExpiration, List<ServerMessage> messages, ServerMessage.Mutable[] replies)
protected void
AbstractStreamHttpTransport. write(javax.servlet.http.HttpServletRequest request, javax.servlet.http.HttpServletResponse response, ServerSessionImpl session, boolean scheduleExpiration, List<ServerMessage> messages, ServerMessage.Mutable[] replies)
protected void
AsyncJSONTransport. write(javax.servlet.http.HttpServletRequest request, javax.servlet.http.HttpServletResponse response, ServerSessionImpl session, boolean scheduleExpiration, List<ServerMessage> messages, ServerMessage.Mutable[] replies)
protected void
AbstractStreamHttpTransport. writeComplete(javax.servlet.http.HttpServletRequest request, javax.servlet.http.HttpServletResponse response, ServerSessionImpl session, List<ServerMessage> messages, ServerMessage.Mutable[] replies)
protected void
AsyncJSONTransport. writeComplete(javax.servlet.http.HttpServletRequest request, javax.servlet.http.HttpServletResponse response, ServerSessionImpl session, List<ServerMessage> messages, ServerMessage.Mutable[] replies)
Constructor parameters in org.cometd.server.transport with type arguments of type ServerMessage Constructor Description Writer(javax.servlet.http.HttpServletRequest request, javax.servlet.http.HttpServletResponse response, javax.servlet.AsyncContext asyncContext, ServerSessionImpl session, boolean scheduleExpiration, List<ServerMessage> messages, ServerMessage.Mutable[] replies)
-
Uses of ServerMessage in org.cometd.websocket.server.common
Method parameters in org.cometd.websocket.server.common with type arguments of type ServerMessage Modifier and Type Method Description protected void
AbstractWebSocketTransport.AbstractWebSocketScheduler. send(S wsSession, List<? extends ServerMessage> messages, int batchSize, org.eclipse.jetty.util.Callback callback)