Uses of Interface
org.cometd.bayeux.Message.Mutable
Package
Description
-
Uses of Message.Mutable in org.cometd.bayeux.client
Modifier and TypeMethodDescriptiondefault 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 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
-
Uses of Message.Mutable in org.cometd.client
Modifier and TypeMethodDescriptionprotected 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) Modifier and TypeMethodDescriptionprotected void
BayeuxClient.sendMessages
(List<Message.Mutable> messages, Promise<Boolean> promise) -
Uses of Message.Mutable in org.cometd.client.ext
Modifier and TypeMethodDescriptionboolean
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
Modifier and TypeMethodDescriptionprotected 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
Modifier and TypeMethodDescriptionvoid
JettyHttpClientTransport.send
(TransportListener listener, List<Message.Mutable> messages) -
Uses of Message.Mutable in org.cometd.client.http.okhttp
Modifier and TypeMethodDescriptionvoid
OkHttpClientTransport.send
(TransportListener listener, List<Message.Mutable> messages) -
Uses of Message.Mutable in org.cometd.client.transport
Modifier and TypeMethodDescriptionprotected List
<Message.Mutable> ClientTransport.parseMessages
(String content) Modifier and TypeMethodDescriptionprotected 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
Modifier and TypeMethodDescriptionprotected 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.jakarta
Modifier and TypeMethodDescriptionprotected AbstractWebSocketTransport.Delegate
WebSocketTransport.connect
(String uri, TransportListener listener, List<Message.Mutable> messages) -
Uses of Message.Mutable in org.cometd.client.websocket.jetty
Modifier and TypeMethodDescriptionprotected AbstractWebSocketTransport.Delegate
JettyWebSocketTransport.connect
(String uri, TransportListener listener, List<Message.Mutable> messages) -
Uses of Message.Mutable in org.cometd.client.websocket.okhttp
Modifier and TypeMethodDescriptionprotected AbstractWebSocketTransport.Delegate
OkHttpWebSocketTransport.connect
(String uri, TransportListener listener, List<Message.Mutable> messages) -
Uses of Message.Mutable in org.cometd.common
Modifier and TypeClassDescriptionclass
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.Modifier and TypeInterfaceDescriptionstatic interface
Client specificJSONContext
that binds toMessage.Mutable
.Modifier and TypeMethodDescriptionprotected Message.Mutable
AbstractClientSession.newMessage()
protected Message.Mutable
JettyJSONContextClient.newMessage()
Modifier and TypeMethodDescriptionprotected 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, 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) ModifierConstructorDescriptionBufferingJSONAsyncParser
(JSONContext<? extends Message.Mutable> jsonContext) -
Uses of Message.Mutable in org.cometd.server
Modifier and TypeMethodDescriptionvoid
LocalSessionImpl.receive
(Message.Mutable message, Promise<Void> promise) protected void
LocalSessionImpl.send
(Message.Mutable message)