Class ConsumerBase<T>
Abstract class to define a base for all in Simplic used consumers
Inheritance
System.Object
ConsumerBase<T>
Namespace: Simplic.MessageBroker
Assembly: Simplic.MessageBroker.dll
Syntax
public abstract class ConsumerBase<T> : IConsumer<T> where T : classType Parameters
| Name | Description |
|---|---|
| T |
Constructors
| Improve this Doc View SourceConsumerBase(IKeyValueStore)
Initialize a new instance of ConsumerBase
Declaration
public ConsumerBase(IKeyValueStore keyValueStore)Parameters
| Type | Name | Description |
|---|---|---|
| IKeyValueStore | keyValueStore | An instance of IChannelPublisher |
Methods
| Improve this Doc View SourceConsume(ConsumeContext<T>)
Consumes a context. Gets called whenever the consumer gets a message of the given type
Declaration
public virtual async Task Consume(ConsumeContext<T> context)Parameters
| Type | Name | Description |
|---|---|---|
| ConsumeContext<T> | context | The consumer context of the given message type |
Returns
| Type | Description |
|---|---|
| System.Threading.Tasks.Task |
Execute(ConsumeContext<T>)
The Execute function that needs to be implemented and should contain the consumer logic
Declaration
public abstract Task Execute(ConsumeContext<T> message)Parameters
| Type | Name | Description |
|---|---|---|
| ConsumeContext<T> | message | The message of the consumed context |
Returns
| Type | Description |
|---|---|
| System.Threading.Tasks.Task |