Менеджер соединения с RabbitMQ.
Inheritance
System.Object
RabbitMqManager
Namespace:InfinniPlatform.MessageQueue.Management
Assembly:InfinniPlatform.MessageQueue.RabbitMQ.dll
public class RabbitMqManager : IDisposable
Constructors
|
Improve this Doc
View Source
Declaration
public RabbitMqManager(RabbitMqMessageQueueOptions options, AppOptions appOptions, ILogger<RabbitMqManager> logger)
Parameters
Properties
|
Improve this Doc
View Source
Declaration
public string BroadcastExchangeName { get; }
Property Value
Type |
Description |
System.String |
|
|
Improve this Doc
View Source
Declaration
public IConnection Connection { get; }
Property Value
Type |
Description |
IConnection |
|
Methods
|
Improve this Doc
View Source
Создает очередь для широковещательных сообщений по ключу.
Declaration
public string DeclareBroadcastQueue(string routingKey)
Parameters
Type |
Name |
Description |
System.String |
routingKey |
Ключ.
|
Returns
Type |
Description |
System.String |
|
|
Improve this Doc
View Source
Создает очередь для сообщений по имени.
Declaration
public string DeclareTaskQueue(string queueName)
Parameters
Type |
Name |
Description |
System.String |
queueName |
Имя очереди.
|
Returns
Type |
Description |
System.String |
|
|
Improve this Doc
View Source
Declaration
|
Improve this Doc
View Source
Declaration
public string GetBroadcastKey(string key)
Parameters
Type |
Name |
Description |
System.String |
key |
Ключ.
|
Returns
Type |
Description |
System.String |
|
|
Improve this Doc
View Source
Declaration
public IModel GetChannel()
Returns
|
Improve this Doc
View Source
Declaration
public IModel GetChannel(ushort prefetchCount)
Parameters
Type |
Name |
Description |
System.UInt16 |
prefetchCount |
|
Returns
|
Improve this Doc
View Source
Declaration
public string GetTaskKey(string key)
Parameters
Type |
Name |
Description |
System.String |
key |
Ключ.
|
Returns
Type |
Description |
System.String |
|
Events
|
Improve this Doc
View Source
Событие, вызываемое при восстановлении соединения с сервером RabbitMq.
Declaration
public event RabbitMqManager.ReconnectEventHandler OnReconnect
Event Type
Extension Methods