Uses of Interface
org.cometd.bayeux.Message.Mutable

Packages that use Message.Mutable

Package	Description
org.cometd.bayeux.client
org.cometd.bayeux.server
org.cometd.client
org.cometd.client.ext
org.cometd.client.http.common
org.cometd.client.http.jetty
org.cometd.client.http.okhttp
org.cometd.client.transport
org.cometd.client.websocket.common
org.cometd.client.websocket.javax
org.cometd.client.websocket.jetty
org.cometd.client.websocket.okhttp
org.cometd.common
org.cometd.server

Uses of Message.Mutable in org.cometd.bayeux.client

Methods in org.cometd.bayeux.client with parameters of type Message.Mutable

Modifier and Type	Method	Description
default void	ClientSession.Extension.incoming(ClientSession session, Message.Mutable message, Promise<Boolean> promise)	Callback method invoked every time a message is incoming.
default void	ClientSession.Extension.outgoing(ClientSession session, Message.Mutable message, Promise<Boolean> promise)	Callback method invoked every time a message is outgoing.
void	ClientSessionChannel.publish(Message.Mutable message, ClientSession.MessageListener callback)	Publishes the given message onto this channel, notifying the given callback of the publish result.
default boolean	ClientSession.Extension.rcv(ClientSession session, Message.Mutable message)	Callback method invoked every time a normal message is received.
default boolean	ClientSession.Extension.rcvMeta(ClientSession session, Message.Mutable message)	Callback method invoked every time a meta message is received.
default boolean	ClientSession.Extension.send(ClientSession session, Message.Mutable message)	Callback method invoked every time a normal message is being sent.
default boolean	ClientSession.Extension.sendMeta(ClientSession session, Message.Mutable message)	Callback method invoked every time a meta message is being sent.
boolean	ClientSessionChannel.subscribe(Message.Mutable message, ClientSessionChannel.MessageListener listener, ClientSession.MessageListener callback)	Subscribes the given listener to receive messages sent to this channel.
boolean	ClientSessionChannel.unsubscribe(Message.Mutable message, ClientSessionChannel.MessageListener listener, ClientSession.MessageListener callback)	Unsubscribes the given listener from receiving messages sent to this channel.

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

Subinterfaces of Message.Mutable in org.cometd.bayeux.server

Modifier and Type	Interface	Description
static interface	ServerMessage.Mutable	The mutable version of a ServerMessage

Uses of Message.Mutable in org.cometd.client

Methods in org.cometd.client with parameters of type Message.Mutable

Modifier and Type	Method	Description
protected void	BayeuxClient.enqueueSend(Message.Mutable message)
protected void	BayeuxClient.BayeuxClientChannel.nonFirstSubscribe(Message.Mutable message, ClientSessionChannel.MessageListener listener, ClientSession.MessageListener callback)
protected void	BayeuxClient.BayeuxClientChannel.nonLastUnSubscribe(Message.Mutable message, ClientSessionChannel.MessageListener listener, ClientSession.MessageListener callback)
protected void	BayeuxClient.processConnect(Message.Mutable connect)
protected void	BayeuxClient.processDisconnect(Message.Mutable disconnect)
protected void	BayeuxClient.processHandshake(Message.Mutable handshake)
protected void	BayeuxClient.processMessage(Message.Mutable message)
protected void	BayeuxClient.send(Message.Mutable message)

Method parameters in org.cometd.client with type arguments of type Message.Mutable

Modifier and Type	Method	Description
void	BayeuxClient.onMessages(List<Message.Mutable> messages)	Deprecated. use BayeuxClient.addTransportListener(TransportListener) instead
protected void	BayeuxClient.sendMessages(List<Message.Mutable> messages, Promise<Boolean> promise)

Uses of Message.Mutable in org.cometd.client.ext

Methods in org.cometd.client.ext with parameters of type Message.Mutable

