Module org.apache.qpid.protonj2.client
Package org.apache.qpid.protonj2.client

Interface StreamSenderMessage

All Superinterfaces:
AdvancedMessage<OutputStream>, Message<OutputStream>
public interface StreamSenderMessage extends AdvancedMessage<OutputStream>
Streaming Message Tracker object used to operate on and track the state of a streamed message at the remote. The StreamSenderMessage allows for local settlement and disposition management as well as waiting for remote settlement of a streamed message.

  • Method Details

    • tracker

      StreamTracker tracker()
      Returns:
      The Tracker assigned to monitor the life-cycle of this StreamSenderMessage

    • sender

      StreamSender sender()
      Returns:
      the Sender that was used to send the delivery that is being tracked.

    • messageFormat

      StreamSenderMessage messageFormat(int messageFormat) throws ClientException
      Sets the configured message format value that will be set on the first outgoing AMQP Transfer frame for the delivery that comprises this streamed message. This value can only be updated before write operation is attempted and will throw an ClientIllegalStateException if any attempt to alter the value is made following a write.
      Specified by:
      messageFormat in interface AdvancedMessage<OutputStream>
      Parameters:
      messageFormat - The assigned AMQP message format for this streamed message.
      Returns:
      this StreamSenderMessage instance.
      Throws:
      ClientException - if an error occurs while attempting set the message format.

    • complete

      StreamSenderMessage complete() throws ClientException
      Marks the currently streaming message as being complete.

      Marking a message as complete finalizes the streaming send operation and causes a final Transfer frame to be sent to the remote indicating that the ongoing streaming delivery is done and no more message data will arrive.

      Returns:
      this StreamSenderMessage instance.
      Throws:
      ClientException - if an error occurs while initiating the completion operation.

    • completed

      boolean completed()
      Returns:
      true if this message has been marked as being complete.

    • abort

      StreamSenderMessage abort() throws ClientException
      Marks the currently streaming message as being aborted. Once aborted no further writes regardless of whether any writes have yet been performed or not.
      Returns:
      this StreamSenderMessage instance.
      Throws:
      ClientException - if an error occurs while initiating the abort operation.

    • aborted

      boolean aborted()
      Returns:
      true if this StreamSenderMessage has been marked as aborted previously.

    • body

      OutputStream body(OutputStreamOptions options) throws ClientException
      Creates an OutputStream instance configured with the given options which will write the bytes as the payload of one or more AMQP Data sections based on the provided configuration..

      The returned OutputStream can be used to write the payload of an AMQP Message in chunks when the source is not readily available in memory or as part of a larger streams based component. The Data section based stream allows for control over the AMQP message Section values that are sent but does the encoding itself. For stream of message data where the content source already consists of an AMQP encoded message refer to the rawOutputStream() method.

      Parameters:
      options - The stream options to use to configure the returned OutputStream
      Returns:
      a OutputStream instance configured using the given options.
      Throws:
      ClientException - if an error occurs while creating the OutputStream.
      See Also:

    • rawOutputStream

      OutputStream rawOutputStream() throws ClientException
      Creates an OutputStream instance that writes the bytes given without additional encoding or transformation. Using this stream option disables use of any other Message APIs and the message transfer is completed upon close of this OutputStream.

      The returned OutputStream can be used to write the payload of an AMQP Message in chunks when the source is not readily available in memory or as part of a larger streams based component. The source of the bytes written to the OutputStream should consist of already encoded AMQP Message data. For an OutputStream that performs the encoding of message data refer to the body(OutputStreamOptions) method.

      Returns:
      an OutputStream instance that performs no encoding.
      Throws:
      ClientException - if an error occurs while creating the OutputStream.
      See Also: