org.cometd.client.transport

Interface TransportListener

All Superinterfaces:

EventListener

All Known Implementing Classes:

TransportListener.Empty

public interface TransportListener
extends EventListener

Abstracts the communication between BayeuxClient and ClientTransport.

A TransportListener is associated to every batch of messages being sent, and notified when responses for those messages come back, or a failure occurs.

See Also:

MessageClientTransport

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static class	TransportListener.Empty Deprecated. use TransportListener directly instead.

Method Summary

Modifier and Type	Method and Description
default void	onFailure(Throwable failure, List<? extends Message> messages) Callback method invoked when a failure to send or receive messages occurs.
default void	onMessages(List<Message.Mutable> messages) Callback method invoked when a batch of message is received.
default void	onSending(List<? extends Message> messages) Callback method invoked when the batch of messages is being sent.
default void	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.

Method Detail

onSending

default void onSending(List<? extends Message> messages)

Callback method invoked when the batch of messages is being sent.

Parameters:

messages - the batch of messages being sent

onMessages

default void onMessages(List<Message.Mutable> messages)

Callback method invoked when a batch of message is received.

Parameters:

messages - the batch of messages received

onFailure

default void onFailure(Throwable failure,
                       List<? extends Message> messages)

Callback method invoked when a failure to send or receive messages occurs.

Parameters:

failure - the failure occurred

messages - the batch of messages being sent

onTimeout

default void 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.

Implementations may extend the wait by succeeding the promise with the number of milliseconds of the extended wait.

Succeeding the callback with 0 or a negative value confirms the expiration, which will eventually call onFailure(Throwable, List) with a TimeoutException.

Parameters:

messages - the batch of messages sent

promise - the promise to complete