Modifier and Type	Method	Description
boolean	BinaryExtension.rcv(ClientSession session, Message.Mutable message)
boolean	AckExtension.rcvMeta(ClientSession session, Message.Mutable message)
boolean	TimesyncClientExtension.rcvMeta(ClientSession session, Message.Mutable message)
boolean	BinaryExtension.send(ClientSession session, Message.Mutable message)
boolean	TimestampClientExtension.send(ClientSession session, Message.Mutable message)
boolean	AckExtension.sendMeta(ClientSession session, Message.Mutable message)
boolean	TimestampClientExtension.sendMeta(ClientSession session, Message.Mutable message)
boolean	TimesyncClientExtension.sendMeta(ClientSession session, Message.Mutable message)

Uses of Message.Mutable in org.cometd.client.http.common

Method parameters in org.cometd.client.http.common with type arguments of type Message.Mutable

Modifier and Type	Method	Description
protected long	AbstractHttpClientTransport.calculateMaxNetworkDelay(List<Message.Mutable> messages)
protected String	AbstractHttpClientTransport.newRequestURI(List<Message.Mutable> messages)
protected void	AbstractHttpClientTransport.processResponseContent(TransportListener listener, List<Message.Mutable> requestMessages, String content)
protected void	AbstractHttpClientTransport.processResponseMessages(TransportListener listener, List<Message.Mutable> messages)
protected void	AbstractHttpClientTransport.processWrongResponseCode(TransportListener listener, List<Message.Mutable> messages, int code)

Uses of Message.Mutable in org.cometd.client.http.jetty

Method parameters in org.cometd.client.http.jetty with type arguments of type Message.Mutable

Modifier and Type	Method	Description
void	JettyHttpClientTransport.send(TransportListener listener, List<Message.Mutable> messages)

Uses of Message.Mutable in org.cometd.client.http.okhttp

Method parameters in org.cometd.client.http.okhttp with type arguments of type Message.Mutable

Modifier and Type	Method	Description
void	OkHttpClientTransport.send(TransportListener listener, List<Message.Mutable> messages)

Uses of Message.Mutable in org.cometd.client.transport

Methods in org.cometd.client.transport that return types with arguments of type Message.Mutable

Modifier and Type	Method	Description
protected List<Message.Mutable>	ClientTransport.parseMessages(String content)

Method parameters in org.cometd.client.transport with type arguments of type Message.Mutable

Modifier and Type	Method	Description
protected String	ClientTransport.generateJSON(List<Message.Mutable> messages)
default void	TransportListener.onMessages(List<Message.Mutable> messages)	Callback method invoked when a batch of message is received.
abstract void	ClientTransport.send(TransportListener listener, List<Message.Mutable> messages)

Uses of Message.Mutable in org.cometd.client.websocket.common

Method parameters in org.cometd.client.websocket.common with type arguments of type Message.Mutable

Modifier and Type	Method	Description
protected abstract AbstractWebSocketTransport.Delegate	AbstractWebSocketTransport.connect(String uri, TransportListener listener, List<Message.Mutable> messages)
protected void	AbstractWebSocketTransport.Delegate.onMessages(List<Message.Mutable> messages)
protected void	AbstractWebSocketTransport.Delegate.registerMessages(TransportListener listener, List<Message.Mutable> messages)
void	AbstractWebSocketTransport.send(TransportListener listener, List<Message.Mutable> messages)

Uses of Message.Mutable in org.cometd.client.websocket.javax

Method parameters in org.cometd.client.websocket.javax with type arguments of type Message.Mutable

Modifier and Type	Method	Description
protected AbstractWebSocketTransport.Delegate	WebSocketTransport.connect(String uri, TransportListener listener, List<Message.Mutable> messages)

Uses of Message.Mutable in org.cometd.client.websocket.jetty

Method parameters in org.cometd.client.websocket.jetty with type arguments of type Message.Mutable

Modifier and Type	Method	Description
protected AbstractWebSocketTransport.Delegate	JettyWebSocketTransport.connect(String uri, TransportListener listener, List<Message.Mutable> messages)

Uses of Message.Mutable in org.cometd.client.websocket.okhttp

Method parameters in org.cometd.client.websocket.okhttp with type arguments of type Message.Mutable

Modifier and Type	Method	Description
protected AbstractWebSocketTransport.Delegate	OkHttpWebSocketTransport.connect(String uri, TransportListener listener, List<Message.Mutable> messages)

