Uses of Interface
org.apache.qpid.protonj2.engine.IncomingDelivery
-
Packages that use IncomingDelivery Package Description org.apache.qpid.protonj2.client.impl org.apache.qpid.protonj2.engine org.apache.qpid.protonj2.engine.impl -
-
Uses of IncomingDelivery in org.apache.qpid.protonj2.client.impl
Methods in org.apache.qpid.protonj2.client.impl with parameters of type IncomingDelivery Modifier and Type Method Description ClientTransactionContext
ClientTransactionContext. disposition(IncomingDelivery delivery, DeliveryState state, boolean settled)
Apply a disposition to the given delivery wrapping it with aTransactionalState
outcome if there is an active transaction. -
Uses of IncomingDelivery in org.apache.qpid.protonj2.engine
Methods in org.apache.qpid.protonj2.engine that return IncomingDelivery Modifier and Type Method Description IncomingDelivery
IncomingDelivery. 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
IncomingDelivery. deliveryAbortedHandler(EventHandler<IncomingDelivery> handler)
Handler for aborted deliveries that is called if this delivery is aborted by theSender
.IncomingDelivery
IncomingDelivery. deliveryReadHandler(EventHandler<IncomingDelivery> handler)
IncomingDelivery
IncomingDelivery. deliveryStateUpdatedHandler(EventHandler<IncomingDelivery> handler)
Handler for updates to the remote state of incoming deliveries that have previously been received.IncomingDelivery
IncomingDelivery. disposition(DeliveryState state)
updates the state of the deliveryIncomingDelivery
IncomingDelivery. 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
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
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
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
IncomingDelivery. setLinkedResource(java.lang.Object resource)
Links a given resource to thisIncomingDelivery
.IncomingDelivery
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 IncomingDelivery Modifier and Type Method Description java.util.Collection<IncomingDelivery>
Receiver. 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 IncomingDelivery Modifier and Type Method Description IncomingDelivery
IncomingDelivery. deliveryAbortedHandler(EventHandler<IncomingDelivery> handler)
Handler for aborted deliveries that is called if this delivery is aborted by theSender
.Receiver
Receiver. deliveryAbortedHandler(EventHandler<IncomingDelivery> handler)
Handler for aborted deliveries that is called for each aborted in-progress delivery.IncomingDelivery
IncomingDelivery. deliveryReadHandler(EventHandler<IncomingDelivery> handler)
Receiver
Receiver. deliveryReadHandler(EventHandler<IncomingDelivery> handler)
IncomingDelivery
IncomingDelivery. deliveryStateUpdatedHandler(EventHandler<IncomingDelivery> handler)
Handler for updates to the remote state of incoming deliveries that have previously been received.Receiver
Receiver. deliveryStateUpdatedHandler(EventHandler<IncomingDelivery> handler)
Handler for updates to the remote state of incoming deliveries that have previously been received.Receiver
Receiver. disposition(java.util.function.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
Receiver. settle(java.util.function.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 IncomingDelivery Modifier and Type Class Description class
ProtonIncomingDelivery
Proton Incoming Delivery implementationMethods in org.apache.qpid.protonj2.engine.impl that return IncomingDelivery Modifier and Type Method Description IncomingDelivery
ProtonIncomingDelivery. claimAvailableBytes()
IncomingDelivery
ProtonIncomingDelivery. disposition(DeliveryState state)
IncomingDelivery
ProtonIncomingDelivery. disposition(DeliveryState state, boolean settle)
IncomingDelivery
ProtonIncomingDelivery. settle()
Methods in org.apache.qpid.protonj2.engine.impl that return types with arguments of type IncomingDelivery Modifier and Type Method Description java.util.Collection<IncomingDelivery>
ProtonReceiver. unsettled()
Method parameters in org.apache.qpid.protonj2.engine.impl with type arguments of type IncomingDelivery Modifier and Type Method Description ProtonIncomingDelivery
ProtonIncomingDelivery. deliveryAbortedHandler(EventHandler<IncomingDelivery> handler)
Receiver
ProtonReceiver. deliveryAbortedHandler(EventHandler<IncomingDelivery> handler)
ProtonIncomingDelivery
ProtonIncomingDelivery. deliveryReadHandler(EventHandler<IncomingDelivery> handler)
Receiver
ProtonReceiver. deliveryReadHandler(EventHandler<IncomingDelivery> handler)
ProtonIncomingDelivery
ProtonIncomingDelivery. deliveryStateUpdatedHandler(EventHandler<IncomingDelivery> handler)
Receiver
ProtonReceiver. deliveryStateUpdatedHandler(EventHandler<IncomingDelivery> handler)
Receiver
ProtonReceiver. disposition(java.util.function.Predicate<IncomingDelivery> filter, DeliveryState disposition, boolean settle)
Receiver
ProtonReceiver. settle(java.util.function.Predicate<IncomingDelivery> filter)
-