Interface IDestinationProvider
Provides methods for creating temporary destinations and resolving named destinations (queues and topics) in a messaging system.
Namespace: CodersRealm.AmqpClient
Assembly: CodersRealm.AmqpClient.dll
Syntax
public interface IDestinationProviderMethods
CreateTemporaryQueueAsync()
Create a temporary queue bound to the underlying connection/session.
Declaration
Task<ITemporaryQueue?> CreateTemporaryQueueAsync()Returns
| Type | Description |
|---|---|
| Task<ITemporaryQueue> | The created ITemporaryQueue or |
CreateTemporaryTopicAsync()
Create a temporary topic bound to the underlying connection/session.
Declaration
Task<ITemporaryTopic?> CreateTemporaryTopicAsync()Returns
| Type | Description |
|---|---|
| Task<ITemporaryTopic> | The created ITemporaryTopic or |
GetQueueAsync(string)
Resolve a named queue on the broker and return an IQueue reference.
Declaration
Task<IQueue?> GetQueueAsync(string queueName)Parameters
| Type | Name | Description |
|---|---|---|
| string | queueName | The name of the queue to resolve. |
Returns
| Type | Description |
|---|---|
| Task<IQueue> | The resolved IQueue or |
Exceptions
| Type | Condition |
|---|---|
| ArgumentException | Thrown when |
GetTopicAsync(string)
Resolve a named topic on the broker and return an ITopic reference.
Declaration
Task<ITopic?> GetTopicAsync(string topicName)Parameters
| Type | Name | Description |
|---|---|---|
| string | topicName | The name of the topic to resolve. |
Returns
| Type | Description |
|---|---|
| Task<ITopic> | The resolved ITopic or |
Exceptions
| Type | Condition |
|---|---|
| ArgumentException | Thrown when |