Package org.apache.qpid.protonj2.client
Interface StreamReceiverMessage
-
- All Superinterfaces:
AdvancedMessage<java.io.InputStream>,Message<java.io.InputStream>
- All Known Implementing Classes:
ClientStreamReceiverMessage
public interface StreamReceiverMessage extends AdvancedMessage<java.io.InputStream>
A specializedMessagetype that represents a streamed delivery possibly spanning many incomingTransferframes from the remote peer. It is possible for various calls in thisStreamReceiverMessageto block while awaiting the receipt of sufficient bytes to provide the result.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description booleanaborted()Check if theStreamDeliverythat was assigned to thisStreamReceiverMessagehas been marked as aborted by the remote.booleancompleted()Check if theStreamDeliverythat was assigned to thisStreamReceiverMessagehas been marked as complete by the remote.StreamDeliverydelivery()StreamReceiverreceiver()-
Methods inherited from interface org.apache.qpid.protonj2.client.AdvancedMessage
addBodySection, annotations, annotations, applicationProperties, applicationProperties, bodySections, bodySections, clearBodySections, encode, footer, footer, forEachBodySection, header, header, messageFormat, messageFormat, properties, properties
-
Methods inherited from interface org.apache.qpid.protonj2.client.Message
absoluteExpiryTime, absoluteExpiryTime, annotation, annotation, body, body, contentEncoding, contentEncoding, contentType, contentType, correlationId, correlationId, creationTime, creationTime, deliveryCount, deliveryCount, durable, durable, firstAcquirer, firstAcquirer, footer, footer, forEachAnnotation, forEachFooter, forEachProperty, groupId, groupId, groupSequence, groupSequence, hasAnnotation, hasAnnotations, hasFooter, hasFooters, hasProperties, hasProperty, messageId, messageId, priority, priority, property, property, removeAnnotation, removeFooter, removeProperty, replyTo, replyTo, replyToGroupId, replyToGroupId, subject, subject, timeToLive, timeToLive, to, to, toAdvancedMessage, userId, userId
-
-
-
-
Method Detail
-
delivery
StreamDelivery delivery()
- Returns:
- the
StreamDeliverythat is associated with the life-cycle of thisStreamReceiverMessage
-
receiver
StreamReceiver receiver()
- Returns:
- the
StreamReceiverthat this context was create under.
-
aborted
boolean aborted()
Check if theStreamDeliverythat was assigned to thisStreamReceiverMessagehas been marked as aborted by the remote.- Returns:
- true if this context has been marked as aborted previously.
-
completed
boolean completed()
Check if theStreamDeliverythat was assigned to thisStreamReceiverMessagehas been marked as complete by the remote.- Returns:
- true if this context has been marked as being the complete.
-
-