Package org.apache.qpid.proton.engine
Interface Delivery
-
- All Superinterfaces:
Extendable
- All Known Implementing Classes:
DeliveryImpl
public interface Delivery extends Extendable
A delivery of a message on a particular link. Whilst a message is logically a long-lived object, a delivery is short-lived - it is only intended to be used by the application until it is settled and all its data has been read.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description int
available()
Returns the number of bytes currently available for this delivery, which may not be complete yet, that are still to either be received by the application or sent by the transport.void
clear()
void
disposition(DeliveryState state)
updates the state of the delivery The new state may have no on-the-wire effect, if delivery settlement was already communicated to/from the peer.void
free()
TODO When does an application call this method? Do we really need this?java.lang.Object
getContext()
DeliveryState
getDefaultDeliveryState()
Link
getLink()
DeliveryState
getLocalState()
int
getMessageFormat()
Gets the message-format for this Delivery, representing the 32bit value using an int.DeliveryState
getRemoteState()
byte[]
getTag()
Delivery
getWorkNext()
boolean
isAborted()
Check for whether the delivery was aborted.boolean
isBuffered()
boolean
isPartial()
Check for whether the delivery is still partial.boolean
isReadable()
Returns whether this delivery has data ready to be received.boolean
isSettled()
Returns whether this delivery has been settled.boolean
isUpdated()
Returns whether this delivery's state or settled flag has ever remotely changed.boolean
isWritable()
Delivery
next()
int
pending()
boolean
remotelySettled()
void
setContext(java.lang.Object o)
void
setDefaultDeliveryState(DeliveryState state)
Configures a default DeliveryState to be used if a received delivery is settled/freed without any disposition state having been previously applied.void
setMessageFormat(int messageFormat)
Sets the message-format for this Delivery, representing the 32bit value using an int.void
settle()
Settles this delivery.-
Methods inherited from interface org.apache.qpid.proton.engine.Extendable
attachments
-
-
-
-
Method Detail
-
getTag
byte[] getTag()
-
getLink
Link getLink()
-
getLocalState
DeliveryState getLocalState()
-
getRemoteState
DeliveryState getRemoteState()
-
disposition
void disposition(DeliveryState state)
updates the state of the delivery The new state may have no on-the-wire effect, if delivery settlement was already communicated to/from the peer.- Parameters:
state
- the new delivery state
-
settle
void settle()
Settles this delivery. Causes the delivery to be removed from the connection's work list (seeConnection.getWorkHead()
). If this delivery is its link's current delivery, the link's current delivery pointer is advanced.
-
isSettled
boolean isSettled()
Returns whether this delivery has been settled. TODO proton-j and proton-c return the local and remote statuses respectively. Resolve this ambiguity.- See Also:
settle()
-
remotelySettled
boolean remotelySettled()
-
free
void free()
TODO When does an application call this method? Do we really need this?
-
getWorkNext
Delivery getWorkNext()
- See Also:
Connection.getWorkHead()
-
next
Delivery next()
-
isWritable
boolean isWritable()
-
isReadable
boolean isReadable()
Returns whether this delivery has data ready to be received.- See Also:
Receiver.recv(byte[], int, int)
-
setContext
void setContext(java.lang.Object o)
-
getContext
java.lang.Object getContext()
-
isUpdated
boolean isUpdated()
Returns whether this delivery's state or settled flag has ever remotely changed. TODO what is the main intended use case for calling this method?
-
clear
void clear()
-
isPartial
boolean isPartial()
Check for whether the delivery is still partial. For a receiving Delivery, this means the delivery does not hold a complete message payload as all the content hasn't been received yet. Note that anaborted
delivery will also be considered partial and the full payload won't be received. For a sending Delivery, this means the sender link has not beenadvanced
to complete the delivery yet.- Returns:
- true if the delivery is partial
- See Also:
isAborted()
-
isAborted
boolean isAborted()
Check for whether the delivery was aborted.- Returns:
- true if the delivery was aborted.
-
pending
int pending()
-
isBuffered
boolean isBuffered()
-
setDefaultDeliveryState
void setDefaultDeliveryState(DeliveryState state)
Configures a default DeliveryState to be used if a received delivery is settled/freed without any disposition state having been previously applied.- Parameters:
state
- the default delivery state
-
getDefaultDeliveryState
DeliveryState getDefaultDeliveryState()
-
setMessageFormat
void setMessageFormat(int messageFormat)
Sets the message-format for this Delivery, representing the 32bit value using an int. The default value is 0 as per the message format defined in the core AMQP 1.0 specification.See the following for more details:
http://docs.oasis-open.org/amqp/core/v1.0/os/amqp-core-transport-v1.0-os.html#type-transfer
http://docs.oasis-open.org/amqp/core/v1.0/os/amqp-core-transport-v1.0-os.html#type-message-format
http://docs.oasis-open.org/amqp/core/v1.0/os/amqp-core-messaging-v1.0-os.html#section-message-format
http://docs.oasis-open.org/amqp/core/v1.0/os/amqp-core-messaging-v1.0-os.html#definition-MESSAGE-FORMAT- Parameters:
messageFormat
- the message format
-
getMessageFormat
int getMessageFormat()
Gets the message-format for this Delivery, representing the 32bit value using an int.- Returns:
- the message-format
- See Also:
setMessageFormat(int)
-
available
int available()
Returns the number of bytes currently available for this delivery, which may not be complete yet, that are still to either be received by the application or sent by the transport. Note that this value will change as bytes are received/sent, and is in general not equal to the total length of a delivery, except the point whereisPartial()
returns false and no content has yet been received by the application or sent by the transport.- Returns:
- the number of bytes currently available for the delivery
- See Also:
Receiver.recv(byte[], int, int)
,Receiver.recv(org.apache.qpid.proton.codec.WritableBuffer)
,Sender.send(byte[], int, int)
,Sender.send(org.apache.qpid.proton.codec.ReadableBuffer)
-
-