Uses of Interface
org.apache.qpid.protonj2.client.Receiver
-
Packages that use Receiver Package Description org.apache.qpid.protonj2.client org.apache.qpid.protonj2.client.impl -
-
Uses of Receiver in org.apache.qpid.protonj2.client
Subinterfaces of Receiver in org.apache.qpid.protonj2.client Modifier and Type Interface Description interfaceStreamReceiverA receiver of large message content that is delivered in multipleTransferframes from the remote.Methods in org.apache.qpid.protonj2.client that return Receiver Modifier and Type Method Description ReceiverReceiver. addCredit(int credits)Adds credit to theReceiverlink for use when there receiver has not been configured with a credit window.ReceiverConnection. openDurableReceiver(java.lang.String address, java.lang.String subscriptionName)Creates a receiver used to consume messages from the given node address and configure it such that the remote create a durable node.ReceiverConnection. openDurableReceiver(java.lang.String address, java.lang.String subscriptionName, ReceiverOptions receiverOptions)Creates a receiver used to consume messages from the given node address and configure it such that the remote create a durable node.ReceiverSession. openDurableReceiver(java.lang.String address, java.lang.String subscriptionName)Creates a receiver used to consume messages from the given node address and configure it such that the remote create a durable node.ReceiverSession. openDurableReceiver(java.lang.String address, java.lang.String subscriptionName, ReceiverOptions receiverOptions)Creates a receiver used to consume messages from the given node address and configure it such that the remote create a durable node.ReceiverConnection. openDynamicReceiver()Creates a dynamic receiver used to consume messages from the given node address.ReceiverConnection. openDynamicReceiver(java.util.Map<java.lang.String,java.lang.Object> dynamicNodeProperties)Creates a dynamic receiver used to consume messages from a dynamically generated node on the remote..ReceiverConnection. openDynamicReceiver(java.util.Map<java.lang.String,java.lang.Object> dynamicNodeProperties, ReceiverOptions receiverOptions)Creates a dynamic receiver used to consume messages from the given node address.ReceiverConnection. openDynamicReceiver(ReceiverOptions receiverOptions)Creates a dynamic receiver used to consume messages from a dynamically generated node on the remote..ReceiverSession. openDynamicReceiver()Creates a dynamic receiver used to consume messages from the given node address.ReceiverSession. openDynamicReceiver(java.util.Map<java.lang.String,java.lang.Object> dynamicNodeProperties)Creates a dynamic receiver used to consume messages from the given node address.ReceiverSession. openDynamicReceiver(java.util.Map<java.lang.String,java.lang.Object> dynamicNodeProperties, ReceiverOptions receiverOptions)Creates a dynamic receiver used to consume messages from the given node address.ReceiverSession. openDynamicReceiver(ReceiverOptions receiverOptions)Creates a dynamic receiver used to consume messages from the given node address.ReceiverConnection. openReceiver(java.lang.String address)Creates a receiver used to consumer messages from the given node address.ReceiverConnection. openReceiver(java.lang.String address, ReceiverOptions receiverOptions)Creates a receiver used to consumer messages from the given node address.ReceiverSession. openReceiver(java.lang.String address)Creates a receiver used to consume messages from the given node address.ReceiverSession. openReceiver(java.lang.String address, ReceiverOptions receiverOptions)Creates a receiver used to consume messages from the given node address.ReceiverDelivery. receiver()Methods in org.apache.qpid.protonj2.client that return types with arguments of type Receiver Modifier and Type Method Description java.util.concurrent.Future<Receiver>Receiver. closeAsync()Requests a close of theReceiverlink at the remote and returns aFuturethat will be completed once the link has been closed.java.util.concurrent.Future<Receiver>Receiver. closeAsync(ErrorCondition error)Requests a close of theReceiverlink at the remote and returns aFuturethat will be completed once the link has been closed.java.util.concurrent.Future<Receiver>Receiver. detachAsync()Requests a detach of theReceiverlink at the remote and returns aFuturethat will be completed once the link has been detached.java.util.concurrent.Future<Receiver>Receiver. detachAsync(ErrorCondition error)Requests a detach of theReceiverlink at the remote and returns aFuturethat will be completed once the link has been detached.java.util.concurrent.Future<Receiver>Receiver. drain()Requests the remote to drain previously granted credit for thisReceiverlink.java.util.concurrent.Future<Receiver>Receiver. openFuture() -
Uses of Receiver in org.apache.qpid.protonj2.client.impl
Classes in org.apache.qpid.protonj2.client.impl that implement Receiver Modifier and Type Class Description classClientReceiverClientReceiverimplementation.classClientStreamReceiverClient implementation of aStreamReceiver.Methods in org.apache.qpid.protonj2.client.impl that return Receiver Modifier and Type Method Description ReceiverClientReceiver. addCredit(int credits)ReceiverClientConnection. openDurableReceiver(java.lang.String address, java.lang.String subscriptionName)ReceiverClientConnection. openDurableReceiver(java.lang.String address, java.lang.String subscriptionName, ReceiverOptions receiverOptions)ReceiverClientSession. openDurableReceiver(java.lang.String address, java.lang.String subscriptionName)ReceiverClientSession. openDurableReceiver(java.lang.String address, java.lang.String subscriptionName, ReceiverOptions receiverOptions)ReceiverClientStreamSession. openDurableReceiver(java.lang.String address, java.lang.String subscriptionName)ReceiverClientStreamSession. openDurableReceiver(java.lang.String address, java.lang.String subscriptionName, ReceiverOptions receiverOptions)ReceiverClientConnection. openDynamicReceiver()ReceiverClientConnection. openDynamicReceiver(java.util.Map<java.lang.String,java.lang.Object> dynamicNodeProperties)ReceiverClientConnection. openDynamicReceiver(java.util.Map<java.lang.String,java.lang.Object> dynamicNodeProperties, ReceiverOptions receiverOptions)ReceiverClientConnection. openDynamicReceiver(ReceiverOptions receiverOptions)ReceiverClientSession. openDynamicReceiver()ReceiverClientSession. openDynamicReceiver(java.util.Map<java.lang.String,java.lang.Object> dynamicNodeProperties)ReceiverClientSession. openDynamicReceiver(java.util.Map<java.lang.String,java.lang.Object> dynamicNodeProperties, ReceiverOptions receiverOptions)ReceiverClientSession. openDynamicReceiver(ReceiverOptions receiverOptions)ReceiverClientStreamSession. openDynamicReceiver()ReceiverClientStreamSession. openDynamicReceiver(java.util.Map<java.lang.String,java.lang.Object> dynamicNodeProperties)ReceiverClientStreamSession. openDynamicReceiver(java.util.Map<java.lang.String,java.lang.Object> dynamicNodeProperties, ReceiverOptions receiverOptions)ReceiverClientStreamSession. openDynamicReceiver(ReceiverOptions receiverOptions)ReceiverClientConnection. openReceiver(java.lang.String address)ReceiverClientConnection. openReceiver(java.lang.String address, ReceiverOptions receiverOptions)ReceiverClientSession. openReceiver(java.lang.String address)ReceiverClientSession. openReceiver(java.lang.String address, ReceiverOptions receiverOptions)ReceiverClientStreamSession. openReceiver(java.lang.String address)ReceiverClientStreamSession. openReceiver(java.lang.String address, ReceiverOptions receiverOptions)ReceiverClientDelivery. receiver()Methods in org.apache.qpid.protonj2.client.impl that return types with arguments of type Receiver Modifier and Type Method Description ClientFuture<Receiver>ClientReceiver. closeAsync()ClientFuture<Receiver>ClientReceiver. closeAsync(ErrorCondition error)ClientFuture<Receiver>ClientStreamReceiver. closeAsync()ClientFuture<Receiver>ClientStreamReceiver. closeAsync(ErrorCondition error)ClientFuture<Receiver>ClientReceiver. detachAsync()ClientFuture<Receiver>ClientReceiver. detachAsync(ErrorCondition error)ClientFuture<Receiver>ClientStreamReceiver. detachAsync()ClientFuture<Receiver>ClientStreamReceiver. detachAsync(ErrorCondition error)java.util.concurrent.Future<Receiver>ClientReceiver. drain()java.util.concurrent.Future<Receiver>ClientStreamReceiver. drain()java.util.concurrent.Future<Receiver>ClientReceiver. openFuture()ClientFuture<Receiver>ClientStreamReceiver. openFuture()
-