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

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

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

Modifier and Type	Method	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	Description
default void	ServerSession.deliver(Session sender, ServerMessage.Mutable message)	Deprecated. use ServerSession.deliver(Session, ServerMessage.Mutable, Promise) instead
void	ServerSession.deliver(Session sender, ServerMessage.Mutable message, Promise<Boolean> promise)	Delivers the given message to this session.
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 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 session, ServerMessage.Mutable message, Promise<ServerMessage.Mutable> promise)	Callback method invoked every time a message is outgoing.
default void	ServerChannel.publish(Session from, ServerMessage.Mutable message)	Deprecated. use ServerChannel.publish(Session, ServerMessage.Mutable, Promise) instead
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	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.
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 session, ServerMessage.Mutable message)	Blocking version of ServerSession.Extension.outgoing(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	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 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	Description
boolean	Oort.CloudListener.onMessage(ServerSession from, ServerChannel channel, ServerMessage.Mutable message)
boolean	OortService.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	Description
class	ServerMessageImpl

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

Modifier and Type	Method	Description
protected ServerMessage.Mutable	BayeuxServerImpl.createReply(ServerMessage.Mutable message)
ServerMessage.Mutable	ServerMessageImpl.getAssociated()
ServerMessage.Mutable	BayeuxServerImpl.newMessage()
ServerMessage.Mutable	BayeuxServerImpl.newMessage(ServerMessage original)
protected ServerMessage.Mutable	LocalSessionImpl.newMessage()
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	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	BayeuxServerImpl.extendOutgoing(ServerSession sender, ServerSession session, ServerMessage.Mutable message, Promise<Boolean> promise)
protected void	ServerSessionImpl.extendOutgoing(ServerMessage.Mutable message, Promise<ServerMessage.Mutable> promise)
void	BayeuxServerImpl.extendReply(ServerSessionImpl sender, ServerSessionImpl session, ServerMessage.Mutable reply, Promise<ServerMessage.Mutable> promise)
void	BayeuxServerImpl.freeze(ServerMessage.Mutable mutable)
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	Description
protected void	ServerSessionImpl.extendOutgoing(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	Description
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)
boolean	BinaryExtension.send(ServerSession from, ServerSession to, ServerMessage.Mutable message)
boolean	TimestampExtension.send(ServerSession from, ServerSession to, ServerMessage.Mutable message)
boolean	AcknowledgedMessagesSessionExtension.sendMeta(ServerSession to, ServerMessage.Mutable message)
boolean	ActivityExtension.SessionExtension.sendMeta(ServerSession session, ServerMessage.Mutable message)
boolean	TimestampExtension.sendMeta(ServerSession to, ServerMessage.Mutable message)
boolean	TimesyncExtension.sendMeta(ServerSession session, ServerMessage.Mutable message)

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

Modifier and Type	Method	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	Description
boolean	DataFilterMessageListener.onMessage(ServerSession from, ServerChannel channel, ServerMessage.Mutable message)

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

Fields in org.cometd.server.transport declared as ServerMessage.Mutable

Modifier and Type	Field	Description
protected ServerMessage.Mutable[]	AbstractHttpTransport.Context.messages

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

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

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

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

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

Modifier and Type	Method	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.processMessages(AbstractHttpTransport.Context context, ServerMessage.Mutable[] messages, Promise<Void> promise)
protected void	AbstractHttpTransport.resume(AbstractHttpTransport.Context context, ServerMessage.Mutable message, Promise<Void> promise)
protected abstract AbstractHttpTransport.HttpScheduler	AbstractHttpTransport.suspend(AbstractHttpTransport.Context context, Promise<Void> promise, ServerMessage.Mutable message, long timeout)
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)

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

Modifier and Type	Method	Description
protected void	AbstractHttpTransport.handleMessage(AbstractHttpTransport.Context context, ServerMessage.Mutable message, Promise<ServerMessage.Mutable> promise)

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

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