Interface IContainer
Represents an AMQP container.
Namespace: Amqp.Listener
Assembly: Amqp.Net.dll
Syntax
public interface IContainer
Properties
CustomTransports
Gets the collection of custom transport providers. Key is the address scheme.
Declaration
IDictionary<string, TransportProvider> CustomTransports { get; }
Property Value
Type | Description |
---|---|
System.Collections.Generic.IDictionary<System.String, TransportProvider> |
ServiceCertificate
Gets the service certificate.
Declaration
X509Certificate2 ServiceCertificate { get; }
Property Value
Type | Description |
---|---|
System.Security.Cryptography.X509Certificates.X509Certificate2 |
Methods
AttachLink(ListenerConnection, ListenerSession, Link, Attach)
Attaches the link. Brokers/listen applications should perform necessary validations (security, resource condition, etc). If return value is true, an attach is sent to peer by the library, otherwise the implementation is responsible to send attach to move the link to attached state.
Declaration
bool AttachLink(ListenerConnection connection, ListenerSession session, Link link, Attach attach)
Parameters
Type | Name | Description |
---|---|---|
ListenerConnection | connection | The connection where attach was received. |
ListenerSession | session | The session where attach was received. |
Link | link | The link created in CreateLink call. |
Attach | attach | The received attach frame. |
Returns
Type | Description |
---|---|
System.Boolean | A boolean value indicating if attaching the link has completed. |
CreateLink(ListenerConnection, ListenerSession, Attach)
Creates an AMQP link for the attach request.
Declaration
Link CreateLink(ListenerConnection connection, ListenerSession session, Attach attach)
Parameters
Type | Name | Description |
---|---|---|
ListenerConnection | connection | The connection where attach was received. |
ListenerSession | session | The session where attach was received. |
Attach | attach | The received attach frame. |
Returns
Type | Description |
---|---|
Link | A Link object to be attached to the node specified by the attach performative. |
CreateMessage(ByteBuffer)
Creates an AMQP message from the buffer. This is useful for brokers/listen applications to create lightweight message objects without paying the full serialization cost.
Declaration
Message CreateMessage(ByteBuffer buffer)
Parameters
Type | Name | Description |
---|---|---|
ByteBuffer | buffer | The serialized message. |
Returns
Type | Description |
---|---|
Message | A message object created from the buffer. |