Class MessageQueueConsumersManager
Предоставляет метод регистрации получателей сообщений из очереди.
Inheritance
System.Object
MessageQueueConsumersManager
Namespace:InfinniPlatform.MessageQueue.Hosting
Assembly:InfinniPlatform.MessageQueue.RabbitMQ.dll
Syntax
public class MessageQueueConsumersManager : object, IMessageQueueConsumersManager
Constructors
| Improve this Doc View SourceMessageQueueConsumersManager(MessageQueueThreadPool, IMessageSerializer, RabbitMqManager, ILogger<MessageQueueConsumersManager>, IPerformanceLogger<MessageQueueConsumersManager>)
Declaration
public MessageQueueConsumersManager(MessageQueueThreadPool messageQueueThreadPool, IMessageSerializer messageSerializer, RabbitMqManager manager, ILogger<MessageQueueConsumersManager> logger, IPerformanceLogger<MessageQueueConsumersManager> perfLogger)
Parameters
Type | Name | Description |
---|---|---|
MessageQueueThreadPool | messageQueueThreadPool | |
IMessageSerializer | messageSerializer | |
RabbitMqManager | manager | |
ILogger<MessageQueueConsumersManager> | logger | |
IPerformanceLogger<MessageQueueConsumersManager> | perfLogger |
Methods
| Improve this Doc View SourceRegisterConsumer(String, IConsumer)
Регистрирует обработчик.
Declaration
public void RegisterConsumer(string queueName, IConsumer consumer)
Parameters
Type | Name | Description |
---|---|---|
System.String | queueName | Имя очереди. |
IConsumer | consumer | Экземпляр получателя. |