Class StreamMessageHandler

  • All Implemented Interfaces:

    
    public class StreamMessageHandler
    
                        

    Data handler for streaming message operations.

    Manages fetching and delivering incremental stream message content. Deduplicates in-flight requests and exposes data via KEY_FETCH_STREAM_MESSAGE.

    Since:

    5.16.0

    • Nested Class Summary

      Nested Classes 
      Modifier and Type Class Description
      public interface StreamMessageHandler.State

      Business-state constants for stream message errors.

    • Enum Constant Summary

      Enum Constants 
      Enum Constant Description
    • Method Summary

      Modifier and Type Method Description
      void fetchStreamMessage(String msgUId, boolean isRetry) Fetches streaming message content for the given message UID.
      void stop()
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    • Constructor Detail

      • StreamMessageHandler

        StreamMessageHandler()
    • Method Detail

      • fetchStreamMessage

         void fetchStreamMessage(String msgUId, boolean isRetry)

        Fetches streaming message content for the given message UID.

        Deduplicates concurrent requests for the same message. If the message has already been fetched and isRetry is false, the request is skipped.

        Parameters:
        msgUId - the unique message ID of the stream message
        isRetry - true to force a re-fetch even if the message was already pulled