Uses of Interface
org.apache.qpid.protonj2.engine.IncomingDelivery
Package
Description
-
Uses of IncomingDelivery in org.apache.qpid.protonj2.client.impl
Modifier and TypeMethodDescriptionprotected void
ClientReceiverLinkType.handleDeliveryAborted
(IncomingDelivery delivery) protected void
ClientReceiver.handleDeliveryRead
(IncomingDelivery delivery) protected abstract void
ClientReceiverLinkType.handleDeliveryRead
(IncomingDelivery delivery) protected void
ClientStreamReceiver.handleDeliveryRead
(IncomingDelivery delivery) protected void
ClientReceiverLinkType.handleDeliveryStateRemotelyUpdated
(IncomingDelivery delivery) -
Uses of IncomingDelivery in org.apache.qpid.protonj2.engine
Modifier and TypeMethodDescriptionIncomingDelivery.claimAvailableBytes()
Marks all available bytes as being claimed by the caller meaning that available byte count value can be returned to the session which can expand the session incoming window to allow more bytes to be sent from the remote peer.IncomingDelivery.deliveryAbortedHandler
(EventHandler<IncomingDelivery> handler) Handler for aborted deliveries that is called if this delivery is aborted by theSender
.IncomingDelivery.deliveryReadHandler
(EventHandler<IncomingDelivery> handler) IncomingDelivery.deliveryStateUpdatedHandler
(EventHandler<IncomingDelivery> handler) Handler for updates to the remote state of incoming deliveries that have previously been received.IncomingDelivery.disposition
(DeliveryState state) updates the state of the deliveryIncomingDelivery.disposition
(DeliveryState state, boolean settle) Update the delivery with the given disposition if not locally settled and optionally settles the delivery if not already settled.IncomingDelivery.readBytes
(byte[] array, int offset, int length) Reads bytes from this delivery and writes them into the destination array starting at the given offset and continuing for the specified length reducing the available bytes by the value of the number of bytes written to the target.IncomingDelivery.readBytes
(ProtonBuffer buffer) Reads bytes from this delivery and writes them into the destination ProtonBuffer reducing the available bytes by the value of the number of bytes written to the target.IncomingDelivery.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.IncomingDelivery.setLinkedResource
(Object resource) Links a given resource to thisIncomingDelivery
.IncomingDelivery.settle()
Settles this delivery locally, transmitting aDisposition
frame to the remote if the remote has not already settled the delivery.Modifier and TypeMethodDescriptionReceiver.unsettled()
Retrieves the list of unsettled deliveries for thisReceiver
link which have yet to be settled on this end of the link.Modifier and TypeMethodDescriptionIncomingDelivery.deliveryAbortedHandler
(EventHandler<IncomingDelivery> handler) Handler for aborted deliveries that is called if this delivery is aborted by theSender
.Receiver.deliveryAbortedHandler
(EventHandler<IncomingDelivery> handler) Handler for aborted deliveries that is called for each aborted in-progress delivery.IncomingDelivery.deliveryReadHandler
(EventHandler<IncomingDelivery> handler) Receiver.deliveryReadHandler
(EventHandler<IncomingDelivery> handler) Session.deliveryReadHandler
(EventHandler<IncomingDelivery> delivery) Allows monitoring of incoming deliveries to receivers attached to thisSession
.IncomingDelivery.deliveryStateUpdatedHandler
(EventHandler<IncomingDelivery> handler) Handler for updates to the remote state of incoming deliveries that have previously been received.Receiver.deliveryStateUpdatedHandler
(EventHandler<IncomingDelivery> handler) Handler for updates to the remote state of incoming deliveries that have previously been received.Receiver.disposition
(Predicate<IncomingDelivery> filter, DeliveryState state, boolean settle) For each unsettled outgoing delivery that is pending in theReceiver
apply the given predicate and if it matches then apply the given delivery state and settled value to it.Receiver.settle
(Predicate<IncomingDelivery> filter) For each unsettled outgoing delivery that is pending in theReceiver
apply the given predicate and if it matches then settle the delivery. -
Uses of IncomingDelivery in org.apache.qpid.protonj2.engine.impl
Modifier and TypeClassDescriptionclass
Proton Incoming Delivery implementationModifier and TypeMethodDescriptionProtonIncomingDelivery.claimAvailableBytes()
ProtonIncomingDelivery.disposition
(DeliveryState state) ProtonIncomingDelivery.disposition
(DeliveryState state, boolean settle) ProtonIncomingDelivery.settle()
Modifier and TypeMethodDescriptionProtonIncomingDelivery.deliveryAbortedHandler
(EventHandler<IncomingDelivery> handler) ProtonReceiver.deliveryAbortedHandler
(EventHandler<IncomingDelivery> handler) ProtonIncomingDelivery.deliveryReadHandler
(EventHandler<IncomingDelivery> handler) ProtonReceiver.deliveryReadHandler
(EventHandler<IncomingDelivery> handler) ProtonSession.deliveryReadHandler
(EventHandler<IncomingDelivery> deliveryReadHandler) ProtonIncomingDelivery.deliveryStateUpdatedHandler
(EventHandler<IncomingDelivery> handler) ProtonReceiver.deliveryStateUpdatedHandler
(EventHandler<IncomingDelivery> handler) ProtonReceiver.disposition
(Predicate<IncomingDelivery> filter, DeliveryState disposition, boolean settle) ProtonReceiver.settle
(Predicate<IncomingDelivery> filter)