Sender implementation that send complete messages on a remote link.
More...
|
ITracker | Send< T > (IMessage< T > message, IDictionary< string, object > deliveryAnnotations=null) |
| Send the given message immediately if there is credit available or blocks if the link has not yet been granted credit. If a send timeout has been configured then this method will throw a timed out error after that if the message cannot be sent. More...
|
|
ITracker | TrySend< T > (IMessage< T > message, IDictionary< string, object > deliveryAnnotations=null) |
| Send the given message if credit is available or returns null if no credit has been granted to the link at the time of the send attempt. More...
|
|
Task< ITracker > | SendAsync< T > (IMessage< T > message, IDictionary< string, object > deliveryAnnotations=null) |
| Send the given message immediately if there is credit available or waits if the link has not yet been granted credit. If a send timeout has been configured then this method will fail the returned Task with a timed out error after that if the message cannot be sent. The returned Task will be completed once the message has been sent. More...
|
|
Task< ITracker > | TrySendAsync< T > (IMessage< T > message, IDictionary< string, object > deliveryAnnotations=null) |
| Send the given message if credit is available or completes the returned Task with null if no credit has been granted to the link at the time of the send attempt. More...
|
|
void | Close (IErrorCondition error=null) |
|
Task< LinkType > | CloseAsync (IErrorCondition error=null) |
|
void | Detach (IErrorCondition error=null) |
|
Task< LinkType > | DetachAsync (IErrorCondition error=null) |
|
void | Dispose () |
|
|
IClient | Client |
|
IConnection | Connection |
|
ISession | Session |
|
Task< LinkType > | OpenTask |
|
virtual Task< LinkType > | DoCloseOrDetach (bool close, IErrorCondition error) |
|
void | CheckClosedOrFailed () |
|
void | WaitForOpenToComplete () |
|
bool | NotClosedOrFailed< T > (TaskCompletionSource< T > request) |
|
bool | NotClosedOrFailed< T > (TaskCompletionSource< T > request, ProtonLinkType sender) |
|
readonly AtomicBoolean | closed |
|
readonly ClientSession | session |
|
ClientException | failureCause |
|
readonly TaskCompletionSource< LinkType > | openFuture |
|
readonly TaskCompletionSource< LinkType > | closeFuture |
|
volatile ISource | remoteSource |
|
volatile ITarget | remoteTarget |
|
ProtonLinkType | protonLink |
|
string??? | Address [get] |
|
ISource | Source [get] |
|
ITarget | Target [get] |
|
IReadOnlyDictionary< string, object > | Properties [get] |
|
IReadOnlyCollection< string > | OfferedCapabilities [get] |
|
IReadOnlyCollection< string > | DesiredCapabilities [get] |
|
Sender implementation that send complete messages on a remote link.
◆ Send< T >()
ITracker Apache.Qpid.Proton.Client.Implementation.ClientSender.Send< T > |
( |
IMessage< T > |
message, |
|
|
IDictionary< string, object > |
deliveryAnnotations = null |
|
) |
| |
|
inline |
Send the given message immediately if there is credit available or blocks if the link has not yet been granted credit. If a send timeout has been configured then this method will throw a timed out error after that if the message cannot be sent.
- Template Parameters
-
T | The type that describes the message body |
- Parameters
-
message | The message object that will be sent |
deliveryAnnotations | Optional delivery annotation to include with the message |
- Returns
- A Tracker for the sent message
Implements Apache.Qpid.Proton.Client.ISender.
◆ SendAsync< T >()
Task<ITracker> Apache.Qpid.Proton.Client.Implementation.ClientSender.SendAsync< T > |
( |
IMessage< T > |
message, |
|
|
IDictionary< string, object > |
deliveryAnnotations = null |
|
) |
| |
|
inline |
Send the given message immediately if there is credit available or waits if the link has not yet been granted credit. If a send timeout has been configured then this method will fail the returned Task with a timed out error after that if the message cannot be sent. The returned Task will be completed once the message has been sent.
- Template Parameters
-
T | The type that describes the message body |
- Parameters
-
message | The message object that will be sent |
deliveryAnnotations | Optional delivery annotation to include with the message |
- Returns
- A Task that is completed with a Tracker once the send completes
Implements Apache.Qpid.Proton.Client.ISender.
◆ TrySend< T >()
ITracker Apache.Qpid.Proton.Client.Implementation.ClientSender.TrySend< T > |
( |
IMessage< T > |
message, |
|
|
IDictionary< string, object > |
deliveryAnnotations = null |
|
) |
| |
|
inline |
Send the given message if credit is available or returns null if no credit has been granted to the link at the time of the send attempt.
- Template Parameters
-
T | The type that describes the message body |
- Parameters
-
message | The message object that will be sent |
deliveryAnnotations | Optional delivery annotation to include with the message |
- Returns
- A Tracker for the sent message or null if no credit to send is available
Implements Apache.Qpid.Proton.Client.ISender.
◆ TrySendAsync< T >()
Task<ITracker> Apache.Qpid.Proton.Client.Implementation.ClientSender.TrySendAsync< T > |
( |
IMessage< T > |
message, |
|
|
IDictionary< string, object > |
deliveryAnnotations = null |
|
) |
| |
|
inline |
Send the given message if credit is available or completes the returned Task with null if no credit has been granted to the link at the time of the send attempt.
- Template Parameters
-
T | The type that describes the message body |
- Parameters
-
message | The message object that will be sent |
deliveryAnnotations | Optional delivery annotation to include with the message |
- Returns
- A Task that provides a tracker if the send completes or null if no credit
Implements Apache.Qpid.Proton.Client.ISender.
The documentation for this class was generated from the following file:
- src/Proton.Client/Client/Implementation/ClientSender.cs