Interface IContainerHost

Represents an AMQP container that hosts processors.

Inherited Members

IContainer.ServiceCertificate

IContainer.CustomTransports

IContainer.CreateMessage(ByteBuffer)

IContainer.CreateLink(ListenerConnection, ListenerSession, Attach)

IContainer.AttachLink(ListenerConnection, ListenerSession, Link, Attach)

Namespace: Amqp.Listener

Assembly: Amqp.Net.dll

Syntax

public interface IContainerHost : IContainer

Methods

Close()

Closes the container host object.

Declaration

void Close()

Open()

Opens the container host object.

Declaration

void Open()

RegisterLinkProcessor(ILinkProcessor)

Registers a link processor to handle received attach performatives.

Declaration

void RegisterLinkProcessor(ILinkProcessor linkProcessor)

Parameters

Type	Name	Description
ILinkProcessor	linkProcessor	The link processor to be registered.

RegisterMessageProcessor(String, IMessageProcessor)

Registers a message processor to accept incoming messages from the specified address. When it is called, the container creates a node where the client can attach.

Declaration

void RegisterMessageProcessor(string address, IMessageProcessor messageProcessor)

Parameters

Type	Name	Description
System.String	address	The address.
IMessageProcessor	messageProcessor	The message processor to be registered.

RegisterMessageSource(String, IMessageSource)

Registers a message source at the specified address where client receives messages. When it is called, the container creates a node where the client can attach.

Declaration

void RegisterMessageSource(string address, IMessageSource messageSource)

Parameters

Type	Name	Description
System.String	address	The address.
IMessageSource	messageSource	The message source to be registered.

RegisterRequestProcessor(String, IRequestProcessor)

Registers a request processor from the specified address.

Declaration

void RegisterRequestProcessor(string address, IRequestProcessor requestProcessor)

Parameters

Type	Name	Description
System.String	address	The address.
IRequestProcessor	requestProcessor	The request processor to be registered.

Remarks

Client must create a pair of links (sending and receiving) at the address. The source.address on the sending link should contain an unique address in the client and it should be specified in target.address on the receiving link.

UnregisterLinkProcessor(ILinkProcessor)

Unregisters a link processor that was previously registered.

Declaration

void UnregisterLinkProcessor(ILinkProcessor linkProcessor)

Parameters

Type	Name	Description
ILinkProcessor	linkProcessor	The link processor to unregister.

Remarks

If the linkProcessor was not registered or is different from the current registered one, an exception is thrown.

UnregisterMessageProcessor(String)

Unregisters a message processor at the specified address.

Declaration

void UnregisterMessageProcessor(string address)

Parameters

Type	Name	Description
System.String	address	The address.

UnregisterMessageSource(String)

Unregisters a message source at the specified address.

Declaration

void UnregisterMessageSource(string address)

Parameters

Type	Name	Description
System.String	address	The address.

UnregisterRequestProcessor(String)

Unregisters a request processor at the specified address.

Declaration

void UnregisterRequestProcessor(string address)

Parameters

Type	Name	Description
System.String	address	The address.