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

Subclasses with type arguments of type ServerMessage.Mutable in org.cometd.server

Modifier and Type	Class	Description
class	JacksonJSONContextServer
class	JettyJSONContextServer

Subinterfaces with type arguments of type ServerMessage.Mutable in org.cometd.server

Modifier and Type	Interface	Description
interface	JSONContextServer	Server specific JSONContext that binds to ServerMessage.Mutable.

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()
default ServerMessage.Mutable	AbstractServerTransport.Scheduler.getMessage()
ServerMessage.Mutable	BayeuxServerImpl.newMessage()
ServerMessage.Mutable	BayeuxServerImpl.newMessage(ServerMessage original)
protected ServerMessage.Mutable	JettyJSONContextServer.newMessage()
protected ServerMessage.Mutable	LocalSessionImpl.newMessage()

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

Modifier and Type	Method	Description
List<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(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.freeze(ServerMessage.Mutable mutable)
String	JacksonJSONContextServer.generate(ServerMessage.Mutable message)
String	JettyJSONContextServer.generate(ServerMessage.Mutable message)
default String	JSONContextServer.generate(ServerMessage.Mutable message)
void	BayeuxServerImpl.handle(ServerSessionImpl session, ServerMessage.Mutable message, Promise<ServerMessage.Mutable> promise)
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(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	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 sender, ServerSession to, ServerMessage.Mutable message)
boolean	ActivityExtension.SessionExtension.sendMeta(ServerSession sender, 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.http

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

Modifier and Type	Method	Description
ServerMessage.Mutable	AbstractHttpScheduler.getMessage()

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

Modifier and Type	Method	Description
List<ServerMessage.Mutable>	TransportContext.messages()
List<ServerMessage.Mutable>	TransportContext.replies()

Methods in org.cometd.server.http 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(TransportContext context, ServerMessage.Mutable message, Promise<ServerMessage.Mutable> promise)
protected AbstractHttpTransport.HttpScheduler	AbstractHttpTransport.newHttpScheduler(TransportContext context, Promise<Void> promise, ServerMessage.Mutable reply, long timeout)
protected void	AbstractHttpTransport.resume(TransportContext context, ServerMessage.Mutable message, Promise<Void> promise)
protected AbstractHttpTransport.HttpScheduler	AbstractHttpTransport.suspend(TransportContext 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	Description
protected void	AbstractHttpTransport.handleMessage(TransportContext context, ServerMessage.Mutable message, Promise<ServerMessage.Mutable> promise)
void	TransportContext.messages(List<ServerMessage.Mutable> messages)
protected void	AbstractHttpTransport.processMessages(TransportContext context, List<ServerMessage.Mutable> messages)

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

Modifier	Constructor	Description
protected	AbstractHttpScheduler(AbstractHttpTransport transport, TransportContext context, Promise<Void> promise, ServerMessage.Mutable message, long timeout)