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

Packages that use ServerMessage.Mutable

Package	Description
org.cometd.bayeux.server
org.cometd.oort
org.cometd.server
org.cometd.server.ext
org.cometd.server.filter
org.cometd.server.http

Uses of ServerMessage.Mutable in org.cometd.bayeux.server

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

Modifier and Type	Method and Description
ServerMessage.Mutable	ServerMessage.getAssociated()
ServerMessage.Mutable	BayeuxServer.newMessage()

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

Modifier and Type	Method and Description
void	ServerSession.deliver(Session sender, ServerMessage.Mutable message, Promise<Boolean> promise) Delivers the given message to this session.
default void	ServerSession.Extension.incoming(ServerSession session, ServerMessage.Mutable message, Promise<Boolean> promise) Callback method invoked every time a message is incoming.
default void	BayeuxServer.Extension.incoming(ServerSession from, 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 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	ServerChannel.publish(Session from, ServerMessage.Mutable message, Promise<Boolean> promise) Publishes the given message to this channel, delivering the message to all the ServerSessions subscribed to this channel.
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.rcv(ServerSession from, ServerMessage.Mutable message) Blocking version of BayeuxServer.Extension.incoming(ServerSession, ServerMessage.Mutable, Promise) for non-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.
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	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 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.
void	ServerMessage.Mutable.setAssociated(ServerMessage.Mutable message)

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

Modifier and Type	Method and Description
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	ServerSession.Extension.outgoing(ServerSession sender, ServerSession session, ServerMessage.Mutable message, Promise<ServerMessage.Mutable> promise) Callback method invoked every time a message is outgoing.

Uses of ServerMessage.Mutable in org.cometd.oort

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

Modifier and Type	Method and Description
boolean	OortService.onMessage(ServerSession from, ServerChannel channel, ServerMessage.Mutable message)
boolean	Oort.CloudListener.onMessage(ServerSession from, ServerChannel channel, ServerMessage.Mutable message)

Uses of ServerMessage.Mutable in org.cometd.server

Classes in org.cometd.server that implement ServerMessage.Mutable

Modifier and Type	Class and Description
class	ServerMessageImpl

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

Modifier and Type	Method and Description
protected ServerMessage.Mutable	BayeuxServerImpl.createReply(ServerMessage.Mutable message)
ServerMessage.Mutable	ServerMessageImpl.getAssociated()
default ServerMessage.Mutable	AbstractServerTransport.Scheduler.getMessage()
ServerMessage.Mutable	BayeuxServerImpl.newMessage()
protected ServerMessage.Mutable	LocalSessionImpl.newMessage()
ServerMessage.Mutable	BayeuxServerImpl.newMessage(ServerMessage original)
protected ServerMessage.Mutable	JettyJSONContextServer.newRoot()
protected ServerMessage.Mutable[]	JettyJSONContextServer.newRootArray(int size)
protected ServerMessage.Mutable[]	AbstractServerTransport.parseMessages(BufferedReader reader, boolean jsonDebug)
ServerMessage.Mutable[]	AbstractServerTransport.parseMessages(String json)

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

Modifier and Type	Method and Description
protected ServerMessage.Mutable	BayeuxServerImpl.createReply(ServerMessage.Mutable message)
void	ServerSessionImpl.deliver(Session sender, ServerMessage.Mutable message, Promise<Boolean> promise)
protected void	ServerSessionImpl.deliver1(ServerSession sender, ServerMessage.Mutable mutable, Promise<Boolean> promise)
protected void	BayeuxServerImpl.error(ServerMessage.Mutable reply, String error)
protected void	ServerSessionImpl.extendIncoming(ServerMessage.Mutable message, Promise<Boolean> promise)
protected void	ServerSessionImpl.extendOutgoing(ServerSession sender, ServerMessage.Mutable message, Promise<ServerMessage.Mutable> promise)
protected void	BayeuxServerImpl.extendOutgoing(ServerSession sender, ServerSession session, ServerMessage.Mutable message, Promise<Boolean> promise)
void	BayeuxServerImpl.extendReply(ServerSessionImpl sender, ServerSessionImpl session, ServerMessage.Mutable reply, Promise<ServerMessage.Mutable> promise)
void	BayeuxServerImpl.freeze(ServerMessage.Mutable mutable)
String	JettyJSONContextServer.generate(ServerMessage.Mutable message)
String	JacksonJSONContextServer.generate(ServerMessage.Mutable message)
default String	JSONContextServer.generate(ServerMessage.Mutable message)
void	BayeuxServerImpl.handle(ServerSessionImpl session, ServerMessage.Mutable message, Promise<ServerMessage.Mutable> promise)
protected boolean	ServerSessionImpl.handshake(ServerMessage.Mutable message)
void	AbstractServerTransport.processReply(ServerSessionImpl session, ServerMessage.Mutable reply, Promise<ServerMessage.Mutable> promise)
protected void	BayeuxServerImpl.publish(ServerSessionImpl session, ServerChannelImpl channel, ServerMessage.Mutable message, boolean receiving, Promise<Boolean> promise)
void	ServerChannelImpl.publish(Session from, ServerMessage.Mutable mutable, Promise<Boolean> promise)
protected void	LocalSessionImpl.send(ServerSessionImpl session, ServerMessage.Mutable message) Enqueues or sends a message to the server.
void	ServerMessageImpl.setAssociated(ServerMessage.Mutable associated)
protected void	BayeuxServerImpl.unknownSession(ServerMessage.Mutable reply)
protected String	BayeuxServerImpl.validateMessage(ServerMessage.Mutable message)

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

Modifier and Type	Method and Description
protected void	ServerSessionImpl.extendOutgoing(ServerSession sender, ServerMessage.Mutable message, Promise<ServerMessage.Mutable> promise)
void	BayeuxServerImpl.extendReply(ServerSessionImpl sender, ServerSessionImpl session, ServerMessage.Mutable reply, Promise<ServerMessage.Mutable> promise)
void	BayeuxServerImpl.handle(ServerSessionImpl session, ServerMessage.Mutable message, Promise<ServerMessage.Mutable> promise)
void	AbstractServerTransport.processReply(ServerSessionImpl session, ServerMessage.Mutable reply, Promise<ServerMessage.Mutable> promise)
List<ServerMessage>	ServerSessionImpl.takeQueue(List<ServerMessage.Mutable> replies)

Uses of ServerMessage.Mutable in org.cometd.server.ext

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

Modifier and Type	Method and Description
boolean	AcknowledgedMessagesSessionExtension.rcv(ServerSession from, ServerMessage.Mutable message)
boolean	BinaryExtension.rcv(ServerSession from, ServerMessage.Mutable message)
boolean	ActivityExtension.SessionExtension.rcv(ServerSession session, ServerMessage.Mutable message)
boolean	BinarySessionExtension.rcv(ServerSession session, ServerMessage.Mutable message)
boolean	AcknowledgedMessagesSessionExtension.rcvMeta(ServerSession session, ServerMessage.Mutable message)
boolean	TimesyncExtension.rcvMeta(ServerSession from, ServerMessage.Mutable message)
boolean	ActivityExtension.rcvMeta(ServerSession session, ServerMessage.Mutable message)
boolean	ActivityExtension.SessionExtension.rcvMeta(ServerSession session, ServerMessage.Mutable message)
boolean	AcknowledgedMessagesExtension.rcvMeta(ServerSession remote, ServerMessage.Mutable message)
boolean	BinaryExtension.send(ServerSession from, ServerSession to, ServerMessage.Mutable message)
boolean	TimestampExtension.send(ServerSession from, ServerSession to, ServerMessage.Mutable message)
boolean	TimesyncExtension.sendMeta(ServerSession session, ServerMessage.Mutable message)
boolean	TimestampExtension.sendMeta(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)

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

Modifier and Type	Method and Description
void	AcknowledgedMessagesSessionExtension.deQueue(ServerSession session, Queue<ServerMessage> queue, List<ServerMessage.Mutable> replies)

Uses of ServerMessage.Mutable in org.cometd.server.filter

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

Modifier and Type	Method and Description
boolean	DataFilterMessageListener.onMessage(ServerSession from, ServerChannel channel, ServerMessage.Mutable message)

Uses of ServerMessage.Mutable in org.cometd.server.http

Fields in org.cometd.server.http with type parameters of type ServerMessage.Mutable

Modifier and Type	Field and Description
protected List<ServerMessage.Mutable>	AbstractHttpTransport.Context.messages
protected List<ServerMessage.Mutable>	AbstractHttpTransport.Context.replies

Methods in org.cometd.server.http that return ServerMessage.Mutable

Modifier and Type	Method and Description
ServerMessage.Mutable	AbstractHttpTransport.LongPollScheduler.getMessage()
protected ServerMessage.Mutable[]	JSONPTransport.parseMessages(javax.servlet.http.HttpServletRequest request)
protected abstract ServerMessage.Mutable[]	AbstractStreamHttpTransport.parseMessages(javax.servlet.http.HttpServletRequest request)
protected ServerMessage.Mutable[]	JSONTransport.parseMessages(javax.servlet.http.HttpServletRequest request)
protected ServerMessage.Mutable[]	AbstractStreamHttpTransport.parseMessages(String[] requestParameters)

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

Modifier and Type	Method and Description
protected ServerSessionImpl	AbstractHttpTransport.findSession(Collection<ServerSessionImpl> sessions, ServerMessage.Mutable message)
protected void	AbstractHttpTransport.handleMessage(AbstractHttpTransport.Context context, ServerMessage.Mutable message, Promise<ServerMessage.Mutable> promise)
protected AbstractHttpTransport.HttpScheduler	AbstractStreamHttpTransport.newHttpScheduler(AbstractHttpTransport.Context context, Promise<Void> promise, ServerMessage.Mutable message, long timeout)
protected AbstractHttpTransport.HttpScheduler	AsyncJSONTransport.newHttpScheduler(AbstractHttpTransport.Context context, Promise<Void> promise, ServerMessage.Mutable reply, long timeout)
protected void	AbstractHttpTransport.resume(AbstractHttpTransport.Context context, ServerMessage.Mutable message, Promise<Void> promise)
protected AbstractHttpTransport.HttpScheduler	AbstractStreamHttpTransport.suspend(AbstractHttpTransport.Context context, Promise<Void> promise, ServerMessage.Mutable message, long timeout)
protected AbstractHttpTransport.HttpScheduler	AsyncJSONTransport.suspend(AbstractHttpTransport.Context context, Promise<Void> promise, ServerMessage.Mutable message, long timeout)
protected abstract AbstractHttpTransport.HttpScheduler	AbstractHttpTransport.suspend(AbstractHttpTransport.Context context, Promise<Void> promise, ServerMessage.Mutable message, long timeout)

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

Modifier and Type	Method and Description
protected void	AsyncJSONTransport.AbstractReader.finish(List<ServerMessage.Mutable> messages)
protected void	AbstractHttpTransport.handleMessage(AbstractHttpTransport.Context context, ServerMessage.Mutable message, Promise<ServerMessage.Mutable> promise)
protected void	AbstractHttpTransport.processMessages(AbstractHttpTransport.Context context, List<ServerMessage.Mutable> messages, Promise<Void> promise)

Constructors in org.cometd.server.http with parameters of type ServerMessage.Mutable

Constructor and Description
DispatchingLongPollScheduler(AbstractHttpTransport.Context context, Promise<Void> promise, ServerMessage.Mutable message, long timeout)
LongPollScheduler(AbstractHttpTransport.Context context, Promise<Void> promise, ServerMessage.Mutable message, long timeout)