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 ClientTransactionContextClientTransactionContext. disposition(IncomingDelivery delivery, DeliveryState state, boolean settled)Apply a disposition to the given delivery wrapping it with aTransactionalStateoutcome 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 IncomingDeliveryIncomingDelivery. 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.IncomingDeliveryIncomingDelivery. deliveryAbortedHandler(EventHandler<IncomingDelivery> handler)Handler for aborted deliveries that is called if this delivery is aborted by theSender.IncomingDeliveryIncomingDelivery. deliveryReadHandler(EventHandler<IncomingDelivery> handler)IncomingDeliveryIncomingDelivery. deliveryStateUpdatedHandler(EventHandler<IncomingDelivery> handler)Handler for updates to the remote state of incoming deliveries that have previously been received.IncomingDeliveryIncomingDelivery. disposition(DeliveryState state)updates the state of the deliveryIncomingDeliveryIncomingDelivery. 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.IncomingDeliveryIncomingDelivery. 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.IncomingDeliveryIncomingDelivery. 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.IncomingDeliveryIncomingDelivery. 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.IncomingDeliveryIncomingDelivery. setLinkedResource(java.lang.Object resource)Links a given resource to thisIncomingDelivery.IncomingDeliveryIncomingDelivery. settle()Settles this delivery locally, transmitting aDispositionframe 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 thisReceiverlink 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 IncomingDeliveryIncomingDelivery. deliveryAbortedHandler(EventHandler<IncomingDelivery> handler)Handler for aborted deliveries that is called if this delivery is aborted by theSender.ReceiverReceiver. deliveryAbortedHandler(EventHandler<IncomingDelivery> handler)Handler for aborted deliveries that is called for each aborted in-progress delivery.IncomingDeliveryIncomingDelivery. deliveryReadHandler(EventHandler<IncomingDelivery> handler)ReceiverReceiver. deliveryReadHandler(EventHandler<IncomingDelivery> handler)IncomingDeliveryIncomingDelivery. deliveryStateUpdatedHandler(EventHandler<IncomingDelivery> handler)Handler for updates to the remote state of incoming deliveries that have previously been received.ReceiverReceiver. deliveryStateUpdatedHandler(EventHandler<IncomingDelivery> handler)Handler for updates to the remote state of incoming deliveries that have previously been received.ReceiverReceiver. disposition(java.util.function.Predicate<IncomingDelivery> filter, DeliveryState state, boolean settle)For each unsettled outgoing delivery that is pending in theReceiverapply the given predicate and if it matches then apply the given delivery state and settled value to it.ReceiverReceiver. settle(java.util.function.Predicate<IncomingDelivery> filter)For each unsettled outgoing delivery that is pending in theReceiverapply 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 classProtonIncomingDeliveryProton Incoming Delivery implementationMethods in org.apache.qpid.protonj2.engine.impl that return IncomingDelivery Modifier and Type Method Description IncomingDeliveryProtonIncomingDelivery. claimAvailableBytes()IncomingDeliveryProtonIncomingDelivery. disposition(DeliveryState state)IncomingDeliveryProtonIncomingDelivery. disposition(DeliveryState state, boolean settle)IncomingDeliveryProtonIncomingDelivery. 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 ProtonIncomingDeliveryProtonIncomingDelivery. deliveryAbortedHandler(EventHandler<IncomingDelivery> handler)ReceiverProtonReceiver. deliveryAbortedHandler(EventHandler<IncomingDelivery> handler)ProtonIncomingDeliveryProtonIncomingDelivery. deliveryReadHandler(EventHandler<IncomingDelivery> handler)ReceiverProtonReceiver. deliveryReadHandler(EventHandler<IncomingDelivery> handler)ProtonIncomingDeliveryProtonIncomingDelivery. deliveryStateUpdatedHandler(EventHandler<IncomingDelivery> handler)ReceiverProtonReceiver. deliveryStateUpdatedHandler(EventHandler<IncomingDelivery> handler)ReceiverProtonReceiver. disposition(java.util.function.Predicate<IncomingDelivery> filter, DeliveryState disposition, boolean settle)ReceiverProtonReceiver. settle(java.util.function.Predicate<IncomingDelivery> filter)
-