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<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 givenmessage
onto this channel, notifying the givencallback
of the publish result.default void
ClientSessionChannel. publish(Message.Mutable message, ClientSessionChannel.MessageListener callback)
Deprecated.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. 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)
Callback method invoke when the given messages have just arrived from the Bayeux server.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.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)
void
TransportListener.Empty. onMessages(List<Message.Mutable> messages)
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)
void
LongPollingTransport. send(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<T extends Message.Mutable,I extends T>
class
JettyJSONContext<T extends Message.Mutable>
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 T[]
JettyJSONContext. newRootArray(int size)
protected Message.Mutable[]
JettyJSONContextClient. newRootArray(int size)
T[]
JacksonJSONContext. parse(InputStream stream)
T[]
JacksonJSONContext. parse(Reader reader)
T[]
JacksonJSONContext. parse(String json)
T[]
JettyJSONContext. parse(InputStream stream)
T[]
JettyJSONContext. parse(Reader reader)
T[]
JettyJSONContext. parse(String json)
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. 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)
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)
-
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)
-
Uses of Message.Mutable in org.cometd.websocket.client
Method parameters in org.cometd.websocket.client 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)
protected AbstractWebSocketTransport.Delegate
WebSocketTransport. connect(String uri, TransportListener listener, List<Message.Mutable> messages)
-
Uses of Message.Mutable in org.cometd.websocket.client.common
Method parameters in org.cometd.websocket.client.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.websocket.client.okhttp
Method parameters in org.cometd.websocket.client.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)
-