Uses of Interface
org.apache.qpid.protonj2.client.Receiver
Packages that use Receiver
-
Uses of Receiver in org.apache.qpid.protonj2.client
Methods in org.apache.qpid.protonj2.client that return ReceiverModifier and TypeMethodDescriptionReceiver.addCredit
(int credits) Adds credit to theReceiver
link for use when there receiver has not been configured with a credit window.Connection.nextReceiver()
Waits indefinitely for a receiver created from the connection default session to have a delivery ready for receipt.Connection.nextReceiver
(long timeout, TimeUnit unit) Waits for the configured time interval for a receiver created from the connection default session to have a delivery ready for receipt.Connection.nextReceiver
(NextReceiverPolicy policy) Waits indefinitely for a receiver created from the connection default session to have a delivery ready for receipt.Connection.nextReceiver
(NextReceiverPolicy policy, long timeout, TimeUnit unit) Waits for the configured time interval for a receiver created from the connection default session to have a delivery ready for receipt.Session.nextReceiver()
Waits indefinitely for a receiver created from this session to have a delivery ready for receipt.Session.nextReceiver
(long timeout, TimeUnit unit) Waits for the given duration for a receiver created from this session to have a delivery ready for receipt.Session.nextReceiver
(NextReceiverPolicy policy) Waits indefinitely for a receiver created from this session to have a delivery ready for receipt.Session.nextReceiver
(NextReceiverPolicy policy, long timeout, TimeUnit unit) Waits for the given duration for a receiver created from this session to have a delivery ready for receipt.Connection.openDurableReceiver
(String address, 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.Connection.openDurableReceiver
(String address, 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.Session.openDurableReceiver
(String address, 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.Session.openDurableReceiver
(String address, 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.Connection.openDynamicReceiver()
Creates a dynamic receiver used to consume messages from the given node address.Connection.openDynamicReceiver
(Map<String, Object> dynamicNodeProperties) Creates a dynamic receiver used to consume messages from a dynamically generated node on the remote..Connection.openDynamicReceiver
(Map<String, Object> dynamicNodeProperties, ReceiverOptions receiverOptions) Creates a dynamic receiver used to consume messages from the given node address.Connection.openDynamicReceiver
(ReceiverOptions receiverOptions) Creates a dynamic receiver used to consume messages from a dynamically generated node on the remote..Session.openDynamicReceiver()
Creates a dynamic receiver used to consume messages from the given node address.Session.openDynamicReceiver
(Map<String, Object> dynamicNodeProperties) Creates a dynamic receiver used to consume messages from the given node address.Session.openDynamicReceiver
(Map<String, Object> dynamicNodeProperties, ReceiverOptions receiverOptions) Creates a dynamic receiver used to consume messages from the given node address.Session.openDynamicReceiver
(ReceiverOptions receiverOptions) Creates a dynamic receiver used to consume messages from the given node address.Connection.openReceiver
(String address) Creates a receiver used to consumer messages from the given node address.Connection.openReceiver
(String address, ReceiverOptions receiverOptions) Creates a receiver used to consumer messages from the given node address.Session.openReceiver
(String address) Creates a receiver used to consume messages from the given node address.Session.openReceiver
(String address, ReceiverOptions receiverOptions) Creates a receiver used to consume messages from the given node address.Delivery.receiver()
Methods in org.apache.qpid.protonj2.client that return types with arguments of type Receiver -
Uses of Receiver in org.apache.qpid.protonj2.client.impl
Classes in org.apache.qpid.protonj2.client.impl that implement ReceiverMethods in org.apache.qpid.protonj2.client.impl that return ReceiverModifier and TypeMethodDescriptionClientReceiver.addCredit
(int credits) ClientConnection.nextReceiver()
ClientConnection.nextReceiver
(long timeout, TimeUnit unit) ClientConnection.nextReceiver
(NextReceiverPolicy policy) ClientConnection.nextReceiver
(NextReceiverPolicy policy, long timeout, TimeUnit unit) ClientSession.nextReceiver()
ClientSession.nextReceiver
(long timeout, TimeUnit unit) ClientSession.nextReceiver
(NextReceiverPolicy policy) ClientSession.nextReceiver
(NextReceiverPolicy policy, long timeout, TimeUnit unit) ClientConnection.openDurableReceiver
(String address, String subscriptionName) ClientConnection.openDurableReceiver
(String address, String subscriptionName, ReceiverOptions receiverOptions) ClientSession.openDurableReceiver
(String address, String subscriptionName) ClientSession.openDurableReceiver
(String address, String subscriptionName, ReceiverOptions receiverOptions) ClientStreamSession.openDurableReceiver
(String address, String subscriptionName) ClientStreamSession.openDurableReceiver
(String address, String subscriptionName, ReceiverOptions receiverOptions) ClientConnection.openDynamicReceiver()
ClientConnection.openDynamicReceiver
(Map<String, Object> dynamicNodeProperties) ClientConnection.openDynamicReceiver
(Map<String, Object> dynamicNodeProperties, ReceiverOptions receiverOptions) ClientConnection.openDynamicReceiver
(ReceiverOptions receiverOptions) ClientSession.openDynamicReceiver()
ClientSession.openDynamicReceiver
(Map<String, Object> dynamicNodeProperties) ClientSession.openDynamicReceiver
(Map<String, Object> dynamicNodeProperties, ReceiverOptions receiverOptions) ClientSession.openDynamicReceiver
(ReceiverOptions receiverOptions) ClientStreamSession.openDynamicReceiver()
ClientStreamSession.openDynamicReceiver
(Map<String, Object> dynamicNodeProperties) ClientStreamSession.openDynamicReceiver
(Map<String, Object> dynamicNodeProperties, ReceiverOptions receiverOptions) ClientStreamSession.openDynamicReceiver
(ReceiverOptions receiverOptions) ClientConnection.openReceiver
(String address) ClientConnection.openReceiver
(String address, ReceiverOptions receiverOptions) ClientSession.openReceiver
(String address) ClientSession.openReceiver
(String address, ReceiverOptions receiverOptions) ClientStreamSession.openReceiver
(String address) ClientStreamSession.openReceiver
(String address, ReceiverOptions receiverOptions) ClientDelivery.receiver()
protected Receiver
ClientReceiver.self()
Methods in org.apache.qpid.protonj2.client.impl that return types with arguments of type Receiver