Uses of Interface
org.apache.qpid.protonj2.engine.IncomingDelivery
Packages that use IncomingDelivery
Package
Description
-
Uses of IncomingDelivery in org.apache.qpid.protonj2.client.impl
Fields in org.apache.qpid.protonj2.client.impl declared as IncomingDeliveryMethods in org.apache.qpid.protonj2.client.impl with parameters of type IncomingDeliveryModifier 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
Methods in org.apache.qpid.protonj2.engine that return IncomingDeliveryModifier 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.Methods in org.apache.qpid.protonj2.engine that return types with arguments of type IncomingDeliveryModifier and TypeMethodDescriptionReceiver.unsettled()
Retrieves the list of unsettled deliveries for thisReceiver
link which have yet to be settled on this end of the link.Method parameters in org.apache.qpid.protonj2.engine with type arguments of type IncomingDeliveryModifier 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
Classes in org.apache.qpid.protonj2.engine.impl that implement IncomingDeliveryModifier and TypeClassDescriptionclass
Proton Incoming Delivery implementationMethods in org.apache.qpid.protonj2.engine.impl that return IncomingDeliveryModifier and TypeMethodDescriptionProtonIncomingDelivery.claimAvailableBytes()
ProtonIncomingDelivery.disposition
(DeliveryState state) ProtonIncomingDelivery.disposition
(DeliveryState state, boolean settle) ProtonIncomingDelivery.settle()
Methods in org.apache.qpid.protonj2.engine.impl that return types with arguments of type IncomingDeliveryMethod parameters in org.apache.qpid.protonj2.engine.impl with type arguments of type IncomingDeliveryModifier 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)