Базовый потребитель сообщений очереди задач.
Inheritance
System.Object
TaskConsumerBase<T>
Namespace:InfinniPlatform.MessageQueue
Assembly:InfinniPlatform.MessageQueue.Abstractions.dll
public abstract class TaskConsumerBase<T> : object, ITaskConsumer, IConsumer
Type Parameters
Name |
Description |
T |
Тип тела сообщения.
|
Properties
|
Improve this Doc
View Source
Declaration
public Type MessageType { get; }
Property Value
Implements
Methods
|
Improve this Doc
View Source
Declaration
protected abstract Task Consume(Message<T> message)
Parameters
Type |
Name |
Description |
Message<T> |
message |
|
Returns
|
Improve this Doc
View Source
Declaration
protected virtual Task<bool> OnError(Exception exception)
Parameters
Type |
Name |
Description |
Exception |
exception |
|
Returns
Type |
Description |
Task<System.Boolean> |
|
Explicit Interface Implementations
|
Improve this Doc
View Source
Declaration
Task IConsumer.Consume(IMessage message)
Parameters
Returns
Implements
|
Improve this Doc
View Source
Declaration
Task<bool> IConsumer.OnError(Exception exception)
Parameters
Type |
Name |
Description |
Exception |
exception |
|
Returns
Type |
Description |
Task<System.Boolean> |
|
Implements
Extension Methods