Uses of Message.Mutable in org.cometd.common

Classes in org.cometd.common with type parameters of type Message.Mutable

Modifier and Type	Class	Description
class	JacksonJSONContext<M extends Message.Mutable,I extends M>
class	JettyJSONContext<M extends Message.Mutable>
interface	JSONContext<T extends Message.Mutable>	Abstraction for JSON parsing and generation.

Classes in org.cometd.common that implement Message.Mutable

Modifier and Type	Class	Description
class	HashMapMessage

Methods in org.cometd.common that return Message.Mutable

Modifier and Type	Method	Description
protected Message.Mutable	AbstractClientSession.newMessage()
protected Message.Mutable	JettyJSONContextClient.newRoot()
protected abstract M[]	JettyJSONContext.newRootArray(int size)
protected Message.Mutable[]	JettyJSONContextClient.newRootArray(int size)
M[]	JacksonJSONContext.parse(InputStream stream)
M[]	JacksonJSONContext.parse(Reader reader)
M[]	JacksonJSONContext.parse(String json)
M[]	JettyJSONContext.parse(InputStream stream)
M[]	JettyJSONContext.parse(Reader reader)
M[]	JettyJSONContext.parse(String json)
T[]	JSONContext.parse(InputStream stream)	Deprecated. use JSONContext.parse(Reader) instead
T[]	JSONContext.parse(Reader reader)	Parses an array of messages from the given reader.
T[]	JSONContext.parse(String json)	Parses an array of messages from the given string.

Methods in org.cometd.common with parameters of type Message.Mutable

Modifier and Type	Method	Description
protected void	AbstractClientSession.extendIncoming(Message.Mutable message, Promise<Boolean> promise)
protected void	AbstractClientSession.extendOutgoing(Message.Mutable message, Promise<Boolean> promise)
protected void	AbstractClientSession.AbstractSessionChannel.nonFirstSubscribe(Message.Mutable message, ClientSessionChannel.MessageListener listener, ClientSession.MessageListener callback)
protected void	AbstractClientSession.AbstractSessionChannel.nonLastUnSubscribe(Message.Mutable message, ClientSessionChannel.MessageListener listener, ClientSession.MessageListener callback)
protected void	AbstractClientSession.notifyCallback(ClientSession.MessageListener callback, Message.Mutable message)
protected void	AbstractClientSession.notifyListeners(Message.Mutable message)
void	AbstractClientSession.AbstractSessionChannel.publish(Message.Mutable message, ClientSession.MessageListener callback)
void	AbstractClientSession.receive(Message.Mutable message, Promise<Void> promise)	Receives a message (from the server) and process it.
protected abstract void	AbstractClientSession.send(Message.Mutable message)
protected void	AbstractClientSession.AbstractSessionChannel.sendSubscribe(Message.Mutable message, ClientSessionChannel.MessageListener listener, ClientSession.MessageListener callback)
protected void	AbstractClientSession.AbstractSessionChannel.sendUnSubscribe(Message.Mutable message, ClientSession.MessageListener callback)	Deprecated.
protected void	AbstractClientSession.AbstractSessionChannel.sendUnSubscribe(Message.Mutable message, ClientSessionChannel.MessageListener listener, ClientSession.MessageListener callback)
boolean	AbstractClientSession.AbstractSessionChannel.subscribe(Message.Mutable message, ClientSessionChannel.MessageListener listener, ClientSession.MessageListener callback)
boolean	AbstractClientSession.AbstractSessionChannel.unsubscribe(Message.Mutable message, ClientSessionChannel.MessageListener listener, ClientSession.MessageListener callback)

Constructor parameters in org.cometd.common with type arguments of type Message.Mutable

Modifier	Constructor	Description
	BufferingJSONAsyncParser(JSONContext<? extends Message.Mutable> jsonContext)

Uses of Message.Mutable in org.cometd.server

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

Modifier and Type	Class	Description
class	ServerMessageImpl

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

Modifier and Type	Method	Description
void	LocalSessionImpl.receive(Message.Mutable message, Promise<Void> promise)
protected void	LocalSessionImpl.send(Message.Mutable message)