Uses of Interface
org.cometd.bayeux.Message.Mutable
-
-
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<java.lang.Boolean> promise)
Callback method invoked every time a message is incoming.default void
ClientSession.Extension. outgoing(ClientSession session, Message.Mutable message, Promise<java.lang.Boolean> promise)
Callback method invoked every time a message is outgoing.void
ClientSessionChannel. publish(Message.Mutable message, ClientSession.MessageListener callback)
Publishes the givenmessage
onto this channel, notifying the givencallback
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 givenlistener
to receive messages sent to this channel.boolean
ClientSessionChannel. unsubscribe(Message.Mutable message, ClientSessionChannel.MessageListener listener, ClientSession.MessageListener callback)
Unsubscribes the givenlistener
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 aServerMessage
-
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 protected void
BayeuxClient. sendMessages(java.util.List<Message.Mutable> messages, Promise<java.lang.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(java.util.List<Message.Mutable> messages)
protected java.lang.String
AbstractHttpClientTransport. newRequestURI(java.util.List<Message.Mutable> messages)
protected void
AbstractHttpClientTransport. processResponseContent(TransportListener listener, java.util.List<Message.Mutable> requestMessages, java.lang.String content)
protected void
AbstractHttpClientTransport. processResponseMessages(TransportListener listener, java.util.List<Message.Mutable> messages)
protected void
AbstractHttpClientTransport. processWrongResponseCode(TransportListener listener, java.util.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, java.util.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, java.util.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 java.util.List<Message.Mutable>
ClientTransport. parseMessages(java.lang.String content)
Method parameters in org.cometd.client.transport with type arguments of type Message.Mutable Modifier and Type Method Description protected java.lang.String
ClientTransport. generateJSON(java.util.List<Message.Mutable> messages)
default void
TransportListener. onMessages(java.util.List<Message.Mutable> messages)
Callback method invoked when a batch of message is received.abstract void
ClientTransport. send(TransportListener listener, java.util.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(java.lang.String uri, TransportListener listener, java.util.List<Message.Mutable> messages)
protected void
AbstractWebSocketTransport.Delegate. onMessages(java.util.List<Message.Mutable> messages)
protected void
AbstractWebSocketTransport.Delegate. registerMessages(TransportListener listener, java.util.List<Message.Mutable> messages)
void
AbstractWebSocketTransport. send(TransportListener listener, java.util.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(java.lang.String uri, TransportListener listener, java.util.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(java.lang.String uri, TransportListener listener, java.util.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(java.lang.String uri, TransportListener listener, java.util.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(java.io.Reader reader)
M[]
JacksonJSONContext. parse(java.lang.String json)
M[]
JettyJSONContext. parse(java.io.Reader reader)
M[]
JettyJSONContext. parse(java.lang.String json)
T[]
JSONContext. parse(java.io.Reader reader)
Parses an array of messages from the given reader.T[]
JSONContext. parse(java.lang.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<java.lang.Boolean> promise)
protected void
AbstractClientSession. extendOutgoing(Message.Mutable message, Promise<java.lang.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<java.lang.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 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<java.lang.Void> promise)
protected void
LocalSessionImpl. send(Message.Mutable message)
-