Interface StreamSender

  • All Superinterfaces:
    java.lang.AutoCloseable, Sender
    All Known Implementing Classes:
    ClientStreamSender

    public interface StreamSender
    extends Sender
    Sending link implementation that allows sending of large message payload data in multiple transfers to reduce memory overhead of large message sends.
    • Method Detail

      • beginMessage

        StreamSenderMessage beginMessage​(java.util.Map<java.lang.String,​java.lang.Object> deliveryAnnotations)
                                  throws ClientException
        Creates and returns a new StreamSenderMessage that can be used by the caller to perform streaming sends of large message payload data.
        Parameters:
        deliveryAnnotations - the delivery annotations that should be included in the sent StreamSenderMessage.
        Returns:
        a new StreamSenderMessage that can be used to stream message data to the remote.
        Throws:
        ClientException - if an error occurs while initiating a new streaming send message.