Package org.apache.qpid.protonj2.client

Interface StreamDelivery

All Known Implementing Classes:

ClientStreamDelivery

public interface StreamDelivery

A specialized StreamDelivery type that is returned from the StreamReceiver which can be used to read incoming large messages that are streamed via multiple incoming AMQP Transfer frames.

Method Summary

Modifier and Type	Method	Description
boolean	aborted()	Check if the StreamDelivery has been marked as aborted by the remote sender.
StreamDelivery	accept()	Accepts and settles the delivery.
Map<String,Object>	annotations()	Decodes the StreamDelivery payload and returns a Map containing a copy of any associated DeliveryAnnotations that were transmitted with the Message payload of this StreamDelivery.
boolean	completed()	Check if the StreamDelivery has been marked as complete by the remote sender.
StreamDelivery	disposition(DeliveryState state, boolean settle)	Updates the DeliveryState, and optionally settle the delivery as well.
StreamReceiverMessage	message()	Decode the StreamDelivery payload and return an Message object.
int	messageFormat()	Gets the message format for the current delivery.
StreamDelivery	modified(boolean deliveryFailed, boolean undeliverableHere)	Modifies and settles the delivery.
InputStream	rawInputStream()	Create and return an InputStream that reads the raw payload bytes of the given StreamDelivery.
StreamReceiver	receiver()
StreamDelivery	reject(String condition, String description)	Rejects and settles the delivery, sending supplied error information along with the rejection.
StreamDelivery	release()	Releases and settles the delivery.
boolean	remoteSettled()	Gets whether the delivery was settled by the remote peer yet.
DeliveryState	remoteState()	Gets the current remote state for the delivery.
StreamDelivery	settle()	Settles the delivery locally.
boolean	settled()
DeliveryState	state()	Gets the current local state for the delivery.

Method Detail

receiver

StreamReceiver receiver()

Returns:

the StreamReceiver that originated this StreamDelivery.

message

StreamReceiverMessage message()
                       throws ClientException

Decode the StreamDelivery payload and return an Message object.

If the incoming message carried any delivery annotations they can be accessed via the annotations() method. Re-sending the returned message will not also send the incoming delivery annotations, the sender must include them in the Sender.send(Message, Map) call if they are to be forwarded onto the next recipient.

Calling this message claims the payload of the delivery for the returned Message and excludes use of the rawInputStream() method of the StreamDelivery object. Calling the rawInputStream() method after calling this method throws ClientIllegalStateException.

Returns:

a Message instance that wraps the decoded payload.

Throws:

ClientException - if an error occurs while decoding the payload.

rawInputStream

InputStream rawInputStream()
                    throws ClientException

Create and return an InputStream that reads the raw payload bytes of the given StreamDelivery.

Calling this method claims the payload of the delivery for the returned InputStream and excludes use of the message() and annotations() methods of the StreamDelivery object. Closing the returned input stream discards any unread bytes from the delivery payload. Calling the message() or annotations() methods after calling this method throws ClientIllegalStateException.

Returns:

an InputStream instance that can be used to read the raw delivery payload.

Throws:

ClientException - if an error occurs while decoding the payload.

aborted

boolean aborted()

Check if the StreamDelivery has been marked as aborted by the remote sender.

Returns:

true if this context has been marked as aborted previously.

completed

boolean completed()

Check if the StreamDelivery has been marked as complete by the remote sender.

Returns:

true if this context has been marked as being the complete.

annotations

Map<String,Object> annotations()
                              throws ClientException

Decodes the StreamDelivery payload and returns a Map containing a copy of any associated DeliveryAnnotations that were transmitted with the Message payload of this StreamDelivery.

Calling this message claims the payload of the delivery for the returned Map and the decoded Message that can be accessed via the message() method and excludes use of the rawInputStream() method of the StreamDelivery object. Calling the rawInputStream() method after calling this method throws ClientIllegalStateException.

Returns:

copy of the delivery annotations that were transmitted with the Message payload.

Throws:

ClientException - if an error occurs while decoding the payload.

accept

StreamDelivery accept()
               throws ClientException

Accepts and settles the delivery.

Returns:

this StreamDelivery instance.

Throws:

ClientException - if an error occurs while sending the disposition

release

StreamDelivery release()
                throws ClientException

Releases and settles the delivery.

Returns:

this StreamDelivery instance.

Throws:

ClientException - if an error occurs while sending the disposition

reject

StreamDelivery reject(String condition,
                      String description)
               throws ClientException

Rejects and settles the delivery, sending supplied error information along with the rejection.

Parameters:

condition - The error condition value to supply with the rejection.

description - The error description value to supply with the rejection.

Returns:

this StreamDelivery instance.

Throws:

ClientException - if an error occurs while sending the disposition

modified

StreamDelivery modified(boolean deliveryFailed,
                        boolean undeliverableHere)
                 throws ClientException

Modifies and settles the delivery.

Parameters:

deliveryFailed - Indicates if the modified delivery failed.

undeliverableHere - Indicates if the modified delivery should not be returned here again.

Returns:

this StreamDelivery instance.

Throws:

ClientException - if an error occurs while sending the disposition

disposition

StreamDelivery disposition(DeliveryState state,
                           boolean settle)
                    throws ClientException

Updates the DeliveryState, and optionally settle the delivery as well.

Parameters:

state - the delivery state to apply

settle - whether to settle() the delivery at the same time

Returns:

this StreamDelivery instance.

Throws:

ClientException - if an error occurs while sending the disposition

settle

StreamDelivery settle()
               throws ClientException

Settles the delivery locally.

Returns:

the delivery

Throws:

ClientException - if an error occurs while sending the disposition

settled

boolean settled()
         throws ClientException

Returns:

true if the delivery has been locally settled.

Throws:

ClientException - if an error occurs while reading the settled state

state

DeliveryState state()
             throws ClientException

Gets the current local state for the delivery.

Returns:

the delivery state

Throws:

ClientException - if an error occurs while reading the delivery state

remoteState

DeliveryState remoteState()
                   throws ClientException

Gets the current remote state for the delivery.

Returns:

the remote delivery state

Throws:

ClientException - if an error occurs while reading the remote delivery state

remoteSettled

boolean remoteSettled()
               throws ClientException

Gets whether the delivery was settled by the remote peer yet.

Returns:

whether the delivery is remotely settled

Throws:

ClientException - if an error occurs while reading the remote settlement state

messageFormat

int messageFormat()
           throws ClientException

Gets the message format for the current delivery.

Returns:

the message format

Throws:

ClientException - if an error occurs while reading the delivery message format