public class DeliveryImpl extends Object implements Delivery
Modifier and Type | Field and Description |
---|---|
static int |
DEFAULT_MESSAGE_FORMAT |
Modifier and Type | Method and Description |
---|---|
Record |
attachments() |
void |
clear() |
void |
disposition(DeliveryState state)
updates the state of the delivery
|
void |
free()
TODO When does an application call this method? Do we really need this?
|
Object |
getContext() |
DeliveryState |
getDefaultDeliveryState() |
LinkImpl |
getLink() |
DeliveryState |
getLocalState() |
int |
getMessageFormat()
Gets the message-format for this Delivery, representing the 32bit value using an int.
|
DeliveryState |
getRemoteState() |
byte[] |
getTag() |
DeliveryImpl |
getWorkNext() |
boolean |
isBuffered() |
boolean |
isPartial() |
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() |
DeliveryImpl |
next() |
int |
pending() |
boolean |
remotelySettled() |
void |
setContext(Object context) |
void |
setDataOffset(int arrayOffset) |
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.
|
String |
toString() |
public static final int DEFAULT_MESSAGE_FORMAT
public DeliveryState getLocalState()
getLocalState
in interface Delivery
public DeliveryState getRemoteState()
getRemoteState
in interface Delivery
public boolean remotelySettled()
remotelySettled
in interface Delivery
public void setMessageFormat(int messageFormat)
Delivery
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
setMessageFormat
in interface Delivery
messageFormat
- the message formatpublic int getMessageFormat()
Delivery
getMessageFormat
in interface Delivery
Delivery.setMessageFormat(int)
public void disposition(DeliveryState state)
Delivery
disposition
in interface Delivery
state
- the new delivery statepublic void settle()
Delivery
Connection.getWorkHead()
).
If this delivery is its link's current delivery, the link's current delivery pointer is advanced.public DeliveryImpl next()
public void free()
Delivery
public DeliveryImpl getWorkNext()
getWorkNext
in interface Delivery
Connection.getWorkHead()
public boolean isSettled()
Delivery
isSettled
in interface Delivery
Delivery.settle()
public void setDataOffset(int arrayOffset)
public boolean isWritable()
isWritable
in interface Delivery
public boolean isReadable()
Delivery
isReadable
in interface Delivery
Receiver.recv(byte[], int, int)
public boolean isUpdated()
Delivery
public boolean isBuffered()
isBuffered
in interface Delivery
public Object getContext()
getContext
in interface Delivery
public void setContext(Object context)
setContext
in interface Delivery
public Record attachments()
attachments
in interface Extendable
public void setDefaultDeliveryState(DeliveryState state)
Delivery
setDefaultDeliveryState
in interface Delivery
state
- the default delivery statepublic DeliveryState getDefaultDeliveryState()
getDefaultDeliveryState
in interface Delivery
Copyright © 2016 The Apache Software Foundation. All rights reserved.