Uses of Interface
org.apache.qpid.protonj2.client.Receiver
-
Uses of Receiver in org.apache.qpid.protonj2.client
Modifier 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()
-
Uses of Receiver in org.apache.qpid.protonj2.client.impl
Modifier 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()