Interface AcknowledgedMessagesExtension.Listener

Enclosing class:
AcknowledgedMessagesExtension

public static interface AcknowledgedMessagesExtension.Listener

A listener for acknowledgement events.

Implementation will be notified of these events:

Stateful implementations may use Session.setAttribute(String, Object) to store per-session data, or a Map<ServerSession, ?>

  • Method Details Link icon

    • onBatchSend Link icon

      default void onBatchSend(ServerSession session, List<ServerMessage> messages, long batch)

      Callback method invoked when a batch of messages is about to be sent to a client session.

      Parameters:
      session - the session
      messages - the messages to send, as an immutable list
      batch - the batch number
    • onBatchReceive Link icon

      default void onBatchReceive(ServerSession session, long batch)

      Callback method invoked when a client session confirms it has received the given batch of messages.

      Parameters:
      session - the session
      batch - the batch number
    • onBatchQueueMaxed Link icon

      default void onBatchQueueMaxed(ServerSession session, Queue<ServerMessage> queue)

      Callback method invoked when the unacknowledged message queue size exceeds the value returned by AcknowledgedMessagesExtension.getMaxQueueSize().

      Parameters:
      session - the session
      queue - the unacknowledged message queue