Uses of Interface
org.apache.qpid.protonj2.client.StreamDelivery
-
Packages that use StreamDelivery Package Description org.apache.qpid.protonj2.client org.apache.qpid.protonj2.client.impl -
-
Uses of StreamDelivery in org.apache.qpid.protonj2.client
Methods in org.apache.qpid.protonj2.client that return StreamDelivery Modifier and Type Method Description StreamDeliveryStreamDelivery. accept()Accepts and settles the delivery.StreamDeliveryStreamReceiverMessage. delivery()StreamDeliveryStreamDelivery. disposition(DeliveryState state, boolean settle)Updates the DeliveryState, and optionally settle the delivery as well.StreamDeliveryStreamDelivery. modified(boolean deliveryFailed, boolean undeliverableHere)Modifies and settles the delivery.StreamDeliveryStreamReceiver. receive()Blocking receive method that waits forever for the remote to provide aStreamReceiverMessagefor consumption.StreamDeliveryStreamReceiver. receive(long timeout, java.util.concurrent.TimeUnit unit)Blocking receive method that waits the given time interval for the remote to provide aStreamReceiverMessagefor consumption.StreamDeliveryStreamDelivery. reject(java.lang.String condition, java.lang.String description)Rejects and settles the delivery, sending supplied error information along with the rejection.StreamDeliveryStreamDelivery. release()Releases and settles the delivery.StreamDeliveryStreamDelivery. settle()Settles the delivery locally.StreamDeliveryStreamReceiver. tryReceive()Non-blocking receive method that either returns a message is one is immediately available or returns null if none is currently at hand. -
Uses of StreamDelivery in org.apache.qpid.protonj2.client.impl
Classes in org.apache.qpid.protonj2.client.impl that implement StreamDelivery Modifier and Type Class Description classClientStreamDeliveryAStreamDeliveryimplementation that provides the mechanics of reading message types from an incoming split framed transfer.Methods in org.apache.qpid.protonj2.client.impl that return StreamDelivery Modifier and Type Method Description StreamDeliveryClientStreamDelivery. accept()StreamDeliveryClientStreamDelivery. disposition(DeliveryState state, boolean settle)StreamDeliveryClientStreamDelivery. modified(boolean deliveryFailed, boolean undeliverableHere)StreamDeliveryClientStreamReceiver. receive()StreamDeliveryClientStreamReceiver. receive(long timeout, java.util.concurrent.TimeUnit unit)StreamDeliveryClientStreamDelivery. reject(java.lang.String condition, java.lang.String description)StreamDeliveryClientStreamDelivery. release()StreamDeliveryClientStreamDelivery. settle()StreamDeliveryClientStreamReceiver. tryReceive()
-