Class SourceLinkEndpoint

The AMQP link endpoint for a message source. Use this class to attach a link endpoint to an IMessageSource for sending outgoing messages. This class manages the link credit (flow control).

Inheritance
System.Object
LinkEndpoint
SourceLinkEndpoint
Inherited Members
System.Object.ToString()
System.Object.Equals(System.Object)
System.Object.Equals(System.Object, System.Object)
System.Object.ReferenceEquals(System.Object, System.Object)
System.Object.GetHashCode()
System.Object.GetType()
System.Object.MemberwiseClone()
Namespace: Amqp.Listener
Assembly: Amqp.Net.dll
Syntax
public class SourceLinkEndpoint : LinkEndpoint

Constructors

SourceLinkEndpoint(IMessageSource, ListenerLink)

Initializes a SourceLinkEndpoint object

Declaration
public SourceLinkEndpoint(IMessageSource messageSource, ListenerLink link)
Parameters
Type Name Description
IMessageSource messageSource

The associated message source.
ListenerLink link

The listener link.

Methods

OnDisposition(DispositionContext)

Notifies the message source the delivery state of an outgoing message.

Declaration
public override void OnDisposition(DispositionContext dispositionContext)
Parameters
Type Name Description
DispositionContext dispositionContext

Context of the received disposition performative.
Overrides

OnFlow(FlowContext)

Processes a received flow performative and start receiving from the message source if required.

Declaration
public override void OnFlow(FlowContext flowContext)
Parameters
Type Name Description
FlowContext flowContext

Context of the received flow performative.
Overrides