A single AMQP stream receiver instance More...
Public Member Functions | |
| IStreamDelivery | Receive () |
| Blocking receive method that waits forever for the remote to provide some or all of a delivery for consumption. This method returns a streamed delivery instance that allows for consumption or the incoming delivery as it arrives. More... | |
| IStreamDelivery | Receive (TimeSpan timeout) |
| Blocking receive method that waits for the specified time period for the remote to provide a delivery for consumption before returning null if none was received. This method returns a streamed delivery instance that allows for consumption or the incoming delivery as it arrives. More... | |
| IStreamDelivery | TryReceive () |
| Non-blocking receive method that either returns a delivery is one is immediately available or returns null if none is currently at hand. This method returns a streamed delivery instance that allows for consumption or the incoming delivery as it arrives. More... | |
| Task< IStreamDelivery > | ReceiveAsync () |
| Asynchronous receive method that waits forever for the remote to provide a delivery for consumption and when a delivery is available the returned Task will be completed. The returned task completes with a streamed delivery instance that allows for consumption or the incoming delivery as it arrives. More... | |
| Task< IStreamDelivery > | ReceiveAsync (TimeSpan timeout) |
| Asynchronous receive method that returns a Task that will be completed after the specified time period if the remote to provides a delivery for consumption before completing with null if none was received. The returned task completes with a streamed delivery instance that allows for consumption or the incoming delivery as it arrives. More... | |
| Task< IStreamDelivery > | TryReceiveAsync () |
| Asynchronous receive method that returns a Task which will be completed either with a currently available delivery or with null to indicate there are no queued deliveries. The returned task completes with a streamed delivery instance that allows for consumption or the incoming delivery as it arrives. More... | |
| IStreamReceiver | AddCredit (uint credit) |
| Adds credit to the Receiver link for use when there receiver has not been configured with with a credit window. When credit window is configured credit replenishment is automatic and calling this method will result in an exception indicating that the operation is invalid. More... | |
| Task< IStreamReceiver > | AddCreditAsync (uint credit) |
| Asynchronously Adds credit to the Receiver link for use when there receiver has not been configured with with a credit window. When credit window is configured credit replenishment is automatic and calling this method will result in an exception indicating that the operation is invalid. More... | |
| IStreamReceiver | Drain () |
| Requests the remote to drain previously granted credit for this receiver link. The remote will either send all available deliveries up to the currently granted link credit or will report it has none to send an link credit will be set to zero. This method will block until the remote answers the drain request or the configured drain timeout expires. More... | |
| Task< IStreamReceiver > | DrainAsync () |
| Requests the remote to drain previously granted credit for this receiver link. The remote will either send all available deliveries up to the currently granted link credit or will report it has none to send an link credit will be set to zero. The caller can wait on the returned task which will be signalled either after the remote reports drained or once the configured drain timeout is reached. More... | |
Properties | |
| int | QueuedDeliveries [get] |
| A count of the currently queued deliveries which can be read immediately without blocking a call to receive. More... | |
Detailed Description
A single AMQP stream receiver instance
Member Function Documentation
◆ AddCredit()
| IStreamReceiver Apache.Qpid.Proton.Client.IStreamReceiver.AddCredit | ( | uint | credit | ) |
Adds credit to the Receiver link for use when there receiver has not been configured with with a credit window. When credit window is configured credit replenishment is automatic and calling this method will result in an exception indicating that the operation is invalid.
If the Receiver is draining and this method is called an exception will be thrown to indicate that credit cannot be replenished until the remote has drained the existing link credit.
- Parameters
-
credit The amount of new credit to add to the existing credit if any
- Returns
- This receiver instance.
◆ AddCreditAsync()
| Task<IStreamReceiver> Apache.Qpid.Proton.Client.IStreamReceiver.AddCreditAsync | ( | uint | credit | ) |
Asynchronously Adds credit to the Receiver link for use when there receiver has not been configured with with a credit window. When credit window is configured credit replenishment is automatic and calling this method will result in an exception indicating that the operation is invalid.
If the Receiver is draining and this method is called an exception will be thrown to indicate that credit cannot be replenished until the remote has drained the existing link credit.
- Parameters
-
credit The amount of new credit to add to the existing credit if any
- Returns
- This receiver instance.
◆ Drain()
| IStreamReceiver Apache.Qpid.Proton.Client.IStreamReceiver.Drain | ( | ) |
Requests the remote to drain previously granted credit for this receiver link. The remote will either send all available deliveries up to the currently granted link credit or will report it has none to send an link credit will be set to zero. This method will block until the remote answers the drain request or the configured drain timeout expires.
- Returns
- This receiver instance once the remote reports drain completed
◆ DrainAsync()
| Task<IStreamReceiver> Apache.Qpid.Proton.Client.IStreamReceiver.DrainAsync | ( | ) |
Requests the remote to drain previously granted credit for this receiver link. The remote will either send all available deliveries up to the currently granted link credit or will report it has none to send an link credit will be set to zero. The caller can wait on the returned task which will be signalled either after the remote reports drained or once the configured drain timeout is reached.
- Returns
- A Task that will be completed when the remote reports drained.
◆ Receive() [1/2]
| IStreamDelivery Apache.Qpid.Proton.Client.IStreamReceiver.Receive | ( | ) |
Blocking receive method that waits forever for the remote to provide some or all of a delivery for consumption. This method returns a streamed delivery instance that allows for consumption or the incoming delivery as it arrives.
Receive calls will only grant credit on their own if a credit window is configured in the options which by default will have been configured. If the client application has not configured a credit window then this method won't grant or extend the credit window but will wait for a delivery regardless. The application needs to arrange for credit to be granted in that case.
- Returns
- The next available delivery
Implemented in Apache.Qpid.Proton.Client.Implementation.ClientStreamReceiver.
◆ Receive() [2/2]
| IStreamDelivery Apache.Qpid.Proton.Client.IStreamReceiver.Receive | ( | TimeSpan | timeout | ) |
Blocking receive method that waits for the specified time period for the remote to provide a delivery for consumption before returning null if none was received. This method returns a streamed delivery instance that allows for consumption or the incoming delivery as it arrives.
Receive calls will only grant credit on their own if a credit window is configured in the options which by default will have been configured. If the client application has not configured a credit window then this method won't grant or extend the credit window but will wait for a delivery regardless. The application needs to arrange for credit to be granted in that case.
Implemented in Apache.Qpid.Proton.Client.Implementation.ClientStreamReceiver.
◆ ReceiveAsync() [1/2]
| Task<IStreamDelivery> Apache.Qpid.Proton.Client.IStreamReceiver.ReceiveAsync | ( | ) |
Asynchronous receive method that waits forever for the remote to provide a delivery for consumption and when a delivery is available the returned Task will be completed. The returned task completes with a streamed delivery instance that allows for consumption or the incoming delivery as it arrives.
Receive calls will only grant credit on their own if a credit window is configured in the options which by default will have been configured. If the client application has not configured a credit window then this method won't grant or extend the credit window but will wait for a delivery regardless. The application needs to arrange for credit to be granted in that case.
- Returns
- The next available delivery
Implemented in Apache.Qpid.Proton.Client.Implementation.ClientStreamReceiver.
◆ ReceiveAsync() [2/2]
| Task<IStreamDelivery> Apache.Qpid.Proton.Client.IStreamReceiver.ReceiveAsync | ( | TimeSpan | timeout | ) |
Asynchronous receive method that returns a Task that will be completed after the specified time period if the remote to provides a delivery for consumption before completing with null if none was received. The returned task completes with a streamed delivery instance that allows for consumption or the incoming delivery as it arrives.
Receive calls will only grant credit on their own if a credit window is configured in the options which by default will have been configured. If the client application has not configured a credit window then this method won't grant or extend the credit window but will wait for a delivery regardless. The application needs to arrange for credit to be granted in that case.
- Returns
- The next available delivery or null if the time span elapses
Implemented in Apache.Qpid.Proton.Client.Implementation.ClientStreamReceiver.
◆ TryReceive()
| IStreamDelivery Apache.Qpid.Proton.Client.IStreamReceiver.TryReceive | ( | ) |
Non-blocking receive method that either returns a delivery is one is immediately available or returns null if none is currently at hand. This method returns a streamed delivery instance that allows for consumption or the incoming delivery as it arrives.
- Returns
- A delivery if one is immediately available or null if not
Implemented in Apache.Qpid.Proton.Client.Implementation.ClientStreamReceiver.
◆ TryReceiveAsync()
| Task<IStreamDelivery> Apache.Qpid.Proton.Client.IStreamReceiver.TryReceiveAsync | ( | ) |
Asynchronous receive method that returns a Task which will be completed either with a currently available delivery or with null to indicate there are no queued deliveries. The returned task completes with a streamed delivery instance that allows for consumption or the incoming delivery as it arrives.
- Returns
- A Task that completes with a delivery if one is immediately available or null if not
Implemented in Apache.Qpid.Proton.Client.Implementation.ClientStreamReceiver.
Property Documentation
◆ QueuedDeliveries
|
get |
A count of the currently queued deliveries which can be read immediately without blocking a call to receive.
The documentation for this interface was generated from the following file:
- src/Proton.Client/Client/IStreamReceiver.cs
