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 interface
StreamReceiver
A receiver of large message content that is delivered in multipleTransfer
frames from the remote.Methods in org.apache.qpid.protonj2.client that return Receiver Modifier and Type Method Description Receiver
Receiver. addCredit(int credits)
Adds credit to theReceiver
link for use when there receiver has not been configured with a credit window.Receiver
Connection. 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.Receiver
Connection. 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.Receiver
Session. 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.Receiver
Session. 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.Receiver
Connection. openDynamicReceiver()
Creates a dynamic receiver used to consume messages from the given node address.Receiver
Connection. 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..Receiver
Connection. 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.Receiver
Connection. openDynamicReceiver(ReceiverOptions receiverOptions)
Creates a dynamic receiver used to consume messages from a dynamically generated node on the remote..Receiver
Session. openDynamicReceiver()
Creates a dynamic receiver used to consume messages from the given node address.Receiver
Session. openDynamicReceiver(java.util.Map<java.lang.String,java.lang.Object> dynamicNodeProperties)
Creates a dynamic receiver used to consume messages from the given node address.Receiver
Session. 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.Receiver
Session. openDynamicReceiver(ReceiverOptions receiverOptions)
Creates a dynamic receiver used to consume messages from the given node address.Receiver
Connection. openReceiver(java.lang.String address)
Creates a receiver used to consumer messages from the given node address.Receiver
Connection. openReceiver(java.lang.String address, ReceiverOptions receiverOptions)
Creates a receiver used to consumer messages from the given node address.Receiver
Session. openReceiver(java.lang.String address)
Creates a receiver used to consume messages from the given node address.Receiver
Session. openReceiver(java.lang.String address, ReceiverOptions receiverOptions)
Creates a receiver used to consume messages from the given node address.Receiver
Delivery. 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 theReceiver
link at the remote and returns aFuture
that will be completed once the link has been closed.java.util.concurrent.Future<Receiver>
Receiver. closeAsync(ErrorCondition error)
Requests a close of theReceiver
link at the remote and returns aFuture
that will be completed once the link has been closed.java.util.concurrent.Future<Receiver>
Receiver. detachAsync()
Requests a detach of theReceiver
link at the remote and returns aFuture
that will be completed once the link has been detached.java.util.concurrent.Future<Receiver>
Receiver. detachAsync(ErrorCondition error)
Requests a detach of theReceiver
link at the remote and returns aFuture
that 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 thisReceiver
link.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 class
ClientReceiver
ClientReceiver
implementation.class
ClientStreamReceiver
Client implementation of aStreamReceiver
.Methods in org.apache.qpid.protonj2.client.impl that return Receiver Modifier and Type Method Description Receiver
ClientReceiver. addCredit(int credits)
Receiver
ClientConnection. openDurableReceiver(java.lang.String address, java.lang.String subscriptionName)
Receiver
ClientConnection. openDurableReceiver(java.lang.String address, java.lang.String subscriptionName, ReceiverOptions receiverOptions)
Receiver
ClientSession. openDurableReceiver(java.lang.String address, java.lang.String subscriptionName)
Receiver
ClientSession. openDurableReceiver(java.lang.String address, java.lang.String subscriptionName, ReceiverOptions receiverOptions)
Receiver
ClientStreamSession. openDurableReceiver(java.lang.String address, java.lang.String subscriptionName)
Receiver
ClientStreamSession. openDurableReceiver(java.lang.String address, java.lang.String subscriptionName, ReceiverOptions receiverOptions)
Receiver
ClientConnection. openDynamicReceiver()
Receiver
ClientConnection. openDynamicReceiver(java.util.Map<java.lang.String,java.lang.Object> dynamicNodeProperties)
Receiver
ClientConnection. openDynamicReceiver(java.util.Map<java.lang.String,java.lang.Object> dynamicNodeProperties, ReceiverOptions receiverOptions)
Receiver
ClientConnection. openDynamicReceiver(ReceiverOptions receiverOptions)
Receiver
ClientSession. openDynamicReceiver()
Receiver
ClientSession. openDynamicReceiver(java.util.Map<java.lang.String,java.lang.Object> dynamicNodeProperties)
Receiver
ClientSession. openDynamicReceiver(java.util.Map<java.lang.String,java.lang.Object> dynamicNodeProperties, ReceiverOptions receiverOptions)
Receiver
ClientSession. openDynamicReceiver(ReceiverOptions receiverOptions)
Receiver
ClientStreamSession. openDynamicReceiver()
Receiver
ClientStreamSession. openDynamicReceiver(java.util.Map<java.lang.String,java.lang.Object> dynamicNodeProperties)
Receiver
ClientStreamSession. openDynamicReceiver(java.util.Map<java.lang.String,java.lang.Object> dynamicNodeProperties, ReceiverOptions receiverOptions)
Receiver
ClientStreamSession. openDynamicReceiver(ReceiverOptions receiverOptions)
Receiver
ClientConnection. openReceiver(java.lang.String address)
Receiver
ClientConnection. openReceiver(java.lang.String address, ReceiverOptions receiverOptions)
Receiver
ClientSession. openReceiver(java.lang.String address)
Receiver
ClientSession. openReceiver(java.lang.String address, ReceiverOptions receiverOptions)
Receiver
ClientStreamSession. openReceiver(java.lang.String address)
Receiver
ClientStreamSession. openReceiver(java.lang.String address, ReceiverOptions receiverOptions)
Receiver
ClientDelivery. 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()
-