io.vertx.proton.impl

Class ProtonDeliveryImpl

java.lang.Object

io.vertx.proton.impl.ProtonDeliveryImpl

All Implemented Interfaces:

ProtonDelivery

public class ProtonDeliveryImpl
extends Object
implements ProtonDelivery

Author:

Hiram Chirino

Method Summary

Modifier and Type	Method and Description
org.apache.qpid.proton.engine.Record	attachments() Retrieves the attachments record, upon which application items can be set/retrieved.
void	clear()
ProtonDelivery	disposition(org.apache.qpid.proton.amqp.transport.DeliveryState state, boolean settle) Updates the DeliveryState, and optionally settle the delivery as well.
org.apache.qpid.proton.amqp.transport.DeliveryState	getDefaultDeliveryState()
io.vertx.proton.impl.ProtonLinkImpl	getLink()
io.vertx.proton.impl.ProtonLinkImpl	getLinkImpl()
org.apache.qpid.proton.amqp.transport.DeliveryState	getLocalState() Gets the current local state for the delivery.
int	getMessageFormat() Gets the message format for the current delivery.
org.apache.qpid.proton.amqp.transport.DeliveryState	getRemoteState() Gets the current remote state for the delivery.
byte[]	getTag() Gets the delivery tag for this delivery
ProtonDelivery	handler(Handler<ProtonDelivery> handler)
boolean	isBuffered()
boolean	isPartial()
boolean	isReadable()
boolean	isSettled() Gets whether the delivery was locally settled yet.
boolean	isUpdated()
boolean	isWritable()
int	pending()
boolean	remotelySettled() Gets whether the delivery was settled by the remote peer yet.
void	setDefaultDeliveryState(org.apache.qpid.proton.amqp.transport.DeliveryState state)
ProtonDelivery	settle() Settles the delivery locally.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

getLink

public io.vertx.proton.impl.ProtonLinkImpl getLink()

clear

public void clear()

getLocalState

public org.apache.qpid.proton.amqp.transport.DeliveryState getLocalState()

Description copied from interface: ProtonDelivery

Gets the current local state for the delivery.

Specified by:

getLocalState in interface ProtonDelivery

Returns:

the delivery state

isSettled

public boolean isSettled()

Description copied from interface: ProtonDelivery

Gets whether the delivery was locally settled yet.

Specified by:

isSettled in interface ProtonDelivery

Returns:

whether the delivery is locally settled

remotelySettled

public boolean remotelySettled()

Description copied from interface: ProtonDelivery

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

Specified by:

remotelySettled in interface ProtonDelivery

Returns:

whether the delivery is remotely settled

attachments

public org.apache.qpid.proton.engine.Record attachments()

Description copied from interface: ProtonDelivery

Retrieves the attachments record, upon which application items can be set/retrieved.

Specified by:

attachments in interface ProtonDelivery

Returns:

the attachments

getTag

public byte[] getTag()

Description copied from interface: ProtonDelivery

Gets the delivery tag for this delivery

Specified by:

getTag in interface ProtonDelivery

Returns:

the tag

setDefaultDeliveryState

public void setDefaultDeliveryState(org.apache.qpid.proton.amqp.transport.DeliveryState state)

getDefaultDeliveryState

public org.apache.qpid.proton.amqp.transport.DeliveryState getDefaultDeliveryState()

isReadable

public boolean isReadable()

isUpdated

public boolean isUpdated()

isWritable

public boolean isWritable()

pending

public int pending()

isPartial

public boolean isPartial()

getRemoteState

public org.apache.qpid.proton.amqp.transport.DeliveryState getRemoteState()

Description copied from interface: ProtonDelivery

Gets the current remote state for the delivery.

Specified by:

getRemoteState in interface ProtonDelivery

Returns:

the remote delivery state

getMessageFormat

public int getMessageFormat()

Description copied from interface: ProtonDelivery

Gets the message format for the current delivery.

Specified by:

getMessageFormat in interface ProtonDelivery

Returns:

the message format

isBuffered

public boolean isBuffered()

disposition

public ProtonDelivery disposition(org.apache.qpid.proton.amqp.transport.DeliveryState state,
                                  boolean settle)

Description copied from interface: ProtonDelivery

Updates the DeliveryState, and optionally settle the delivery as well. Has no effect if the delivery was previously locally settled.

Specified by:

disposition in interface ProtonDelivery

Parameters:

state - the delivery state to apply

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

Returns:

itself

settle

public ProtonDelivery settle()

Description copied from interface: ProtonDelivery

Settles the delivery locally.

Specified by:

settle in interface ProtonDelivery

Returns:

the delivery

handler

public ProtonDelivery handler(Handler<ProtonDelivery> handler)

getLinkImpl

public io.vertx.proton.impl.ProtonLinkImpl getLinkImpl()