Package | Description |
---|---|
org.cometd.bayeux | |
org.cometd.bayeux.client | |
org.cometd.bayeux.server | |
org.cometd.client | |
org.cometd.client.transport | |
org.cometd.common | |
org.cometd.oort | |
org.cometd.server |
Modifier and Type | Interface and Description |
---|---|
static interface |
Message.Mutable
The mutable version of a
Message |
Modifier and Type | Method and Description |
---|---|
void |
ClientSessionChannel.MessageListener.onMessage(ClientSessionChannel channel,
Message message)
Callback invoked when a message is received on the given
channel . |
void |
ClientSession.MessageListener.onMessage(Message message)
Callback invoked when a remote call response is received.
|
Modifier and Type | Interface and Description |
---|---|
interface |
ServerMessage
Representation of a server side message.
|
static interface |
ServerMessage.Mutable
The mutable version of a
ServerMessage |
Modifier and Type | Method and Description |
---|---|
boolean |
ServerSession.MaxQueueListener.queueMaxed(ServerSession session,
Queue<ServerMessage> queue,
ServerSession sender,
Message message)
Deprecated.
Callback invoked to notify when the message queue is exceeding the value
configured for the transport with the option "maxQueue".
|
Modifier and Type | Method and Description |
---|---|
protected void |
BayeuxClient.onTransportFailure(Message message,
ClientTransport.FailureInfo failureInfo,
ClientTransport.FailureHandler handler) |
Modifier and Type | Method and Description |
---|---|
protected void |
BayeuxClient.messagesFailure(Throwable cause,
List<? extends Message> messages) |
void |
BayeuxClient.onFailure(Throwable failure,
List<? extends Message> messages)
Deprecated.
|
void |
BayeuxClient.onSending(List<? extends Message> messages)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
default void |
TransportListener.onFailure(Throwable failure,
List<? extends Message> messages)
Callback method invoked when a failure to send or receive messages occurs.
|
default void |
TransportListener.onSending(List<? extends Message> messages)
Callback method invoked when the batch of messages is being sent.
|
default void |
TransportListener.onTimeout(List<? extends Message> messages,
Promise<Long> promise)
Callback method invoked when the send of a batch of messages expires
before receiving a response from the server, controlled by the
maxNetworkDelay option. |
Modifier and Type | Class and Description |
---|---|
class |
HashMapMessage |
Modifier and Type | Method and Description |
---|---|
protected void |
AbstractClientSession.AbstractSessionChannel.notifyMessageListeners(Message message) |
protected void |
AbstractClientSession.AbstractSessionChannel.notifyOnMessage(ClientSessionChannel.MessageListener listener,
Message message) |
Constructor and Description |
---|
HashMapMessage(Message message) |
Modifier and Type | Method and Description |
---|---|
boolean |
Oort.isOortHandshake(Message handshake) |
protected void |
Oort.joinComets(Message message) |
protected void |
Seti.receiveBroadcast(Message message)
Receives messages broadcast by other Setis in the cloud.
|
protected void |
Seti.receiveDirect(Message message)
Receives messages directly from other Setis in the cloud, containing
messages to be delivered to sessions connected to this comet.
|
Modifier and Type | Class and Description |
---|---|
class |
ServerMessageImpl |
Copyright © 2008–2024 The CometD Project. All rights reserved.