|
|
| ProtonReceiver (ProtonSession session, string name, ProtonLinkCreditState creditState) |
| |
| IReceiver | AddCredit (uint amount) |
| | Adds the given amount of credit to the receiver's already existing credit if any. More...
|
| |
| bool | Drain () |
| | Initiate a drain of all remaining credit of this link, the remote sender will then either send enough deliveries to fulfill the drain request or report that it cannot and all remaining link credit will be consumed. More...
|
| |
| bool | Drain (uint credits) |
| | Initiate a drain of the given credit from this this receiver} link. If the credit given is greater than the current link credit the current credit is increased, however if the amount of credit given is less that the current amount of link credit an exception is thrown. More...
|
| |
| IReceiver | Settle (Predicate< IIncomingDelivery > filter) |
| | For each unsettled outgoing delivery that is pending in the receiver apply the given predicate and if it matches then settle the delivery. More...
|
| |
| IReceiver | Disposition (Predicate< IIncomingDelivery > filter, IDeliveryState state, bool settle) |
| | For each unsettled outgoing delivery that is pending in the receiver apply the given predicate and if it matches then apply the given delivery state and settled value to it. More...
|
| |
| IReceiver | DeliveryAbortedHandler (Action< IIncomingDelivery > handler) |
| | Handler for aborted deliveries that is called for each aborted in-progress delivery. This handler is an optional convenience handler that supplements the standard delivery read event handler in cases where the users wishes to break out the processing of inbound delivery data from abort processing. If this handler is not set the receiver will call the registered delivery read handler if one is set. More...
|
| |
| IReceiver | DeliveryReadHandler (Action< IIncomingDelivery > handler) |
| | Handler for incoming deliveries that is called for each incoming transfer frame that comprises either one complete delivery or a chunk of a split framed transfer. The handler should check that the delivery being read is partial or not and act accordingly, as partial deliveries expect additional updates as more frames comprising that delivery arrive or the remote aborts the transfer. More...
|
| |
| IReceiver | DeliveryStateUpdatedHandler (Action< IIncomingDelivery > handler) |
| | Handler for updates to the remote state of incoming deliveries that have previously been received. Remote state updates for an previously received delivery can happen when the remote settles a complete delivery or otherwise modifies the delivery outcome and the user needs to act on those changes such as a spontaneous update to the delivery state. More...
|
| |
| override T | Open () |
| | Open the end point locally, sending the Open performative immediately if possible or holding it until SASL negotiations or the AMQP header exchange and other required performative exchanges has completed. The endpoint will signal any registered handler of the remote opening the endpoint once the remote performative that signals open completion arrives. More...
|
| |
| T | Detach () |
| | Detaches the local end of the link if not already closed or detached. More...
|
| |
| override T | Close () |
| | Close the end point locally and send the closing performative immediately if possible or holds it until the Connection / Engine state allows it. If the engine encounters an error writing the performative or the engine is in a failed state from a previous error then this method will throw an exception. If the engine has been shutdown then this method will close out the local end of the endpoint and clean up any local resources before returning normally. More...
|
| |
| T | DetachHandler (Action< T > handler) |
| | Sets a EventHandler for when an AMQP detach frame is received from the remote peer. This is a convenience event that supplements the normal link closed event point if set. If no detached event handler is set the endpoint will route the detached event to the closed event handler if set and allow it to process the event in one location. More...
|
| |
| T | LocalDetachHandler (Action< T > handler) |
| | Sets a Action for when an this endpoint is closed locally via a call to Close. This is a convenience event that supplements the normal locally closed event point if set. If no local detached event handler is set the endpoint will route the detached event to the local closed event handler if set and allow it to process the event in one location. Typically used by clients for logging or other state update event processing. Clients should not perform any blocking calls within this context. It is an error for the handler to throw an exception and the outcome of doing so is undefined. More...
|
| |
| T | ParentEndpointClosedHandler (Action< T > handler) |
| | Sets a Action delegate for when the parent Session or Connection of this link is locally closed. Typically used by clients for logging or other state update event processing. Clients should not perform any blocking calls within this context. It is an error for the handler to throw an exception and the outcome of doing so is undefined. More...
|
| |
| T | CreditStateUpdateHandler (Action< T > handler) |
| | Handler for link credit updates that occur after a remote flow frame arrives. More...
|
| |
| T | Detach () |
| | Detaches the local end of the link if not already closed or detached. More...
|
| |
| T | LocalDetachHandler (Action< T > localDetachHandler) |
| | Sets a Action for when an this endpoint is closed locally via a call to Close. This is a convenience event that supplements the normal locally closed event point if set. If no local detached event handler is set the endpoint will route the detached event to the local closed event handler if set and allow it to process the event in one location. Typically used by clients for logging or other state update event processing. Clients should not perform any blocking calls within this context. It is an error for the handler to throw an exception and the outcome of doing so is undefined. More...
|
| |
| T | DetachHandler (Action< T > detachHandler) |
| | Sets a EventHandler for when an AMQP detach frame is received from the remote peer. This is a convenience event that supplements the normal link closed event point if set. If no detached event handler is set the endpoint will route the detached event to the closed event handler if set and allow it to process the event in one location. More...
|
| |
| T | CreditStateUpdateHandler (Action< T > handler) |
| | Handler for link credit updates that occur after a remote flow frame arrives. More...
|
| |
| T | ParentEndpointClosedHandler (Action< T > handler) |
| | Sets a Action delegate for when the parent Session or Connection of this link is locally closed. Typically used by clients for logging or other state update event processing. Clients should not perform any blocking calls within this context. It is an error for the handler to throw an exception and the outcome of doing so is undefined. More...
|
| |
|
|
override void | HandleRemoteAttach (Attach attach) |
| |
|
override void | HandleRemoteDetach (Detach detach) |
| |
|
override void | HandleRemoteFlow (Flow flow) |
| |
|
override void | HandleRemoteDisposition (Disposition disposition, ProtonOutgoingDelivery delivery) |
| |
|
override void | HandleRemoteDisposition (Disposition disposition, ProtonIncomingDelivery delivery) |
| |
|
override void | HandleRemoteTransfer (Transfer transfer, IProtonBuffer payload, out ProtonIncomingDelivery delivery) |
| |
|
override void | HandleDecorateOfOutgoingFlow (Flow flow) |
| |
|
override void | HandleSessionCreditStateUpdates (in ProtonSessionOutgoingWindow window) |
| |
|
override void | HandleSessionCreditStateUpdates (in ProtonSessionIncomingWindow window) |
| |
|
| ProtonLink (ProtonSession session, string name, ProtonLinkCreditState creditState) |
| |
|
abstract void | HandleRemoteAttach (Attach attach) |
| |
|
abstract void | HandleRemoteDetach (Detach detach) |
| |
|
abstract void | HandleRemoteFlow (Flow flow) |
| |
|
abstract void | HandleRemoteDisposition (Disposition disposition, ProtonOutgoingDelivery delivery) |
| |
|
abstract void | HandleRemoteDisposition (Disposition disposition, ProtonIncomingDelivery delivery) |
| |
|
abstract void | HandleRemoteTransfer (Transfer transfer, IProtonBuffer payload, out ProtonIncomingDelivery delivery) |
| |
|
abstract void | HandleDecorateOfOutgoingFlow (Flow flow) |
| |
|
virtual void | TransitionedToLocallyOpened () |
| |
|
virtual void | TransitionedToLocallyDetached () |
| |
|
virtual void | TransitionedToLocallyClosed () |
| |
|
virtual void | TransitionToRemotelyOpenedState () |
| |
|
virtual void | TransitionToRemotelyDetached () |
| |
|
virtual void | TransitionToRemotelyClosed () |
| |
|
virtual void | TransitionToParentLocallyClosed () |
| |
|
virtual void | TransitionToParentRemotelyClosed () |
| |
|
void | CheckLinkOperable (string failurePrefix) |
| |
|
bool | AreDeliveriesStillActive () |
| |
|
void | CheckNotOpened (string errorMessage) |
| |
|
void | CheckNotClosed (string errorMessage) |
| |
|
void | TrySyncLocalStateWithRemote () |
| |
|
|
IDeliveryState | DefaultDeliveryState [get, set] |
| |
|
SenderSettleMode | SenderSettleMode [get, set] |
| |
|
ReceiverSettleMode | ReceiverSettleMode [get, set] |
| |
|
Source | Source [get, set] |
| |
|
ITerminus | Terminus [get, set] |
| |
|
Coordinator | Coordinator [get, set] |
| |
|
Target | Target [get, set] |
| |
|
override Symbol[]?? | OfferedCapabilities [get, set] |
| |
|
override Symbol[]?? | DesiredCapabilities [get, set] |
| |
|
override Symbol[]?? | RemoteOfferedCapabilities [get] |
| |
|
override Symbol[]?? | RemoteDesiredCapabilities [get] |
| |
|
override IReadOnlyDictionary< Symbol, object > | Properties [get, set] |
| |
|
override IReadOnlyDictionary< Symbol, object > | RemoteProperties [get] |
| |
|
ulong | MaxMessageSize [get, set] |
| |
|
abstract uint | Credit [get] |
| |
|
abstract bool | IsDraining [get] |
| |
|
abstract Role | Role [get] |
| |
| IDeliveryState | DefaultDeliveryState [get, set] |
| | Configures a default DeliveryState to be used if a received delivery is settled/freed without any disposition state having been previously applied. More...
|
| |
| IReadOnlyCollection< IIncomingDelivery > | Unsettled [get] |
| | Retrieves the list of unsettled deliveries sent from this receiver. The deliveries in the enumerator cannot be written to but can have their settled state and disposition updated. Only when this receiver settles on its end are the outgoing delivery instances removed from the unsettled tracking. More...
|
| |
| bool | HasUnsettled [get] |
| | Returns true if the receiver link is tracking any unsettled sent deliveries. More...
|
| |
| bool | IsLocallyDetached [get] |
| | Returns true if the endpoint having been previously locally opened is now detached due to a call the the detach method. This does not reflect the state of the remote endpoint and that should be checked separately. More...
|
| |
| bool | IsLocallyClosedOrDetached [get] |
| | Returns true if the endpoint having been previously locally opened is now detached or closed due to a call to either the close method or the detach method. This does not reflect the state of the remote endpoint and that should be checked separately. More...
|
| |
| LinkState | LinkState [get] |
| | Gets the current state of the local end of the link object. More...
|
| |
| uint | Credit [get] |
| | Reads the credit that is currently available on or assigned to this link object. More...
|
| |
| bool | IsDraining [get] |
| | Indicates if the link is draining. For a sender link this indicates that the remote has requested that the sender transmit deliveries up to the currently available credit or indicate that it has no more to send. For a receiver this indicates that the Receiver has requested that the remote sender consume its outstanding credit. More...
|
| |
| Role | Role [get] |
| | Reads the role assigned to the local end of the link. More...
|
| |
| bool | IsSender [get] |
| | Returns if this link is a sender link. More...
|
| |
| bool | IsReceiver [get] |
| | Returns if this link is a receiver link. More...
|
| |
| IConnection | Connection [get] |
| | Provides access to the connection that owns this sender endpoint. More...
|
| |
| ISession | Session [get] |
| | Provides access to the session that owns this sender endpoint. More...
|
| |
| string | Name [get] |
| | Access the name that was given to the link on creation. More...
|
| |
| SenderSettleMode | SenderSettleMode [get, set] |
| | Access the sender settle mode. Should only be called during link set-up, i.e. before calling open. If this endpoint is the initiator of the link, this method can be used to set a value other than the default. If this endpoint is not the initiator, this method should be used to set a local value. According to the AMQP spec, the application may choose to accept the sender's suggestion (accessed by calling the remote sender settle mode API) or choose another value. The value has no effect on Proton, but may be useful to the application at a later point. In order to be AMQP compliant the application is responsible for honoring the settlement mode. More...
|
| |
| ReceiverSettleMode | ReceiverSettleMode [get, set] |
| | Access the receiver settle mode. Should only be called during link set-up, i.e. before calling open. If this endpoint is the initiator of the link, this method can be used to set a value other than the default. More...
|
| |
| Source | Source [get, set] |
| | Sets the Source value to assign to the local end of this link. Must be called during link setup, i.e. before calling the open method. More...
|
| |
| Source | RemoteSource [get] |
| | Gets the Source value that was assigned by the remote end of the link. More...
|
| |
| ITerminus | Terminus [get, set] |
| | Gets the local Target terminus value as a generic terminus instance which the user can then interrogate to determine if it is a Target or a Coordinator instance. When set the value must be one of Target or Coordinator. More...
|
| |
| ITerminus | RemoteTerminus [get] |
| | Get the remote set Terminus either Target or Coordinator that is set once the remote sends its attach frame. More...
|
| |
| Coordinator | Coordinator [get, set] |
| | Attempt to access the local target terminus value as a Coordinator value. When reading if the target terminus is not a Coordinator the result is null. Must be called during link setup, i.e. before calling the open method. More...
|
| |
| Target | Target [get, set] |
| | Attempt to access the local target terminus value as a Target value. When reading if the target terminus is not a Target the result is null. Must be called during link setup, i.e. before calling the open method. More...
|
| |
| ulong | MaxMessageSize [get, set] |
| | Sets the local link max message size, to be conveyed to the peer via the Attach frame when attaching the link to the session. Null or 0 means no limit. Must be called during link setup, i.e. before calling the open method. More...
|
| |
| bool | IsRemotelyDetached [get] |
| | Returns true if this link is currently remotely detached meaning the state returned from the remote state accessor is equal to detached. A link is remotely detached after an Detach performative has been received from the remote with the close flag equal to false. More...
|
| |
| bool | IsRemotelyClosedOrDetached [get] |
| | Returns true if this link is currently remotely detached or closed meaning the state returned from the remote state accessor is equal to detached or to closed. A link is remotely detached after an Detach performative has been received from the remote with the close flag equal to false otherwise is considered closed.. More...
|
| |
| SenderSettleMode | RemoteSenderSettleMode [get] |
| | Gets the remote link sender settlement mode, as conveyed from the peer via the Attach frame when attaching the link to the session. More...
|
| |
| ReceiverSettleMode | RemoteReceiverSettleMode [get] |
| | Gets the remote link receiver settlement mode, as conveyed from the peer via the Attach frame when attaching the link to the session. More...
|
| |
| LinkState | RemoteState [get] |
| | Gets the current remote link state. More...
|
| |
Proton Receiver link implementation which manages the receipt of new deliveries and credit associated with the link. Delivery outcomes and settlement states can also be managed from the receiver link.
Public Member Functions inherited from Apache.Qpid.Proton.Engine.Implementation.ProtonLink< IReceiver >