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 voidClientSession.Extension. incoming(ClientSession session, Message.Mutable message, Promise<java.lang.Boolean> promise)Callback method invoked every time a message is incoming.default voidClientSession.Extension. outgoing(ClientSession session, Message.Mutable message, Promise<java.lang.Boolean> promise)Callback method invoked every time a message is outgoing.voidClientSessionChannel. publish(Message.Mutable message, ClientSession.MessageListener callback)Publishes the givenmessageonto this channel, notifying the givencallbackof the publish result.default booleanClientSession.Extension. rcv(ClientSession session, Message.Mutable message)Callback method invoked every time a normal message is received.default booleanClientSession.Extension. rcvMeta(ClientSession session, Message.Mutable message)Callback method invoked every time a meta message is received.default booleanClientSession.Extension. send(ClientSession session, Message.Mutable message)Callback method invoked every time a normal message is being sent.default booleanClientSession.Extension. sendMeta(ClientSession session, Message.Mutable message)Callback method invoked every time a meta message is being sent.booleanClientSessionChannel. subscribe(Message.Mutable message, ClientSessionChannel.MessageListener listener, ClientSession.MessageListener callback)Subscribes the givenlistenerto receive messages sent to this channel.booleanClientSessionChannel. unsubscribe(Message.Mutable message, ClientSessionChannel.MessageListener listener, ClientSession.MessageListener callback)Unsubscribes the givenlistenerfrom 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 interfaceServerMessage.MutableThe 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 voidBayeuxClient. enqueueSend(Message.Mutable message)protected voidBayeuxClient.BayeuxClientChannel. nonFirstSubscribe(Message.Mutable message, ClientSessionChannel.MessageListener listener, ClientSession.MessageListener callback)protected voidBayeuxClient.BayeuxClientChannel. nonLastUnSubscribe(Message.Mutable message, ClientSessionChannel.MessageListener listener, ClientSession.MessageListener callback)protected voidBayeuxClient. processConnect(Message.Mutable connect)protected voidBayeuxClient. processDisconnect(Message.Mutable disconnect)protected voidBayeuxClient. processHandshake(Message.Mutable handshake)protected voidBayeuxClient. processMessage(Message.Mutable message)protected voidBayeuxClient. send(Message.Mutable message)Method parameters in org.cometd.client with type arguments of type Message.Mutable Modifier and Type Method Description protected voidBayeuxClient. 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 booleanBinaryExtension. rcv(ClientSession session, Message.Mutable message)booleanAckExtension. rcvMeta(ClientSession session, Message.Mutable message)booleanTimesyncClientExtension. rcvMeta(ClientSession session, Message.Mutable message)booleanBinaryExtension. send(ClientSession session, Message.Mutable message)booleanTimestampClientExtension. send(ClientSession session, Message.Mutable message)booleanAckExtension. sendMeta(ClientSession session, Message.Mutable message)booleanTimestampClientExtension. sendMeta(ClientSession session, Message.Mutable message)booleanTimesyncClientExtension. 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 longAbstractHttpClientTransport. calculateMaxNetworkDelay(java.util.List<Message.Mutable> messages)protected java.lang.StringAbstractHttpClientTransport. newRequestURI(java.util.List<Message.Mutable> messages)protected voidAbstractHttpClientTransport. processResponseContent(TransportListener listener, java.util.List<Message.Mutable> requestMessages, java.lang.String content)protected voidAbstractHttpClientTransport. processResponseMessages(TransportListener listener, java.util.List<Message.Mutable> messages)protected voidAbstractHttpClientTransport. 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 voidJettyHttpClientTransport. 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 voidOkHttpClientTransport. 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.StringClientTransport. generateJSON(java.util.List<Message.Mutable> messages)default voidTransportListener. onMessages(java.util.List<Message.Mutable> messages)Callback method invoked when a batch of message is received.abstract voidClientTransport. 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.DelegateAbstractWebSocketTransport. connect(java.lang.String uri, TransportListener listener, java.util.List<Message.Mutable> messages)protected voidAbstractWebSocketTransport.Delegate. onMessages(java.util.List<Message.Mutable> messages)protected voidAbstractWebSocketTransport.Delegate. registerMessages(TransportListener listener, java.util.List<Message.Mutable> messages)voidAbstractWebSocketTransport. 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.DelegateWebSocketTransport. 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.DelegateJettyWebSocketTransport. 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.DelegateOkHttpWebSocketTransport. 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 classJacksonJSONContext<M extends Message.Mutable,I extends M>classJettyJSONContext<M extends Message.Mutable>interfaceJSONContext<T extends Message.Mutable>Abstraction for JSON parsing and generation.Classes in org.cometd.common that implement Message.Mutable Modifier and Type Class Description classHashMapMessageMethods in org.cometd.common that return Message.Mutable Modifier and Type Method Description protected Message.MutableAbstractClientSession. newMessage()protected Message.MutableJettyJSONContextClient. 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 voidAbstractClientSession. extendIncoming(Message.Mutable message, Promise<java.lang.Boolean> promise)protected voidAbstractClientSession. extendOutgoing(Message.Mutable message, Promise<java.lang.Boolean> promise)protected voidAbstractClientSession.AbstractSessionChannel. nonFirstSubscribe(Message.Mutable message, ClientSessionChannel.MessageListener listener, ClientSession.MessageListener callback)protected voidAbstractClientSession.AbstractSessionChannel. nonLastUnSubscribe(Message.Mutable message, ClientSessionChannel.MessageListener listener, ClientSession.MessageListener callback)protected voidAbstractClientSession. notifyCallback(ClientSession.MessageListener callback, Message.Mutable message)protected voidAbstractClientSession. notifyListeners(Message.Mutable message)voidAbstractClientSession.AbstractSessionChannel. publish(Message.Mutable message, ClientSession.MessageListener callback)voidAbstractClientSession. receive(Message.Mutable message, Promise<java.lang.Void> promise)Receives a message (from the server) and process it.protected abstract voidAbstractClientSession. send(Message.Mutable message)protected voidAbstractClientSession.AbstractSessionChannel. sendSubscribe(Message.Mutable message, ClientSessionChannel.MessageListener listener, ClientSession.MessageListener callback)protected voidAbstractClientSession.AbstractSessionChannel. sendUnSubscribe(Message.Mutable message, ClientSession.MessageListener callback)Deprecated.protected voidAbstractClientSession.AbstractSessionChannel. sendUnSubscribe(Message.Mutable message, ClientSessionChannel.MessageListener listener, ClientSession.MessageListener callback)booleanAbstractClientSession.AbstractSessionChannel. subscribe(Message.Mutable message, ClientSessionChannel.MessageListener listener, ClientSession.MessageListener callback)booleanAbstractClientSession.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 classServerMessageImplMethods in org.cometd.server with parameters of type Message.Mutable Modifier and Type Method Description voidLocalSessionImpl. receive(Message.Mutable message, Promise<java.lang.Void> promise)protected voidLocalSessionImpl. send(Message.Mutable message)
-